nxt.peer

Class PeerWebSocket

java.lang.Object

nxt.peer.PeerWebSocket

@WebSocket
public class PeerWebSocket
extends java.lang.Object

PeerWebSocket represents an HTTP/HTTPS upgraded connection

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close() Close the WebSocket
java.lang.String	doPost(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
void	onMessage(byte[] inbuf, int off, int len) Process a socket message
void	sendResponse(long requestId, java.lang.String response) Send POST response This method is used by the connection acceptor to return the POST response
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

PeerWebSocket

public PeerWebSocket()

Create a client socket

PeerWebSocket

public PeerWebSocket(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

doPost

public java.lang.String doPost(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

Returns:

Response message

Throws:

java.io.IOException - I/O error occurred

sendResponse

public void sendResponse(long requestId,
                         java.lang.String response)
                  throws java.io.IOException

Send POST response This method is used by the connection acceptor to return the POST response

Parameters:

requestId - Request identifier

response - Response message

Throws:

java.io.IOException - I/O error occurred

onMessage

@OnWebSocketMessage
public void onMessage(byte[] inbuf,
                                          int off,
                                          int len)

Process a socket message

Parameters:

inbuf - Message buffer

off - Starting offset

len - Message length

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