public class StopWatchMessageListener
extends java.lang.Object
implements javax.jms.MessageListener
Modifier and Type | Field and Description |
---|---|
private int |
count
the number of messages processed
|
private int |
groupSize
the message group size
|
private org.apache.commons.logging.Log |
log
The Log to which logging calls will be made.
|
private javax.jms.MessageListener |
messageListener
the underlying MessageListener
|
private long |
startTime
the time that the batch started processing
|
Constructor and Description |
---|
StopWatchMessageListener() |
StopWatchMessageListener(javax.jms.MessageListener messageListener) |
Modifier and Type | Method and Description |
---|---|
int |
getGroupSize() |
org.apache.commons.logging.Log |
getLog() |
javax.jms.MessageListener |
getMessageListener() |
void |
onMessage(javax.jms.Message message) |
void |
setGroupSize(int groupSize)
Sets the number of messages in the group before the performance statistics are logged
|
void |
setLog(org.apache.commons.logging.Log log)
Sets the logger to which statistic messages will be sent
|
void |
setMessageListener(javax.jms.MessageListener messageListener)
Sets the MessageListener which this listener delegates to, which can be null.
|
private org.apache.commons.logging.Log log
private javax.jms.MessageListener messageListener
private int count
private int groupSize
private long startTime
public StopWatchMessageListener()
public StopWatchMessageListener(javax.jms.MessageListener messageListener)
public void onMessage(javax.jms.Message message)
onMessage
in interface javax.jms.MessageListener
public int getGroupSize()
public void setGroupSize(int groupSize)
public org.apache.commons.logging.Log getLog()
public void setLog(org.apache.commons.logging.Log log)
public javax.jms.MessageListener getMessageListener()
public void setMessageListener(javax.jms.MessageListener messageListener)