com.mulesoft.service.http.impl.service.client.ws

Class InboundWebSocket

java.lang.Object

org.glassfish.grizzly.websockets.SimpleWebSocket

org.glassfish.grizzly.websockets.DefaultWebSocket

com.mulesoft.service.http.impl.service.client.ws.InboundWebSocket

All Implemented Interfaces:

org.glassfish.grizzly.websockets.WebSocket

public class InboundWebSocket
extends org.glassfish.grizzly.websockets.DefaultWebSocket
implements org.mule.runtime.http.api.ws.WebSocket

Grizzly based implementation for an INBOUND WebSocket

Since:

1.3.0

Nested Class Summary

Nested classes/interfaces inherited from class org.glassfish.grizzly.websockets.SimpleWebSocket

org.glassfish.grizzly.websockets.SimpleWebSocket.State

Nested classes/interfaces inherited from interface org.mule.runtime.http.api.ws.WebSocket

org.mule.runtime.http.api.ws.WebSocket.WebSocketType

Field Summary

Fields inherited from class org.glassfish.grizzly.websockets.DefaultWebSocket

servletRequest

Fields inherited from class org.glassfish.grizzly.websockets.SimpleWebSocket

broadcaster, connected, listeners, protocolHandler, state

Fields inherited from interface org.glassfish.grizzly.websockets.WebSocket

ABNORMAL_CLOSE, END_POINT_GOING_DOWN, INVALID_DATA, MESSAGE_TOO_LARGE, NO_STATUS_CODE, NORMAL_CLOSURE, PROTOCOL_ERROR

Constructor Summary

Constructors

Constructor and Description
InboundWebSocket(String id, org.mule.runtime.http.api.server.ws.WebSocketHandler resource, org.mule.runtime.http.api.server.ws.WebSocketRequest request, org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler, org.glassfish.grizzly.http.HttpRequestPacket requestPacket, org.glassfish.grizzly.websockets.WebSocketListener... listeners)

Method Summary

Modifier and Type	Method and Description
void	addGroup(String group)
CompletableFuture<Void>	close(org.mule.runtime.http.api.ws.WebSocketCloseCode code, String reason)
boolean	equals(Object obj)
FragmentHandler	getFragmentHandler(Consumer<FragmentHandler> newFragmentHandlerCallback)
List<String>	getGroups()
String	getId()
org.mule.runtime.http.api.ws.WebSocketProtocol	getProtocol()
org.mule.runtime.http.api.server.ws.WebSocketRequest	getRequest()
org.mule.runtime.http.api.server.ws.WebSocketHandler	getResource()
org.mule.runtime.http.api.ws.WebSocket.WebSocketType	getType()
URI	getUri()
int	hashCode()
void	removeGroup(String group)
CompletableFuture<Void>	send(InputStream content, org.mule.runtime.api.metadata.MediaType mediaType)
String	toString()

Methods inherited from class org.glassfish.grizzly.websockets.DefaultWebSocket

getUpgradeRequest

Methods inherited from class org.glassfish.grizzly.websockets.SimpleWebSocket

add, broadcast, broadcast, broadcastFragment, broadcastFragment, close, close, close, completableClose, getBroadcaster, getListeners, isConnected, onClose, onConnect, onFragment, onFragment, onMessage, onMessage, onPing, onPong, remove, send, send, sendPing, sendPong, sendRaw, setBroadcaster, setClosed, stream, stream, toRawData, toRawData, toRawData, toRawData

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

InboundWebSocket

public InboundWebSocket(String id,
                        org.mule.runtime.http.api.server.ws.WebSocketHandler resource,
                        org.mule.runtime.http.api.server.ws.WebSocketRequest request,
                        org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler,
                        org.glassfish.grizzly.http.HttpRequestPacket requestPacket,
                        org.glassfish.grizzly.websockets.WebSocketListener... listeners)

Method Detail

send

public CompletableFuture<Void> send(InputStream content,
                                    org.mule.runtime.api.metadata.MediaType mediaType)

getFragmentHandler

public FragmentHandler getFragmentHandler(Consumer<FragmentHandler> newFragmentHandlerCallback)

getGroups

public List<String> getGroups()

addGroup

public void addGroup(String group)

removeGroup

public void removeGroup(String group)

close

public CompletableFuture<Void> close(org.mule.runtime.http.api.ws.WebSocketCloseCode code,
                                     String reason)

getId

public String getId()

getUri

public URI getUri()

getType

public org.mule.runtime.http.api.ws.WebSocket.WebSocketType getType()

getProtocol

public org.mule.runtime.http.api.ws.WebSocketProtocol getProtocol()

getRequest

public org.mule.runtime.http.api.server.ws.WebSocketRequest getRequest()

getResource

public org.mule.runtime.http.api.server.ws.WebSocketHandler getResource()

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object