|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectfr.dyade.aaa.agent.Agent
org.objectweb.joram.mom.dest.Destination
org.objectweb.joram.mom.dest.Queue
org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueue
public class JMSBridgeQueue
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.
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 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 |
---|
public JMSBridgeQueue()
Method Detail |
---|
public void setProperties(java.util.Properties prop) throws RequestException
BridgeQueue
instance.
setProperties
in class Destination
prop
- The initial set of properties.
RequestException
public void initialize(boolean firstTime)
initialize
in class Queue
firstTime
- true when first called by the factorypublic void react(AgentId from, Notification not) throws java.lang.Exception
Queue
method for processing the
specific bridge notifications.
react
in class Queue
from
- agent sending notificationnot
- notification to react to
java.lang.Exception
public void agentFinalize(boolean lastTime)
Destination
agentFinalize
in class Destination
lastTime
- true when last called by the factory on agent deletion.public java.lang.String toString()
Queue
toString
in interface AgentMBean
toString
in interface DestinationMBean
toString
in class Queue
public void receiveRequest(AgentId from, ReceiveRequest not) throws AccessException
ReceiveRequest
instance, requesting a message.
This method stores the request and requests a message through the JMS interface.
receiveRequest
in class Queue
AccessException
- If the sender is not a reader.public ClientMessages preProcess(AgentId from, ClientMessages not)
ClientMessages
instance.
This method sends the messages to the foreign JMS destination.
preProcess
in class Destination
from
- The sender of the messagenot
- The incoming messages.
protected void doDeleteNot(DeleteNot not)
fr.dyade.aaa.agent.DeleteNot
instance.
This method closes the JMS resources used for connecting to the foreign JMS server.
doDeleteNot
in class Queue
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |