org.wso2.mb.integration.common.clients

Class AndesJMSPublisher

java.lang.Object

org.wso2.mb.integration.common.clients.AndesJMSBase

org.wso2.mb.integration.common.clients.AndesJMSPublisher

All Implemented Interfaces:

Runnable

public class AndesJMSPublisher
extends AndesJMSBase
implements Runnable

The JMS message publisher used for creating a publisher and for publishing JMS messages.

Field Summary

Fields inherited from class org.wso2.mb.integration.common.clients.AndesJMSBase

jmsConfig

Constructor Summary

Constructors

Constructor and Description
AndesJMSPublisher(AndesJMSPublisherClientConfiguration config, boolean createPublisher) Creates a new JMS publisher with a given configuration.

Method Summary

Modifier and Type	Method and Description
AndesJMSPublisherClientConfiguration	getConfig() Gets the configuration.
javax.jms.Connection	getConnection() Gets the JMS message sending connection (Connection).
void	getMessageContentFromFile() Reads message content from a file which is used as the message content to when publishing messages.
double	getPublisherTPS() Gets the transactions per seconds for publisher.
javax.jms.MessageProducer	getSender() Gets the JMS message producer (MessageProducer).
long	getSentMessageCount() Gets the published message count.
javax.jms.Session	getSession() Gets the JMS message sending session (Session).
void	run()
void	setConnection(javax.jms.Connection connection) Sets the JMS message sending connection (Connection).
void	setSender(javax.jms.MessageProducer sender) Sets the JMS message producer (MessageProducer).
void	setSession(javax.jms.Session session) Sets the JMS message sending session (Session).
void	startClient() Starts up the publisher or consumer.
void	stopClient() Stops the publisher or consumer

Methods inherited from class org.wso2.mb.integration.common.clients.AndesJMSBase

getInitialContext

Methods inherited from class java.lang.Object

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

Constructor Detail

AndesJMSPublisher

public AndesJMSPublisher(AndesJMSPublisherClientConfiguration config,
                         boolean createPublisher)
                  throws NamingException,
                         javax.jms.JMSException

Creates a new JMS publisher with a given configuration.

Parameters:

config - The configuration

createPublisher - Creates connection, session and sender.

Throws:

NamingException

javax.jms.JMSException

Method Detail

startClient

public void startClient()
                 throws AndesClientException,
                        IOException

Starts up the publisher or consumer.

Specified by:

startClient in class AndesJMSBase

Throws:

IOException

AndesClientException

stopClient

public void stopClient()
                throws javax.jms.JMSException

Stops the publisher or consumer

Specified by:

stopClient in class AndesJMSBase

Throws:

javax.jms.JMSException

getMessageContentFromFile

public void getMessageContentFromFile()
                               throws IOException

Reads message content from a file which is used as the message content to when publishing messages.

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

getSentMessageCount

public long getSentMessageCount()

Gets the published message count.

Returns:

The published message count.

getPublisherTPS

public double getPublisherTPS()

Gets the transactions per seconds for publisher.

Returns:

The transactions per second.

getConfig

public AndesJMSPublisherClientConfiguration getConfig()

Gets the configuration.

Specified by:

getConfig in class AndesJMSBase

Returns:

The configuration.

getConnection

public javax.jms.Connection getConnection()

Gets the JMS message sending connection (Connection).

Returns:

A Connection

setConnection

public void setConnection(javax.jms.Connection connection)

Sets the JMS message sending connection (Connection).

Parameters:

connection - A Connection.

getSession

public javax.jms.Session getSession()

Gets the JMS message sending session (Session).

Returns:

A Session.

setSession

public void setSession(javax.jms.Session session)

Sets the JMS message sending session (Session).

Parameters:

session - A Session.

getSender

public javax.jms.MessageProducer getSender()

Gets the JMS message producer (MessageProducer).

Returns:

A MessageProducer.

setSender

public void setSender(javax.jms.MessageProducer sender)

Sets the JMS message producer (MessageProducer). Suppressing "UnusedDeclaration" as the client acts as a service.

Parameters:

sender - A MessageProducer.