public abstract class ChannelSender extends AbstractSender
Constructor and Description |
---|
ChannelSender() |
Modifier and Type | Method and Description |
---|---|
void |
doClose() |
boolean |
getAwaitResponse()
Gets the status of waiting for response on the channel.
|
int |
getMaxResponseSize()
Gets the expected response maximum size.
|
void |
postSend(Message message)
Performs any action that needs to be done to complete the sending of the message but is not directly related to the sending operation and thus not measured.
|
void |
preSend(Message message,
Properties messageAttributes)
Performs any action that needs to be done to send the message but is not directly related to the sending operation and thus not measured.
|
ChannelSender |
setAwaitResponse(boolean awaitResponse)
Specifies whether to wait for a response.
|
ChannelSender |
setMaxResponseSize(int maxResponseSize)
Sets the expected response maximum size.
|
close, doInit, doSend, getTarget, getTarget, init, isKeepConnection, safeGetTarget, send, setKeepConnection, setTarget
public void doClose() throws PerfCakeException
doClose
in class AbstractSender
PerfCakeException
public void preSend(Message message, Properties messageAttributes) throws Exception
MessageSender
preSend
in interface MessageSender
preSend
in class AbstractSender
message
- Message to be sent.messageAttributes
- Attributes that can be used to replace placeholders in message and or target.Exception
- In case anything fails during the preparation.public void postSend(Message message) throws Exception
MessageSender
postSend
in interface MessageSender
postSend
in class AbstractSender
message
- Message that was sent.Exception
- In case anything fails during the finalization.public boolean getAwaitResponse()
public ChannelSender setAwaitResponse(boolean awaitResponse)
awaitResponse
- True to make the sender to wait for a response.public int getMaxResponseSize()
public ChannelSender setMaxResponseSize(int maxResponseSize)
maxResponseSize
- The desired maximum response size.Copyright © 2010–2017 PerfCake Community. All rights reserved.