@Deprecated public class JMSBridgeTopic extends Topic
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.
Modifier and Type | Field and Description |
---|---|
private long |
arrivalsCounter
Deprecated.
Counter for keeping the original delivery order.
|
private JMSBridgeModule |
jmsModule
Deprecated.
The JMS module for accessing the foreign JMS destination.
|
private Hashtable |
outTable
Deprecated.
Table persisting the outgoing messages until acknowledgment by the
bridge module.
|
private static long |
serialVersionUID
Deprecated.
define serialVersionUID for interoperability
|
alreadySentLocally, fatherId, friends, logger, nbMsgsReceiveSinceCreation, selectors, subscribers
_rights, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, task, WAKEUP_PERIOD, WRITE
agentProfiling, emptyString, fixed, logmon
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
Constructor and Description |
---|
JMSBridgeTopic()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
agentFinalize(boolean lastTime)
Deprecated.
Finalizes the agent before it is garbaged.
|
private void |
bridgeAckNot(JMSBridgeAckNot not)
Deprecated.
Reacts to
BridgeAckNot notifications holding the identifier
of a message successfuly delivered to the foreign JMS server. |
private void |
bridgeDeliveryNot(AgentId from,
JMSBridgeDeliveryNot not)
Deprecated.
Reacts to
BridgeDeliveryNot notifications holding a message
received from the foreign JMS server. |
private void |
close()
Deprecated.
|
protected void |
doDeleteNot(DeleteNot not)
Deprecated.
Method specifically processing a
fr.dyade.aaa.agent.DeleteNot instance. |
void |
initialize(boolean firstTime)
Deprecated.
Initializes the destination.
|
void |
postSubscribe()
Deprecated.
Method specializing the reaction to a
SubscribeRequest
instance. |
ClientMessages |
preProcess(AgentId from,
ClientMessages not)
Deprecated.
Method specializing the reaction to a
ClientMessages
instance. |
void |
preUnsubscribe()
Deprecated.
Method specializing the reaction to an
UnsubscribeRequest
instance. |
void |
react(AgentId from,
Notification not)
Deprecated.
Specializes this
Topic method for processing the
specific bridge notifications. |
void |
setProperties(Properties prop,
boolean firstTime)
Deprecated.
Configures a
BridgeTopic instance. |
void |
topicForwardNot(AgentId from,
TopicForwardNot not)
Deprecated.
Method specializing the reaction to a
TopicForwardNot
instance, carrying messages forwarded by a cluster fellow or a
hierarchical son. |
String |
toString()
Deprecated.
Returns a string representation of this destination.
|
clusterJoin, clusterJoinAck, createTopicForward, doClientMessages, doRightRequest, doUnknownAgent, finalize, forwardMessages, forwardMessages, getClusterElements, getNbMsgsReceiveSinceCreation, getNumberOfSubscribers, getStats, getSubscriberIds, getTxName, getType, handleAdminRequestNot, postUnsubscribe, preSubscribe, processMessages, sendToCluster, setAlreadySentLocally, subscribeRequest, unsubscribeRequest, wakeUpNot
agentInitialize, clientMessages, decode, delete, deleteNot, encode, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getEncodedSize, getJMXStatistics, getMBeanName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, handleDeniedMessage, interceptorsAvailable, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isValidJMXAttribute, isWriter, postProcess, processAdminCommand, processInterceptors, processSetRight, processStartHandler, processStopHandler, replyToTopic, requestGroupNot, setAdminId, setFreeReading, setFreeWriting, setPeriod, setRight, unknownAgent
agentSave, delete, delete, deploy, deploy, getAgentId, getCommitTime, getEncodableClassId, getId, getLogTopic, getName, getReactNb, getReactTime, hasName, isAgentProfiling, isDeployed, isFixed, isUpdated, needToBeCommited, resetCommitTime, resetReactTime, resetTimer, save, sendTo, sendTo, sendTo, setAgentProfiling, setName, setNoSave, setSave
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod
getAgentId, getCommitTime, getReactNb, getReactTime, isAgentProfiling, isFixed, resetCommitTime, resetReactTime, resetTimer, setAgentProfiling
private static final long serialVersionUID
private JMSBridgeModule jmsModule
private long arrivalsCounter
private Hashtable outTable
Key: message identifier
Value: message
public void setProperties(Properties prop, boolean firstTime) throws Exception
BridgeTopic
instance.setProperties
in class Destination
prop
- The initial set of properties.Exception
public void initialize(boolean firstTime)
initialize
in class Topic
firstTime
- true when first called by the factorypublic void react(AgentId from, Notification not) throws Exception
Topic
method for processing the
specific bridge notifications.public void agentFinalize(boolean lastTime)
Destination
agentFinalize
in class Destination
lastTime
- true when last called by the factory on agent deletion.public String toString()
Topic
toString
in interface AgentMBean
toString
in interface DestinationMBean
toString
in class Topic
private void bridgeDeliveryNot(AgentId from, JMSBridgeDeliveryNot not)
BridgeDeliveryNot
notifications holding a message
received from the foreign JMS server.private void bridgeAckNot(JMSBridgeAckNot not)
BridgeAckNot
notifications holding the identifier
of a message successfuly delivered to the foreign JMS server.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
private void close()
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.