Package net.targetr.rc.monitoring.logs.http

Class HttpRequestMonitoringWebSocketResponse

java.lang.Object

net.targetr.wtm3.net.http.HttpResponse

net.targetr.wtm3.net.http.websocket.WebSocketResponse

net.targetr.rc.monitoring.logs.http.HttpRequestMonitoringWebSocketResponse

All Implemented Interfaces:

Runnable

public class HttpRequestMonitoringWebSocketResponse
extends WebSocketResponse

WebSocket response stream for HTTP request monitoring.

Field Summary

Fields inherited from class net.targetr.wtm3.net.http.websocket.WebSocketResponse

TIMEOUT, webSocket

Fields inherited from class net.targetr.wtm3.net.http.HttpResponse

bytesWritten, code, headerLength, headers, info, version, writeErrorHandler

Constructor Summary

Constructors

Constructor	Description
HttpRequestMonitoringWebSocketResponse()	Constructs a new HttpRequestMonitoringWebSocketResponse.

Method Summary

Modifier and Type	Method	Description
void	notify(HttpRequestLogEntry entry)	Notifies the WebSocket response of a new HTTP request log entry.
protected void	onClose()	Called when WebSocket connection is closed by the client.
protected void	onReceiveText(ReusableBufferList buffers)	Called when text is received from the WebSocket.
protected void	writeResponse()	Called when WebSocket connection is first opened.

Methods inherited from class net.targetr.wtm3.net.http.websocket.WebSocketResponse

run, setInterceptor, write

Methods inherited from class net.targetr.wtm3.net.http.HttpResponse

getBodyInputStream, getContentLength, parseResponse, toString

Methods inherited from class java.lang.Object

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

Constructor Details

HttpRequestMonitoringWebSocketResponse

public HttpRequestMonitoringWebSocketResponse()

Constructs a new HttpRequestMonitoringWebSocketResponse.

Method Details

notify

public void notify(HttpRequestLogEntry entry)

Notifies the WebSocket response of a new HTTP request log entry.

Parameters:

entry - the log entry to add

writeResponse

protected void writeResponse()
                      throws Exception

Description copied from class: WebSocketResponse

Called when WebSocket connection is first opened. This method is called once and should not return until all communication with the client is complete. Implementations of this method will typically call writeText() or writeBinary() to send data to the client.

Specified by:

writeResponse in class WebSocketResponse

Throws:

Exception - If an error occurs while responding to the client.

onClose

protected void onClose()

Description copied from class: WebSocketResponse

Called when WebSocket connection is closed by the client.

Specified by:

onClose in class WebSocketResponse

onReceiveText

protected void onReceiveText(ReusableBufferList buffers)
                      throws Exception

Description copied from class: WebSocketResponse

Called when text is received from the WebSocket.

Specified by:

onReceiveText in class WebSocketResponse

Parameters:

buffers - The raw data received from the WebSocket as a buffer list

Throws:

Exception - If an error occurs while processing the received text.