cgl.narada.samples.jms
Class AnabasTest

java.lang.Object
  cgl.narada.samples.jms.AnabasTest

All Implemented Interfaces:

MessageListener

public class AnabasTest
extends Object
implements MessageListener

Constructor Summary

AnabasTest(Properties connectionProperties, String transportType, String userName, String topicString)

Method Summary

void	close()
Message	createMessage(int messageNumber)
void	initializeChatSession(TopicConnectionFactory conFactory, String username, String topicString)
static void	main(String[] args)
void	onMessage(Message message)
void	processBenchmarkMessage(Message message)
void	reportOnBenchmark(String reportFileName, boolean generateReportFile)
void	set(TopicConnection con, TopicSession pubSess, TopicSession subSess, TopicPublisher pub, String username)
void	startBenchmarkProcess()
void	startConnection()
void	stopConnection()
void	writeMessage(String text)

Methods inherited from class java.lang.Object

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

Constructor Detail

AnabasTest

public AnabasTest(Properties connectionProperties,
                  String transportType,
                  String userName,
                  String topicString)
           throws Exception

Throws:

Exception

Method Detail

initializeChatSession

public void initializeChatSession(TopicConnectionFactory conFactory,
                                  String username,
                                  String topicString)
                           throws Exception

Throws:

Exception

startConnection

public void startConnection()
                     throws JMSException

Throws:

JMSException

stopConnection

public void stopConnection()
                    throws JMSException

Throws:

JMSException

set

public void set(TopicConnection con,
                TopicSession pubSess,
                TopicSession subSess,
                TopicPublisher pub,
                String username)

onMessage

public void onMessage(Message message)

Specified by:

onMessage in interface MessageListener

writeMessage

public void writeMessage(String text)
                  throws JMSException

Throws:

JMSException

createMessage

public Message createMessage(int messageNumber)
                      throws JMSException

Throws:

JMSException

processBenchmarkMessage

public void processBenchmarkMessage(Message message)
                             throws JMSException

Throws:

JMSException

reportOnBenchmark

public void reportOnBenchmark(String reportFileName,
                              boolean generateReportFile)

startBenchmarkProcess

public void startBenchmarkProcess()
                           throws JMSException

Throws:

JMSException

close

public void close()
           throws JMSException

Throws:

JMSException

main

public static void main(String[] args)