org.openeai.jms.consumer
Class PointToPointConsumer.MyQueueListener

java.lang.Object
  org.openeai.jms.consumer.PointToPointConsumer.MyQueueListener

All Implemented Interfaces:

javax.jms.MessageListener

Enclosing class:

PointToPointConsumer

protected class PointToPointConsumer.MyQueueListener
extends java.lang.Object
implements javax.jms.MessageListener

This is the JMS MessageListener implementation for OpenEAI PointToPointConsumers. It uses the QueueReceiver and QueueConnection established when the consumer was started to listen for messages delivered to the Queue specified in the Consumer's ConsumerConfig object.

When a message is delivered to the queue the this objects onMessage method is invoked.

Version:

3.0 - 28 January 2003

Author:

Tod Jackson (tod@openeai.org)

See Also:

ConsumerConfig, ThreadPoolConfig, ThreadPool, PubSubConsumer.MyTopicListener.onMessage(Message), onMessage(Message)

Constructor Summary

PointToPointConsumer.MyQueueListener(javax.jms.QueueReceiver queueRecvr, javax.jms.QueueConnection queueConn)

Method Summary

void	onMessage(javax.jms.Message m)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PointToPointConsumer.MyQueueListener

public PointToPointConsumer.MyQueueListener(javax.jms.QueueReceiver queueRecvr,
                                            javax.jms.QueueConnection queueConn)
                                     throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

onMessage

public void onMessage(javax.jms.Message m)

Specified by:

onMessage in interface javax.jms.MessageListener