|
|||||||||
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.QueueImpl
org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl
public class JMSBridgeQueueImpl
The BridgeQueueImpl
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.
Field Summary | |
---|---|
private JMSBridgeModule |
jmsModule
The JMS module for accessing the foreign JMS destination. |
private java.util.Hashtable |
outTable
Table persisting the outgoing messages until acknowledgement by the bridge module. |
private static long |
serialVersionUID
define serialVersionUID for interoperability |
Fields inherited from class org.objectweb.joram.mom.dest.QueueImpl |
---|
arrivalsCounter, consumers, contexts, deliveredMsgs, logger, messages, nbMaxMsg, receiving, requests |
Fields inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
---|
_rights, agent, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, WAKEUP_PERIOD, WRITE |
Constructor Summary | |
---|---|
JMSBridgeQueueImpl(AgentId adminId,
java.util.Properties prop)
Constructs a BridgeQueueImpl instance. |
Method Summary | |
---|---|
void |
bridgeAck(JMSBridgeAckNot not)
Reacts to BridgeAckNot notifications holding the identifier
of a message successfuly delivered to the foreign JMS server. |
void |
bridgeDelivery(AgentId from,
JMSBridgeDeliveryNot not)
Reacts to BridgeDeliveryNot notifications holding a message
received from the foreign JMS server. |
protected void |
close()
|
protected void |
doDeleteNot(DeleteNot not)
Method specifically processing a fr.dyade.aaa.agent.DeleteNot instance. |
void |
initialize(boolean firstTime)
Initializes the destination. |
ClientMessages |
preProcess(AgentId from,
ClientMessages not)
Method specializing the processing of a ClientMessages
instance. |
void |
receiveRequest(AgentId from,
ReceiveRequest not)
Method specializing the reaction to a ReceiveRequest
instance, requesting a message. |
java.lang.String |
toString()
Returns a string representation of this destination. |
Methods inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
---|
canBeDeleted, clientMessages, delete, deleteNot, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getId, getJMXStatistics, getName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, handleDeniedMessage, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isWriter, postProcess, processSetRight, replyToTopic, requestGroupNot, setAgent, setFreeReading, setFreeWriting, setPeriod, setRight, 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 |
---|
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod |
Field Detail |
---|
private static final long serialVersionUID
private JMSBridgeModule jmsModule
private java.util.Hashtable outTable
Key: message identifier
Value: message
Constructor Detail |
---|
public JMSBridgeQueueImpl(AgentId adminId, java.util.Properties prop)
BridgeQueueImpl
instance.
adminId
- Identifier of the administrator of the queue.prop
- The initial set of properties.Method Detail |
---|
public void initialize(boolean firstTime)
initialize
in class QueueImpl
firstTime
- true when first called by the factorypublic java.lang.String toString()
QueueImpl
toString
in interface DestinationImplMBean
toString
in class QueueImpl
public void bridgeDelivery(AgentId from, JMSBridgeDeliveryNot not)
BridgeDeliveryNot
notifications holding a message
received from the foreign JMS server.
from
- AgentIdnot
- BridgeDeliveryNotpublic void bridgeAck(JMSBridgeAckNot not)
BridgeAckNot
notifications holding the identifier
of a message successfuly 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 QueueImpl
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 DestinationImpl
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 QueueImpl
protected void close()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |