cgl.narada.samples.jms
Class AnabasTest

java.lang.Object
  extended by 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)


For comments and suggestions please send e-mail to The NaradaBrokering Project