Package org.mockserver.closurecallback.websocketregistry

Class WebSocketClientRegistry

java.lang.Object

org.mockserver.closurecallback.websocketregistry.WebSocketClientRegistry

public class WebSocketClientRegistry
extends Object

Author:

jamesdbloom

Field Summary

Fields

Modifier and Type	Field	Description
static String	WEB_SOCKET_CORRELATION_ID_HEADER_NAME

Constructor Summary

Constructors

Constructor	Description
WebSocketClientRegistry(Configuration configuration, MockServerLogger mockServerLogger)

Method Summary

Modifier and Type	Method	Description
void	receivedTextWebSocketFrame(io.netty.handler.codec.http.websocketx.TextWebSocketFrame textWebSocketFrame)
void	registerClient(String clientId, io.netty.channel.ChannelHandlerContext ctx)
void	registerForwardCallbackHandler(String webSocketCorrelationId, WebSocketRequestCallback expectationForwardCallback)
void	registerResponseCallbackHandler(String webSocketCorrelationId, WebSocketResponseCallback expectationResponseCallback)
void	reset()
boolean	sendClientMessage(String clientId, HttpRequest httpRequest, HttpResponse httpResponse)
int	size()
void	unregisterClient(String clientId)
void	unregisterForwardCallbackHandler(String webSocketCorrelationId)
void	unregisterResponseCallbackHandler(String webSocketCorrelationId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

WEB_SOCKET_CORRELATION_ID_HEADER_NAME

public static final String WEB_SOCKET_CORRELATION_ID_HEADER_NAME

See Also:

Constant Field Values

Constructor Detail

WebSocketClientRegistry

public WebSocketClientRegistry(Configuration configuration,
                               MockServerLogger mockServerLogger)

Method Detail

receivedTextWebSocketFrame

public void receivedTextWebSocketFrame(io.netty.handler.codec.http.websocketx.TextWebSocketFrame textWebSocketFrame)

size

public int size()

registerClient

public void registerClient(String clientId,
                           io.netty.channel.ChannelHandlerContext ctx)

unregisterClient

public void unregisterClient(String clientId)

registerResponseCallbackHandler

public void registerResponseCallbackHandler(String webSocketCorrelationId,
                                            WebSocketResponseCallback expectationResponseCallback)

unregisterResponseCallbackHandler

public void unregisterResponseCallbackHandler(String webSocketCorrelationId)

registerForwardCallbackHandler

public void registerForwardCallbackHandler(String webSocketCorrelationId,
                                           WebSocketRequestCallback expectationForwardCallback)

unregisterForwardCallbackHandler

public void unregisterForwardCallbackHandler(String webSocketCorrelationId)

sendClientMessage

public boolean sendClientMessage(String clientId,
                                 HttpRequest httpRequest,
                                 HttpResponse httpResponse)

reset

public void reset()