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

java.lang.Object
  org.objectweb.joram.mom.dest.DestinationImpl
      org.objectweb.joram.mom.dest.TopicImpl
          org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl

All Implemented Interfaces:

java.io.Serializable, DestinationImplMBean, TopicImplMBean

public class JMSBridgeTopicImpl
extends TopicImpl

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.

See Also:

Serialized Form

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, agent, clients, creationDate, dmqId, freeReading, freeWriting, logger, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, WRITE

Constructor Summary

JMSBridgeTopicImpl(fr.dyade.aaa.agent.AgentId adminId, java.util.Properties prop)
Constructs a BridgeTopicImpl instance.

Method Summary

void	bridgeAckNot(JMSBridgeAckNot not) Reacts to BridgeAckNot notifications holding the identifier of a message successfuly delivered to the foreign JMS server.
void	bridgeDeliveryNot(fr.dyade.aaa.agent.AgentId from, JMSBridgeDeliveryNot not) Reacts to BridgeDeliveryNot notifications holding a message received from the foreign JMS server.
protected void	doDeleteNot(fr.dyade.aaa.agent.DeleteNot not) Method specifically processing a fr.dyade.aaa.agent.DeleteNot instance.
void	initialize(boolean firstTime) Initializes the destination.
void	postSubscribe(SubscribeRequest not) Method specializing the reaction to a SubscribeRequest instance.
ClientMessages	preProcess(fr.dyade.aaa.agent.AgentId from, ClientMessages not) Method specializing the reaction to a ClientMessages instance.
void	preUnsubscribe(UnsubscribeRequest not) Method specializing the reaction to an UnsubscribeRequest instance.
void	topicForwardNot(fr.dyade.aaa.agent.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.TopicImpl

clusterAck, clusterNot, clusterRequest, clusterTest, destinationAdminRequestNot, doClientMessages, doRightRequest, doUnknownAgent, fatherAck, fatherTest, forwardMessages, getNbMsgsReceiveSinceCreation, getSubscriberIds, monitGetCluster, monitGetFather, monitGetSubscriptions, postUnsubscribe, preSubscribe, processMessages, setAlreadySentLocally, setFatherRequest, subscribeRequest, unclusterNot, unclusterRequest, unsetFatherRequest, unsubscribeRequest

Methods inherited from class org.objectweb.joram.mom.dest.DestinationImpl

canBeDeleted, clientMessages, deleteNot, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getId, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getRight, getRights, getStatisticHashtable, handleDeniedMessage, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isWriter, monitFreeAccess, monitGetDMQSettings, monitGetReaders, monitGetStat, monitGetWriters, postProcess, postProcess, preProcess, processSetRight, replyToTopic, requestGroupNot, setAgent, setDMQRequest, setFreeReading, setFreeWriting, setRightRequest, specialAdminProcess, specialAdminRequest, unknownAgent

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, getNbMsgsSentToDMQSinceCreation, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting

Constructor Detail

JMSBridgeTopicImpl

public JMSBridgeTopicImpl(fr.dyade.aaa.agent.AgentId adminId,
                          java.util.Properties prop)

Constructs a BridgeTopicImpl instance.

Parameters:

adminId - Identifier of the administrator of the topic.

prop - The initial set of properties.

Method Detail

initialize

public void initialize(boolean firstTime)

Initializes the destination.

Overrides:

initialize in class TopicImpl

Parameters:

firstTime - true when first called by the factory

toString

public java.lang.String toString()

Description copied from class: TopicImpl

Returns a string representation of this destination.

Specified by:

toString in interface DestinationImplMBean

Overrides:

toString in class TopicImpl

bridgeDeliveryNot

public void bridgeDeliveryNot(fr.dyade.aaa.agent.AgentId from,
                              JMSBridgeDeliveryNot not)

Reacts to BridgeDeliveryNot notifications holding a message received from the foreign JMS server.

bridgeAckNot

public void bridgeAckNot(JMSBridgeAckNot not)

Reacts to BridgeAckNot notifications holding the identifier of a message successfuly delivered to the foreign JMS server.

postSubscribe

public void postSubscribe(SubscribeRequest not)

Method specializing the reaction to a SubscribeRequest instance.

This method sets, if needed, a JMS listener on the foreign JMS consumer.

Overrides:

postSubscribe in class TopicImpl

Throws:

AccessException - If the sender is not a READER.

preUnsubscribe

public void preUnsubscribe(UnsubscribeRequest not)

Method specializing the reaction to an UnsubscribeRequest instance.

This method unsets, if needed, the JMS listener on the foreign JMS consumer.

Overrides:

preUnsubscribe in class TopicImpl

topicForwardNot

public void topicForwardNot(fr.dyade.aaa.agent.AgentId from,
                            TopicForwardNot not)

Method specializing the reaction to a 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.

Overrides:

topicForwardNot in class TopicImpl

preProcess

public ClientMessages preProcess(fr.dyade.aaa.agent.AgentId from,
                                 ClientMessages not)

Method specializing the reaction to a 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.

Overrides:

preProcess in class DestinationImpl

doDeleteNot

protected void doDeleteNot(fr.dyade.aaa.agent.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 TopicImpl