org.objectweb.joram.mom.dest

Class BridgeQueueImpl

Implemented Interfaces:
java.io.Serializable

public class BridgeQueueImpl
extends QueueImpl

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.

See Also:
Serialized Form

Field Summary

Fields inherited from class org.objectweb.joram.mom.dest.QueueImpl

arrivalsCounter, consumers, contexts, deliveredMsgs, messages, persistenceModule, receiving, requests

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

READ, READWRITE, WRITE, adminId, clients, destId, dmqId, freeReading, freeWriting

Constructor Summary

BridgeQueueImpl(AgentId destId, AgentId adminId)
Constructs a BridgeQueueImpl instance.

Method Summary

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()

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

deliverMessages, doProcess, doProcess, doProcess, doProcess, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, isUndeliverable, messageDelivered, messageRemoved, react, specialProcess, storeMessage, toString

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

canBeDeleted, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, isAdministrator, isReader, isWriter, processSetRight, react, sendToDMQ, specialAdminProcess, specialProcess

Constructor Details

BridgeQueueImpl

public BridgeQueueImpl(AgentId destId,
                       AgentId adminId)
Constructs a BridgeQueueImpl instance.

Parameters:
destId - Identifier of the agent hosting the queue.
adminId - Identifier of the administrator of the queue.

Method Details

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.

Overrides:
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.

Overrides:
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.

Overrides:
doReact in interface QueueImpl

Throws:
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.


react

public void react(AgentId from,
                  Notification not)
            throws UnknownNotificationException
Specializes this QueueImpl method for processing the specific bridge notifications.
Overrides:
react in interface QueueImpl


toString

public String toString()
Overrides:
toString in interface QueueImpl


Copyright B) 2004 Scalagent - All rights reserved