org.wso2.esb.integration.common.utils.clients.jmsclient

Class JMSQueueMessageProducer

java.lang.Object

org.wso2.esb.integration.common.utils.clients.jmsclient.JMSQueueMessageProducer

public class JMSQueueMessageProducer
extends Object

This class replicates org.wso2.carbon.automation.extensions.servers.jmsserver.client.JMSQueueMessageProducer introducing a Message Producer for a JMS queue, with additional methods including publishing different types of JMS messages.

Constructor Summary

Constructors

Constructor and Description
JMSQueueMessageProducer(org.wso2.carbon.automation.extensions.servers.jmsserver.controller.config.JMSBrokerConfiguration jmsBrokerConfiguration)

Method Summary

Modifier and Type	Method and Description
void	connect(String queueName) Method to establish the connection with the given Queue, with messages not being persisted.
void	connect(String queueName, boolean persistMessage) Method to establish the connection with the given Queue, with message persistance as specified.
void	disconnect() Method to disconnect the connection with the given Queue.
void	sendBytesMessage(byte[] payload) Method to send a BytesMessage.
void	sendMapMessage() Method to send a MapMessage.
void	sendMessage(javax.jms.Message message) Method to send the message to the destination Queue.
void	sendObjectMessage(Serializable payload) Method to send an ObjectMessage.
void	sendStreamMessage(byte[] payload) Method to send a StreamMessage.
void	sendTextMessage(String payload) Method to send a TextMessage.

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSQueueMessageProducer

public JMSQueueMessageProducer(org.wso2.carbon.automation.extensions.servers.jmsserver.controller.config.JMSBrokerConfiguration jmsBrokerConfiguration)
                        throws NamingException

Throws:

NamingException

Method Detail

connect

public void connect(String queueName)
             throws javax.jms.JMSException

Method to establish the connection with the given Queue, with messages not being persisted. This must be called before calling pushMessage() to send messages.

Parameters:

queueName - name of the Queue

Throws:

javax.jms.JMSException - if an error occurs creating the connection, session or producer

connect

public void connect(String queueName,
                    boolean persistMessage)
             throws javax.jms.JMSException

Method to establish the connection with the given Queue, with message persistance as specified. This must be called before calling pushMessage() to send messages.

Parameters:

persistMessage - whether or not messages need to be persisted

queueName - name of the queue

Throws:

javax.jms.JMSException - if connection to the queue fails

disconnect

public void disconnect()

Method to disconnect the connection with the given Queue. This must be called after sending the messages to release the connection.

sendMessage

public void sendMessage(javax.jms.Message message)
                 throws javax.jms.JMSException

Method to send the message to the destination Queue.

Parameters:

message - message to be sent

Throws:

javax.jms.JMSException

sendTextMessage

public void sendTextMessage(String payload)
                     throws javax.jms.JMSException

Method to send a TextMessage.

Parameters:

payload - content of the TextMessage to be sent

Throws:

javax.jms.JMSException - if an error occurs sending the BytesMessage

sendBytesMessage

public void sendBytesMessage(byte[] payload)
                      throws javax.jms.JMSException

Method to send a BytesMessage.

Parameters:

payload - content of the BytesMessage to be sent

Throws:

javax.jms.JMSException - if an error occurs sending the BytesMessage

sendStreamMessage

public void sendStreamMessage(byte[] payload)
                       throws javax.jms.JMSException

Method to send a StreamMessage.

Parameters:

payload - content of the StreamMessage to be sent

Throws:

javax.jms.JMSException - if an error occurs sending the BytesMessage

sendMapMessage

public void sendMapMessage()
                    throws javax.jms.JMSException

Method to send a MapMessage.

Throws:

javax.jms.JMSException - if an error occurs sending the MapMessage

sendObjectMessage

public void sendObjectMessage(Serializable payload)
                       throws javax.jms.JMSException

Method to send an ObjectMessage.

Parameters:

payload - content of the ObjectMessage to be sent

Throws:

javax.jms.JMSException - if an error occurs sending the ObjectMessage