org.openeai.jms.consumer
Class PubSubConsumer.MyTopicListener

java.lang.Object
  org.openeai.jms.consumer.PubSubConsumer.MyTopicListener

All Implemented Interfaces:

javax.jms.MessageListener

Enclosing class:

PubSubConsumer

protected class PubSubConsumer.MyTopicListener
extends java.lang.Object
implements javax.jms.MessageListener

This is the JMS MessageListener implementation for OpenEAI PubSubConsumers. It uses the TopicSubscriber and TopicConnection established when the consumer was started to listen for messages delivered to the Topic specified in the Consumer's ConsumerConfig object.

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

Version:

3.0 - 28 January 2003

Author:

Tod Jackson (tod@openeai.org)

See Also:

ConsumerConfig, ThreadPoolConfig, ThreadPool, onMessage(Message)

Constructor Summary

PubSubConsumer.MyTopicListener(javax.jms.TopicSubscriber topicSub, javax.jms.TopicConnection topicConn)

Method Summary

void	onMessage(javax.jms.Message mesg)

Methods inherited from class java.lang.Object

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

Constructor Detail

PubSubConsumer.MyTopicListener

public PubSubConsumer.MyTopicListener(javax.jms.TopicSubscriber topicSub,
                                      javax.jms.TopicConnection topicConn)
                               throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

onMessage

public void onMessage(javax.jms.Message mesg)

Specified by:

onMessage in interface javax.jms.MessageListener