Package org.jgrapes.webconsole.base

Class WebSocketInputSink

java.lang.Object

java.lang.Thread

org.jgrapes.webconsole.base.WebSocketInputSink

All Implemented Interfaces:

Runnable

public class WebSocketInputSink
extends Thread

Assembles Input events until a complete JSON message has been collected and then fires the message as JsonInput event.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected static final com.fasterxml.jackson.databind.ObjectMapper	mapper

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
WebSocketInputSink(EventPipeline wsInPipeline, ConsoleConnection consoleChannel)	Instantiates a new web socket input reader.

Method Summary

Modifier and Type	Method	Description
void	close()	Forward the close to the JSON decoder.
void	feed(ManagedBuffer<CharBuffer> input)	Forward the data to the JSON decoder.
void	run()
String	toString()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, yield

Methods inherited from class java.lang.Object

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

Field Details

mapper

protected static final com.fasterxml.jackson.databind.ObjectMapper mapper

Constructor Details

WebSocketInputSink

public WebSocketInputSink(EventPipeline wsInPipeline,
 ConsoleConnection consoleChannel)

Instantiates a new web socket input reader.

Parameters:

wsInPipeline - the ws in pipeline

consoleChannel - the web console channel

Method Details

feed

public void feed(ManagedBuffer<CharBuffer> input)
          throws IOException

Forward the data to the JSON decoder.

Parameters:

input - the data to be converted

Throws:

IOException - Signals that an I/O exception has occurred.

close

public void close()
           throws IOException

Forward the close to the JSON decoder.

Throws:

IOException - Signals that an I/O exception has occurred.

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

toString

public String toString()

Overrides:

toString in class Thread