|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.qpid.sustained.SustainedClientTestCase.SustainedListener
class SustainedClientTestCase.SustainedListener
Inner class that listens for messages and sends a report for the time taken between receiving the 'start' and 'end' messages.
Field Summary | |
---|---|
(package private) String |
_client
Record of the client ID used for this SustainedListnener |
(package private) Session |
_session
Session to create the report message on |
(package private) MessageProducer |
_updater
Message producer to use to send reports |
Constructor Summary | |
---|---|
SustainedClientTestCase.SustainedListener(String clientname,
int batchSize,
Session session,
Destination sendDestination)
Main Constructor |
Method Summary | |
---|---|
void |
onMessage(Message message)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
MessageProducer _updater
Session _session
String _client
Constructor Detail |
---|
public SustainedClientTestCase.SustainedListener(String clientname, int batchSize, Session session, Destination sendDestination) throws JMSException
clientname
- The _client id used to identify this connection.batchSize
- The number of messages that are to be sent per batch. Note: This is not used to
control the interval between sending reports.session
- The controlSession used for communication.sendDestination
- The destination that update reports should be sent to.
JMSException
- My occur if creatingthe Producer failsMethod Detail |
---|
public void onMessage(Message message)
onMessage
in interface MessageListener
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |