org.apache.oozie.jms
Class MessageReceiver

java.lang.Object
  org.apache.oozie.jms.MessageReceiver

All Implemented Interfaces:

javax.jms.MessageListener

public class MessageReceiver
extends Object
implements javax.jms.MessageListener

Constructor Summary

MessageReceiver(MessageHandler handler, javax.jms.Session session, javax.jms.MessageConsumer consumer)

Method Summary

javax.jms.MessageConsumer	getConsumer() Get the JMS message consumer object for this message receiver
MessageHandler	getMessageHandler() Get the MessageHandler that will process the message
javax.jms.Session	getSession() Get the JMS session for this message receiver
void	onMessage(javax.jms.Message msg)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageReceiver

public MessageReceiver(MessageHandler handler,
                       javax.jms.Session session,
                       javax.jms.MessageConsumer consumer)

Method Detail

getConsumer

public javax.jms.MessageConsumer getConsumer()

Get the JMS message consumer object for this message receiver

Returns:

MessageConsumer

getMessageHandler

public MessageHandler getMessageHandler()

Get the MessageHandler that will process the message

Returns:

message handler

getSession

public javax.jms.Session getSession()

Get the JMS session for this message receiver

Returns:

JMS session

onMessage

public void onMessage(javax.jms.Message msg)

Specified by:

onMessage in interface javax.jms.MessageListener