|
Joram ${version} | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.mom.dest.DestinationImpl
org.objectweb.joram.mom.dest.TopicImpl
org.objectweb.joram.mom.dest.BridgeTopicImpl
The BridgeTopicImpl
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.TopicImpl |
alreadySentLocally, fatherId, friends, selectors, subscribers |
Fields inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
_rights, clients, creationDate, destId, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSendToDMQSinceCreation, READ, READWRITE, WRITE |
Constructor Summary | |
BridgeTopicImpl(fr.dyade.aaa.agent.AgentId destId,
fr.dyade.aaa.agent.AgentId adminId)
Constructs a BridgeTopicImpl instance. |
Method Summary | |
protected void |
doProcess(ClientMessages not)
Method specializing the reaction to a ClientMessages
instance. |
protected void |
doProcess(fr.dyade.aaa.agent.DeleteNot not)
Method specifically processing a fr.dyade.aaa.agent.DeleteNot instance. |
protected void |
doReact(fr.dyade.aaa.agent.AgentId from,
SubscribeRequest not)
Method specializing the reaction to a SubscribeRequest
instance. |
protected void |
doReact(fr.dyade.aaa.agent.AgentId from,
org.objectweb.joram.mom.dest.TopicForwardNot not)
Method specializing the reaction to a TopicForwardNot
instance, carrying messages forwarded by a cluster fellow or a
hierarchical son. |
protected void |
doReact(fr.dyade.aaa.agent.AgentId from,
UnsubscribeRequest not)
Method specializing the reaction to an UnsubscribeRequest
instance. |
protected void |
doReact(BridgeAckNot not)
Reacts to BridgeAckNot notifications holding the identifier
of a message successfuly delivered to the foreign JMS server. |
protected void |
doReact(BridgeDeliveryNot not)
Reacts to BridgeDeliveryNot notifications holding a message
received from the foreign JMS server. |
void |
init(java.util.Properties prop)
Initiales the topic's JMS module. |
void |
react(fr.dyade.aaa.agent.AgentId from,
fr.dyade.aaa.agent.Notification not)
Specializes this TopicImpl method for processing the
specific bridge notifications. |
java.lang.String |
toString()
Returns a string representation of this destination. |
Methods inherited from class org.objectweb.joram.mom.dest.TopicImpl |
doProcess, doProcess, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, forwardMessages, getSubscriberIds, processMessages, specialProcess |
Methods inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
canBeDeleted, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getNbMsgsDeliverSinceCreation, getNbMsgsReceiveSinceCreation, getNbMsgsSendToDMQSinceCreation, getRight, getRights, isAdministrator, isFreeReading, isFreeWriting, isReader, isWriter, processSetRight, sendToDMQ, setFreeReading, setFreeWriting, specialAdminProcess |
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.DestinationImplMBean |
getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getNbMsgsDeliverSinceCreation, getNbMsgsReceiveSinceCreation, getNbMsgsSendToDMQSinceCreation, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting |
Constructor Detail |
public BridgeTopicImpl(fr.dyade.aaa.agent.AgentId destId, fr.dyade.aaa.agent.AgentId adminId)
BridgeTopicImpl
instance.
destId
- Identifier of the agent hosting the topic.adminId
- Identifier of the administrator of the topic.Method Detail |
public java.lang.String toString()
TopicImpl
toString
in interface DestinationImplMBean
toString
in class TopicImpl
public void init(java.util.Properties prop)
java.lang.IllegalStateException
- If the provided JMS properties are
invalid.public void react(fr.dyade.aaa.agent.AgentId from, fr.dyade.aaa.agent.Notification not) throws fr.dyade.aaa.agent.UnknownNotificationException
TopicImpl
method for processing the
specific bridge notifications.
react
in class TopicImpl
fr.dyade.aaa.agent.UnknownNotificationException
- If a received notification is
unexpected by the topic.protected void doReact(BridgeDeliveryNot not)
BridgeDeliveryNot
notifications holding a message
received from the foreign JMS server.
protected void doReact(BridgeAckNot not)
BridgeAckNot
notifications holding the identifier
of a message successfuly delivered to the foreign JMS server.
protected void doReact(fr.dyade.aaa.agent.AgentId from, SubscribeRequest not) throws AccessException
SubscribeRequest
instance.
This method sets, if needed, a JMS listener on the foreign JMS consumer.
doReact
in class TopicImpl
AccessException
- If the sender is not a READER.protected void doReact(fr.dyade.aaa.agent.AgentId from, UnsubscribeRequest not)
UnsubscribeRequest
instance.
This method unsets, if needed, the JMS listener on the foreign JMS consumer.
doReact
in class TopicImpl
protected void doReact(fr.dyade.aaa.agent.AgentId from, org.objectweb.joram.mom.dest.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.
doReact
in class TopicImpl
protected void doProcess(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.
doProcess
in class TopicImpl
protected void doProcess(fr.dyade.aaa.agent.DeleteNot not)
fr.dyade.aaa.agent.DeleteNot
instance.
This method closes the JMS resources used for connecting to the foreign JMS server.
doProcess
in class TopicImpl
|
Joram ${version} | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |