com.communote.plugins.mq.provider.jms

Class JMSMessageConsumerImpl

java.lang.Object

com.communote.plugins.mq.provider.jms.JMSMessageConsumerImpl

All Implemented Interfaces:

JMSMessageConsumer

public class JMSMessageConsumerImpl
extends Object
implements JMSMessageConsumer

Plays the role of an adapter between JMS MQ consumer and CNT specific consumer.

Author:

Communote GmbH - http://www.communote.com/

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JMSMessageConsumerImpl.MessageDeliveryMode The Enum MessageDeliveryMode.

Constructor Summary

Constructors

Constructor and Description
JMSMessageConsumerImpl()

Method Summary

Modifier and Type	Method and Description
void	setCommunoteMessageConsumer(ProviderMessageConsumer communoteMessageConsumer) Sets CNT message consumer.
void	setJmsMessageConsumer(javax.jms.MessageConsumer jmsMessageConsumer) Sets JMS message consumer.
void	setJmsSender(JMSMessageSender jmsSender)
void	setMessageDeliveryMode(JMSMessageConsumerImpl.MessageDeliveryMode messageDeliveryMode) Sets the message delivery mode.
void	setPollingThread(Thread pollingThread) only for test purposes.
void	start() initializes the message consumer.
void	stop() stops JMS message consumer.

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSMessageConsumerImpl

public JMSMessageConsumerImpl()

Method Detail

setCommunoteMessageConsumer

public void setCommunoteMessageConsumer(ProviderMessageConsumer communoteMessageConsumer)

Sets CNT message consumer.

Specified by:

setCommunoteMessageConsumer in interface JMSMessageConsumer

Parameters:

communoteMessageConsumer - consumer to be set

setJmsMessageConsumer

public void setJmsMessageConsumer(javax.jms.MessageConsumer jmsMessageConsumer)

Sets JMS message consumer.

Specified by:

setJmsMessageConsumer in interface JMSMessageConsumer

Parameters:

jmsMessageConsumer - consumer to be set

setJmsSender

public void setJmsSender(JMSMessageSender jmsSender)

Specified by:

setJmsSender in interface JMSMessageConsumer

Parameters:

jmsSender - the jmsSender to set

setMessageDeliveryMode

public void setMessageDeliveryMode(JMSMessageConsumerImpl.MessageDeliveryMode messageDeliveryMode)

Sets the message delivery mode.

Specified by:

setMessageDeliveryMode in interface JMSMessageConsumer

Parameters:

messageDeliveryMode - the messageDeliveryMode to set

setPollingThread

public void setPollingThread(Thread pollingThread)

only for test purposes.

Specified by:

setPollingThread in interface JMSMessageConsumer

Parameters:

pollingThread - the new polling thread

start

public void start()
           throws javax.jms.JMSException

initializes the message consumer.

Specified by:

start in interface JMSMessageConsumer

Throws:

javax.jms.JMSException - the jMS exception

stop

public void stop()

stops JMS message consumer.

Specified by:

stop in interface JMSMessageConsumer