com.communote.plugins.mq.provider.jms

Class JMSMessageSender

java.lang.Object

com.communote.plugins.mq.provider.jms.JMSMessageSender

All Implemented Interfaces:

ProviderMessageSender

public class JMSMessageSender
extends Object
implements ProviderMessageSender

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

Author:

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

Constructor Summary

Constructors

Constructor and Description
JMSMessageSender()

Method Summary

Modifier and Type	Method and Description
void	close()
protected javax.jms.MessageProducer	getProducer(javax.jms.Destination dest) returns producer for the specified destination
void	init() initializes message sender, creating new session and connecting to the message queue.
void	sendMessageInternal(TransferMessage transferMessage) Sends a message to the message queue internally
void	sendReplyMessage(TransferMessage transferMessage) sends received message to the MQ
void	setSession(javax.jms.Session session) Method to set the session.

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSMessageSender

public JMSMessageSender()

Method Detail

close

public void close()

getProducer

protected javax.jms.MessageProducer getProducer(javax.jms.Destination dest)
                                         throws javax.jms.JMSException

returns producer for the specified destination

Parameters:

dest - destination

Returns:

created producer

Throws:

javax.jms.JMSException - exception

init

public void init()
          throws javax.jms.JMSException

initializes message sender, creating new session and connecting to the message queue.

Throws:

javax.jms.JMSException - exception

sendMessageInternal

public void sendMessageInternal(TransferMessage transferMessage)
                         throws MessageQueueCommunicationException

Sends a message to the message queue internally

Specified by:

sendMessageInternal in interface ProviderMessageSender

Parameters:

transferMessage - the transfer message to send

Throws:

MessageQueueCommunicationException

sendReplyMessage

public void sendReplyMessage(TransferMessage transferMessage)
                      throws MessageQueueCommunicationException

sends received message to the MQ

Specified by:

sendReplyMessage in interface ProviderMessageSender

Parameters:

transferMessage - message to be sent

Throws:

MessageQueueCommunicationException

setSession

public void setSession(javax.jms.Session session)

Method to set the session.

Parameters:

session - JMS session to be set