public class WebSocketSender extends AbstractSender
Modifier and Type | Class and Description |
---|---|
static class |
WebSocketSender.PayloadType
Payload type.
|
class |
WebSocketSender.PerfCakeClientEndpoint
Represents web socket client endpoint.
|
static class |
WebSocketSender.RemoteEndpointType
Remote endpoint type.
|
Constructor and Description |
---|
WebSocketSender() |
Modifier and Type | Method and Description |
---|---|
void |
doClose() |
void |
doInit(Properties messageAttributes) |
Serializable |
doSend(Message message,
MeasurementUnit measurementUnit)
Actually performs the send operation.
|
WebSocketSender.PayloadType |
getPayloadType()
Returns payload type.
|
WebSocketSender.RemoteEndpointType |
getRemoteEndpointType()
Returns remote endpoint type.
|
WebSocketSender |
setPayloadType(WebSocketSender.PayloadType payloadType)
Sets payload type.
|
WebSocketSender |
setRemoteEndpointType(WebSocketSender.RemoteEndpointType remoteEndpointType)
Sets remote endpoint type.
|
close, getTarget, getTarget, init, isKeepConnection, postSend, preSend, safeGetTarget, send, setKeepConnection, setTarget
public WebSocketSender setRemoteEndpointType(WebSocketSender.RemoteEndpointType remoteEndpointType)
remoteEndpointType
- The remote endpoint type. The value should be one of basic
or async
.public WebSocketSender.RemoteEndpointType getRemoteEndpointType()
basic
or async
.public WebSocketSender setPayloadType(WebSocketSender.PayloadType payloadType)
payloadType
- The payload type. The value should be one of text
, binary
or ping
.public WebSocketSender.PayloadType getPayloadType()
text
, binary
or ping
.public void doInit(Properties messageAttributes) throws PerfCakeException
doInit
in class AbstractSender
PerfCakeException
public void doClose() throws PerfCakeException
doClose
in class AbstractSender
PerfCakeException
public Serializable doSend(Message message, MeasurementUnit measurementUnit) throws Exception
AbstractSender
doSend
in class AbstractSender
message
- Message to be sent.measurementUnit
- Measurement unit carrying the current stop-watch.Exception
- When the sending operation failed.MessageSender.send(org.perfcake.message.Message, org.perfcake.reporting.MeasurementUnit)
Copyright © 2010–2017 PerfCake Community. All rights reserved.