org.objectweb.joram.client.connector
Class OutboundReceiver

java.lang.Object
  extended by org.objectweb.joram.client.connector.OutboundConsumer
      extended by org.objectweb.joram.client.connector.OutboundReceiver
All Implemented Interfaces:
javax.jms.MessageConsumer, javax.jms.QueueReceiver

public class OutboundReceiver
extends OutboundConsumer
implements javax.jms.QueueReceiver

An OutboundReceiver instance wraps a JMS PTP consumer for a component involved in outbound messaging.


Field Summary
private  javax.jms.Queue queue
          Queue instance to consume messages from.
 
Fields inherited from class org.objectweb.joram.client.connector.OutboundConsumer
consumer, session, valid
 
Constructor Summary
OutboundReceiver(javax.jms.Queue queue, javax.jms.MessageConsumer consumer, OutboundSession session)
          Constructs an OutboundReceiver instance.
 
Method Summary
 javax.jms.Queue getQueue()
          Returns the consumer's queue.
 
Methods inherited from class org.objectweb.joram.client.connector.OutboundConsumer
checkValidity, close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface javax.jms.MessageConsumer
close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
 

Field Detail

queue

private javax.jms.Queue queue
Queue instance to consume messages from.

Constructor Detail

OutboundReceiver

OutboundReceiver(javax.jms.Queue queue,
                 javax.jms.MessageConsumer consumer,
                 OutboundSession session)
           throws javax.jms.JMSException
Constructs an OutboundReceiver instance.

Throws:
javax.jms.JMSException
Method Detail

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException
Returns the consumer's queue.

Specified by:
getQueue in interface javax.jms.QueueReceiver
Throws:
javax.jms.JMSException


Copyright © 2010 ScalAgent D.T.. All Rights Reserved.