org.objectweb.joram.mom.dest.jmsbridge
Class JMSBridgeQueue

java.lang.Object
  extended by fr.dyade.aaa.agent.Agent
      extended by org.objectweb.joram.mom.dest.Destination
          extended by org.objectweb.joram.mom.dest.Queue
              extended by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueue
All Implemented Interfaces:
AgentMBean, BagSerializer, java.io.Serializable, DestinationMBean, QueueMBean

public class JMSBridgeQueue
extends Queue

The BridgeQueue class implements a specific queue which forwards the messages it receives to a foreign JMS destination, and gets the messages it is requested to deliver from the same foreign destination.

This queue is in fact a bridge linking JORAM and a foreign JMS server.

See Also:
Serialized Form

Field Summary
 
Fields inherited from class org.objectweb.joram.mom.dest.Queue
arrivalsCounter, consumers, contexts, deliveredMsgs, logger, messages, nbMaxMsg, receiving, requests
 
Fields inherited from class org.objectweb.joram.mom.dest.Destination
_rights, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, task, WAKEUP_PERIOD, WRITE
 
Fields inherited from class fr.dyade.aaa.agent.Agent
emptyString, fixed, logmon
 
Constructor Summary
JMSBridgeQueue()
           
 
Method Summary
 void agentFinalize(boolean lastTime)
          Finalizes the agent before it is garbaged.
protected  void doDeleteNot(DeleteNot not)
          Method specifically processing a fr.dyade.aaa.agent.DeleteNot instance.
 void initialize(boolean firstTime)
          Initializes the destination.
 ClientMessages preProcess(AgentId from, ClientMessages not)
          Method specializing the processing of a ClientMessages instance.
 void react(AgentId from, Notification not)
          Specializes this Queue method for processing the specific bridge notifications.
 void receiveRequest(AgentId from, ReceiveRequest not)
          Method specializing the reaction to a ReceiveRequest instance, requesting a message.
 void setProperties(java.util.Properties prop)
          Configures a BridgeQueue instance.
 java.lang.String toString()
          Returns a string representation of this destination.
 
Methods inherited from class org.objectweb.joram.mom.dest.Queue
abortReceiveRequest, acknowledgeRequest, addClientMessages, addMessage, browseRequest, checkDelivery, cleanPendingMessage, cleanPendingMessage, cleanWaitingRequest, cleanWaitingRequest, deliverMessages, denyRequest, doClientMessages, doRightRequest, doUnknownAgent, getClientMessages, getDefaultDMQId, getDefaultThreshold, getDeliveredMessageCount, getMessage, getMessages, getMessagesView, getMsgTxPrefix, getNbMaxMsg, getNbMsgsReceiveSinceCreation, getPendingMessageCount, getQueueMessage, getThreshold, getType, getWaitingRequestCount, handleAdminRequestNot, handleExpiredNot, isUndeliverable, isValidJMXAttribute, messageDelivered, messageRemoved, readBag, setMsgTxName, setNbMaxMsg, setThreshold, storeMessage, storeMessageHeader, wakeUpNot, writeBag
 
Methods inherited from class org.objectweb.joram.mom.dest.Destination
agentInitialize, clientMessages, delete, deleteNot, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getJMXStatistics, getMBeanName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, handleDeniedMessage, interceptorsAvailable, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isWriter, postProcess, processAdminCommand, processInterceptors, processSetRight, processStartHandler, processStopHandler, replyToTopic, requestGroupNot, setAdminId, setFreeReading, setFreeWriting, setPeriod, setRight, unknownAgent, updateProperties
 
Methods inherited from class fr.dyade.aaa.agent.Agent
delete, delete, deploy, deploy, getAgentId, getCommitTime, getId, getLogTopic, getName, getReactNb, getReactTime, isDeployed, isFixed, needToBeCommited, save, sendTo, sendTo, sendTo, setName, setNoSave, setSave
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.objectweb.joram.mom.dest.DestinationMBean
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod
 
Methods inherited from interface fr.dyade.aaa.agent.AgentMBean
getAgentId, getCommitTime, getReactNb, getReactTime, isFixed
 

Constructor Detail

JMSBridgeQueue

public JMSBridgeQueue()
Method Detail

setProperties

public void setProperties(java.util.Properties prop)
                   throws RequestException
Configures a BridgeQueue instance.

Overrides:
setProperties in class Destination
Parameters:
prop - The initial set of properties.
Throws:
RequestException

initialize

public void initialize(boolean firstTime)
Initializes the destination.

Overrides:
initialize in class Queue
Parameters:
firstTime - true when first called by the factory

react

public void react(AgentId from,
                  Notification not)
           throws java.lang.Exception
Specializes this Queue method for processing the specific bridge notifications.

Overrides:
react in class Queue
Parameters:
from - agent sending notification
not - notification to react to
Throws:
java.lang.Exception

agentFinalize

public void agentFinalize(boolean lastTime)
Description copied from class: Destination
Finalizes the agent before it is garbaged.

Overrides:
agentFinalize in class Destination
Parameters:
lastTime - true when last called by the factory on agent deletion.

toString

public java.lang.String toString()
Description copied from class: Queue
Returns a string representation of this destination.

Specified by:
toString in interface AgentMBean
Specified by:
toString in interface DestinationMBean
Overrides:
toString in class Queue
Returns:
A string representation of this agent.

receiveRequest

public void receiveRequest(AgentId from,
                           ReceiveRequest not)
                    throws AccessException
Method specializing the reaction to a ReceiveRequest instance, requesting a message.

This method stores the request and requests a message through the JMS interface.

Overrides:
receiveRequest in class Queue
Throws:
AccessException - If the sender is not a reader.

preProcess

public ClientMessages preProcess(AgentId from,
                                 ClientMessages not)
Method specializing the processing of a ClientMessages instance.

This method sends the messages to the foreign JMS destination.

Overrides:
preProcess in class Destination
Parameters:
from - The sender of the message
not - The incoming messages.
Returns:
The incoming messages after processing.

doDeleteNot

protected void doDeleteNot(DeleteNot not)
Method specifically processing a fr.dyade.aaa.agent.DeleteNot instance.

This method closes the JMS resources used for connecting to the foreign JMS server.

Overrides:
doDeleteNot in class Queue


Copyright © 2011 ScalAgent D.T.. All Rights Reserved.