@Deprecated public class JMSBridgeQueue extends Queue
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.
Queue.QueueFactory
Modifier and Type | Field and Description |
---|---|
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
|
ARRIVAL_STATE_PREFIX, arrivalState, DELIVERY_TABLE_PREFIX, deliveryTable, logger, logmsg, messages, nbExpirations, nbMaxMsg, nbMsgsDeniedSinceCreation, receiving, requests
_rights, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, strictCounters, task, temporary, 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 |
---|
JMSBridgeQueue()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
agentFinalize(boolean lastTime)
Deprecated.
Finalizes the agent before it is garbaged.
|
private void |
bridgeAck(JMSBridgeAckNot not)
Deprecated.
Reacts to
BridgeAckNot notifications holding the identifier
of a message successfully delivered to the foreign JMS server. |
private void |
bridgeDelivery(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. |
int |
getEncodableClassId()
Deprecated.
Enables the sub classes not to implement this method.
|
void |
initialize(boolean firstTime)
Deprecated.
Initializes the destination.
|
ClientMessages |
preProcess(AgentId from,
ClientMessages not)
Deprecated.
Method specializing the processing of a
ClientMessages
instance. |
void |
react(AgentId from,
Notification not)
Deprecated.
Specializes this
Queue method for processing the
specific bridge notifications. |
void |
receiveRequest(AgentId from,
ReceiveRequest not)
Deprecated.
Method specializing the reaction to a
ReceiveRequest
instance, requesting a message. |
void |
setProperties(Properties prop,
boolean firstTime)
Deprecated.
Configures a
BridgeQueue instance. |
String |
toString()
Deprecated.
Returns a string representation of this destination.
|
abortReceiveRequest, acknowledgeRequest, addClientMessages, addMessage, agentSave, browseRequest, checkDelivery, cleanPendingMessage, cleanPendingMessage, cleanWaitingRequest, cleanWaitingRequest, decode, deliverMessages, denyRequest, doClientMessages, doRightRequest, doUnknownAgent, encode, finalize, getClientMessages, getConsumerLoad, getDefaultDMQId, getDefaultRedeliveryDelay, getDefaultThreshold, getDelayedMessageCount, getDeliveredMessageCount, getDeliveryDelay, getEncodedSize, getMessage, getMessages, getMessagesView, getMsgTxPrefix, getNbMaxMsg, getNbMsgsDeliverSinceCreation, getNbMsgsDeniedSinceCreation, getNbMsgsReceiveSinceCreation, getPendingMessageCount, getProducerLoad, getQueueMessage, getRedeliveryDelay, getStats, getThreshold, getType, getWaitingRequestCount, handleAdminRequestNot, handleExpiredNot, isPause, isSyncExceptionOnFullDest, isUndeliverable, isValidJMXAttribute, messageDelivered, messageRemoved, setDefaultRedeliveryDelay, setDeliveryDelay, setMsgTxName, setNbMaxMsg, setPause, setRedeliveryDelay, setSyncExceptionOnFullDest, setThreshold, storeMessage, storeMessageHeader, wakeUpNot
agentInitialize, clientMessages, delete, deleteNot, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getJMXStatistics, getMBeanName, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, handleDeniedMessage, interceptorsAvailable, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isWriter, postProcess, processAdminCommand, processInterceptors, processPause, processSetRight, processStartHandler, processStopHandler, replyToTopic, requestGroupNot, setAdminId, setFreeReading, setFreeWriting, setPeriod, setRight, unknownAgent
delete, delete, deploy, deploy, getAgentId, getCommitTime, 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, 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 Hashtable outTable
Key: message identifier
Value: message
public void setProperties(Properties prop, boolean firstTime) throws Exception
BridgeQueue
instance.setProperties
in class Queue
prop
- The initial set of properties.Exception
public void initialize(boolean firstTime) throws Exception
initialize
in class Queue
firstTime
- true when first called by the factoryException
public void react(AgentId from, Notification not) throws Exception
Queue
method for processing the
specific bridge notifications.public void agentFinalize(boolean lastTime)
Destination
agentFinalize
in class Destination
lastTime
- true if the destination is deletedpublic String toString()
Queue
toString
in interface AgentMBean
toString
in interface DestinationMBean
toString
in class Queue
private void bridgeDelivery(AgentId from, JMSBridgeDeliveryNot not)
BridgeDeliveryNot
notifications holding a message
received from the foreign JMS server.from
- AgentIdnot
- BridgeDeliveryNotprivate void bridgeAck(JMSBridgeAckNot not)
BridgeAckNot
notifications holding the identifier
of a message successfully delivered to the foreign JMS server.not
- BridgeAckNotpublic 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
private void close()
public int getEncodableClassId()
Agent
getEncodableClassId
in interface Encodable
getEncodableClassId
in class Queue
Copyright © 2020 ScalAgent D.T.. All rights reserved.