|
||||||||||
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.Topic
org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopic
public class JMSBridgeTopic
The BridgeTopic
class implements a specific topic 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 topic is in fact a bridge linking JORAM and a foreign JMS server, and which is accessible through the Pub/Sub communication mode.
Field Summary |
---|
Fields inherited from class org.objectweb.joram.mom.dest.Topic |
---|
alreadySentLocally, fatherId, friends, logger, selectors, subscribers |
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 | |
---|---|
JMSBridgeTopic()
|
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. |
void |
postSubscribe()
Method specializing the reaction to a SubscribeRequest
instance. |
ClientMessages |
preProcess(AgentId from,
ClientMessages not)
Method specializing the reaction to a ClientMessages
instance. |
void |
preUnsubscribe()
Method specializing the reaction to an UnsubscribeRequest
instance. |
void |
react(AgentId from,
Notification not)
Specializes this Topic method for processing the
specific bridge notifications. |
void |
setProperties(java.util.Properties prop)
Configures a BridgeTopic instance. |
void |
topicForwardNot(AgentId from,
TopicForwardNot not)
Method specializing the reaction to a TopicForwardNot
instance, carrying messages forwarded by a cluster fellow or a
hierarchical son. |
java.lang.String |
toString()
Returns a string representation of this destination. |
Methods inherited from class org.objectweb.joram.mom.dest.Topic |
---|
clusterJoin, clusterJoinAck, doClientMessages, doRightRequest, doUnknownAgent, forwardMessages, getClusterElements, getNbMsgsReceiveSinceCreation, getNumberOfSubscribers, getSubscriberIds, getType, handleAdminRequestNot, postUnsubscribe, preSubscribe, processMessages, sendToCluster, setAlreadySentLocally, subscribeRequest, unsubscribeRequest, wakeUpNot |
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 JMSBridgeTopic()
Method Detail |
---|
public void setProperties(java.util.Properties prop) throws RequestException
BridgeTopic
instance.
setProperties
in class Destination
prop
- The initial set of properties.
RequestException
public void initialize(boolean firstTime)
initialize
in class Topic
firstTime
- true when first called by the factorypublic void react(AgentId from, Notification not) throws java.lang.Exception
Topic
method for processing the
specific bridge notifications.
react
in class Topic
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()
Topic
toString
in interface AgentMBean
toString
in interface DestinationMBean
toString
in class Topic
public void postSubscribe()
SubscribeRequest
instance.
This method sets, if needed, a JMS listener on the foreign JMS consumer.
postSubscribe
in class Topic
AccessException
- If the sender is not a READER.public void preUnsubscribe()
UnsubscribeRequest
instance.
This method unsets, if needed, the JMS listener on the foreign JMS consumer.
preUnsubscribe
in class Topic
public void topicForwardNot(AgentId from, TopicForwardNot not)
TopicForwardNot
instance, carrying messages forwarded by a cluster fellow or a
hierarchical son.
This method forwards the messages, if needed, to the hierarchical father, and to the foreign JMS destination.
topicForwardNot
in class Topic
public ClientMessages preProcess(AgentId from, ClientMessages not)
ClientMessages
instance.
This method may forward the messages to the topic father if any, or to the cluster fellows if any, and 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 Topic
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |