org.objectweb.joram.mom.dest
Class BridgeQueueImpl
- java.io.Serializable
public class BridgeQueueImpl
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,
and which is accessible through the PTP communication mode.
- Serialized Form
protected void | doProcess(DeleteNot not) - Method specifically processing a
fr.dyade.aaa.agent.DeleteNot instance.
|
protected void | doProcess(ClientMessages not) - Method specializing the processing of a
ClientMessages
instance.
|
protected void | doReact(AgentId from, ReceiveRequest not) - Method specializing the reaction to a
ReceiveRequest
instance, requesting a message.
|
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(Properties prop) - Initiales the queue's JMS module.
|
void | react(AgentId from, Notification not) - Specializes this
QueueImpl method for processing the
specific bridge notifications.
|
String | toString()
|
deliverMessages , doProcess , doProcess , doProcess , doProcess , doReact , doReact , doReact , doReact , doReact , doReact , doReact , doReact , isUndeliverable , messageDelivered , messageRemoved , react , specialProcess , storeMessage , toString |
canBeDeleted , doReact , doReact , doReact , doReact , doReact , doReact , doReact , doReact , doReact , doReact , isAdministrator , isReader , isWriter , processSetRight , react , sendToDMQ , specialAdminProcess , specialProcess |
BridgeQueueImpl
public BridgeQueueImpl(AgentId destId,
AgentId adminId)
Constructs a BridgeQueueImpl
instance.
destId
- Identifier of the agent hosting the queue.adminId
- Identifier of the administrator of the queue.
doProcess
protected void doProcess(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.
- doProcess in interface QueueImpl
doProcess
protected void doProcess(ClientMessages not)
Method specializing the processing of a
ClientMessages
instance.
This method sends the messages to the foreign JMS destination.
- doProcess in interface QueueImpl
doReact
protected void doReact(AgentId from,
ReceiveRequest not)
throws AccessException
Method specializing the reaction to a
ReceiveRequest
instance, requesting a message.
This method stores the request and requests a message through the JMS
interface.
- doReact in interface QueueImpl
AccessException
- If the sender is not a reader.
doReact
protected void doReact(BridgeAckNot not)
Reacts to BridgeAckNot
notifications holding the identifier
of a message successfuly delivered to the foreign JMS server.
doReact
protected void doReact(BridgeDeliveryNot not)
Reacts to BridgeDeliveryNot
notifications holding a message
received from the foreign JMS server.
init
public void init(Properties prop)
Initiales the queue's JMS module.
toString
public String toString()
- toString in interface QueueImpl
Copyright B) 2004 Scalagent - All rights reserved