org.apache.catalina.tribes.group.interceptors
public class ThroughputInterceptor extends ChannelInterceptorBase
ChannelInterceptor.InterceptorEvent| Modifier and Type | Field and Description |
|---|---|
protected static Log |
log |
optionFlag| Constructor and Description |
|---|
ThroughputInterceptor() |
| Modifier and Type | Method and Description |
|---|---|
int |
getInterval() |
void |
messageReceived(ChannelMessage msg)
the
messageReceived is invoked when a message is received. |
void |
report(double timeTx) |
void |
sendMessage(Member[] destination,
ChannelMessage msg,
InterceptorPayload payload)
The
sendMessage method is called when a message is being sent to one more destinations. |
void |
setInterval(int interval) |
accept, fireInterceptorEvent, getLocalMember, getMember, getMembers, getNext, getOptionFlag, getPrevious, hasMembers, heartbeat, memberAdded, memberDisappeared, okToProcess, setNext, setOptionFlag, setPrevious, start, stopprotected static Log log
public void sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) throws ChannelException
ChannelInterceptorsendMessage method is called when a message is being sent to one more destinations.
The interceptor can modify any of the parameters and then pass on the message down the stack by
invoking getNext().sendMessage(destination,msg,payload)getNext().sendMessage(destination,msg,payload)sendMessage in interface ChannelInterceptorsendMessage in class ChannelInterceptorBasedestination - Member[] - the destination for this messagemsg - ChannelMessage - the message to be sentpayload - InterceptorPayload - the payload, carrying an error handler and future useful data, can be nullChannelExceptionErrorHandler,
InterceptorPayloadpublic void messageReceived(ChannelMessage msg)
ChannelInterceptormessageReceived is invoked when a message is received.
ChannelMessage.getAddress() is the sender, or the reply-to address
if it has been overwritten.messageReceived in interface ChannelInterceptormessageReceived in class ChannelInterceptorBasemsg - ChannelMessagepublic void report(double timeTx)
public void setInterval(int interval)
public int getInterval()
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.