nxt.peer

Class MetisWebSocket

java.lang.Object

nxt.peer.MetisWebSocket

@WebSocket
public class MetisWebSocket
extends java.lang.Object

PeerWebSocket represents an HTTP/HTTPS upgraded connection

Constructor Summary

Constructors

Constructor and Description
MetisWebSocket() Create a client socket
MetisWebSocket(PeerServlet peerServlet) Create a server socket

Method Summary

Modifier and Type	Method and Description
void	close() Close the WebSocket
void	doMetisPost(java.lang.String request) Process a POST request by sending the request message and then waiting for a response.
java.net.InetSocketAddress	getRemoteAddress() Return the remote address for this connection
boolean	isOpen() Check if we have a WebSocket connection
void	onClose(int statusCode, java.lang.String reason) WebSocket session has been closed
void	onConnect(org.eclipse.jetty.websocket.api.Session session) WebSocket connection complete
boolean	startClient(java.net.URI uri) Start a client session

Methods inherited from class java.lang.Object

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

Constructor Detail

MetisWebSocket

public MetisWebSocket()

Create a client socket

MetisWebSocket

public MetisWebSocket(PeerServlet peerServlet)

Create a server socket

Parameters:

peerServlet - Servlet for request processing

Method Detail

startClient

public boolean startClient(java.net.URI uri)
                    throws java.io.IOException

Start a client session

Parameters:

uri - Server URI

Returns:

TRUE if the WebSocket connection was completed

Throws:

java.io.IOException - I/O error occurred

onConnect

@OnWebSocketConnect
public void onConnect(org.eclipse.jetty.websocket.api.Session session)

WebSocket connection complete

Parameters:

session - WebSocket session

isOpen

public boolean isOpen()

Check if we have a WebSocket connection

Returns:

TRUE if we have a WebSocket connection

getRemoteAddress

public java.net.InetSocketAddress getRemoteAddress()

Return the remote address for this connection

Returns:

Remote address or null if the connection is closed

doMetisPost

public void doMetisPost(java.lang.String request)
                 throws java.io.IOException

Process a POST request by sending the request message and then waiting for a response. This method is used by the connection originator.

Parameters:

request - Request message

Throws:

java.io.IOException - I/O error occurred

onClose

@OnWebSocketClose
public void onClose(int statusCode,
                                      java.lang.String reason)

WebSocket session has been closed

Parameters:

statusCode - Status code

reason - Reason message

close

public void close()

Close the WebSocket