org.objectweb.joram.mom.dest.jmsbridge
Class JMSBridgeQueueImpl

java.lang.Object
  org.objectweb.joram.mom.dest.DestinationImpl
      org.objectweb.joram.mom.dest.QueueImpl
          org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl

All Implemented Interfaces:

java.io.Serializable, DestinationImplMBean, QueueImplMBean

public class JMSBridgeQueueImpl
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.

See Also:

Serialized Form

Field Summary

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

arrivalsCounter, consumers, contexts, deliveredMsgs, logger, messages, nbMaxMsg, period, receiving, requests

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

_rights, agent, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, WRITE

Constructor Summary

JMSBridgeQueueImpl(fr.dyade.aaa.agent.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(fr.dyade.aaa.agent.AgentId from, JMSBridgeDeliveryNot not) Reacts to BridgeDeliveryNot notifications holding a message received from the foreign JMS server.
protected void	doDeleteNot(fr.dyade.aaa.agent.DeleteNot not) Method specifically processing a fr.dyade.aaa.agent.DeleteNot instance.
void	initialize(boolean firstTime) Initializes the destination.
ClientMessages	preProcess(fr.dyade.aaa.agent.AgentId from, ClientMessages not) Method specializing the processing of a ClientMessages instance.
void	receiveRequest(fr.dyade.aaa.agent.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.QueueImpl

abortReceiveRequest, acknowledgeRequest, addMessage, browseRequest, checkDelivery, cleanPendingMessage, cleanPendingMessage, cleanWaitingRequest, cleanWaitingRequest, deliverMessages, denyRequest, destinationAdminRequestNot, doClientMessages, doRightRequest, doUnknownAgent, getClientMessages, getDefaultDMQId, getDefaultThreshold, getDeliveredMessageCount, getMessage, getMessages, getMsgTxPrefix, getNbMaxMsg, getNbMsgsReceiveSinceCreation, getPendingMessageCount, getPeriod, getQueueMessage, getStatisticHashtable, getThreshold, getWaitingRequestCount, handleExpiredNot, isUndeliverable, messageDelivered, messageRemoved, monitGetDMQSettings, monitGetNbMaxMsg, monitGetPendingMessages, monitGetPendingRequests, readBag, setMsgTxName, setNbMaxMsg, setNbMaxMsgRequest, setPeriod, setThreshold, setThreshRequest, storeMessage, storeMessageHeader, wakeUpNot, writeBag

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

canBeDeleted, clientMessages, deleteNot, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getId, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getRight, getRights, handleDeniedMessage, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isWriter, monitFreeAccess, monitGetReaders, monitGetStat, monitGetWriters, postProcess, postProcess, preProcess, processSetRight, replyToTopic, requestGroupNot, setAgent, setDMQRequest, setFreeReading, setFreeWriting, setRightRequest, 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

getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting

Constructor Detail

JMSBridgeQueueImpl

public JMSBridgeQueueImpl(fr.dyade.aaa.agent.AgentId adminId,
                          java.util.Properties prop)

Constructs a BridgeQueueImpl instance.

Parameters:

adminId - Identifier of the administrator of the queue.

prop - The initial set of properties.

Method Detail

initialize

public void initialize(boolean firstTime)

Initializes the destination.

Overrides:

initialize in class QueueImpl

Parameters:

firstTime - true when first called by the factory

toString

public java.lang.String toString()

Description copied from class: QueueImpl

Returns a string representation of this destination.

Specified by:

toString in interface DestinationImplMBean

Overrides:

toString in class QueueImpl

bridgeDelivery

public void bridgeDelivery(fr.dyade.aaa.agent.AgentId from,
                           JMSBridgeDeliveryNot not)

Reacts to BridgeDeliveryNot notifications holding a message received from the foreign JMS server.

Parameters:

from - AgentId

not - BridgeDeliveryNot

bridgeAck

public void bridgeAck(JMSBridgeAckNot not)

Reacts to BridgeAckNot notifications holding the identifier of a message successfuly delivered to the foreign JMS server.

Parameters:

not - BridgeAckNot

receiveRequest

public void receiveRequest(fr.dyade.aaa.agent.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:

receiveRequest in class QueueImpl

Throws:

AccessException - If the sender is not a reader.

preProcess

public ClientMessages preProcess(fr.dyade.aaa.agent.AgentId from,
                                 ClientMessages not)

Method specializing the processing of a ClientMessages instance.

This method sends the messages to the foreign JMS destination.

Overrides:

preProcess in class DestinationImpl

doDeleteNot

protected void doDeleteNot(fr.dyade.aaa.agent.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:

doDeleteNot in class QueueImpl