public class StreamMessageConsumer extends java.lang.Object implements MessageConsumer, MessageConstants
CONTENT_LENGTH_HEADER, CONTENT_TYPE_HEADER, CRLF, JSON_MIME_TYPE, JSONRPC_VERSION
Constructor and Description |
---|
StreamMessageConsumer(MessageJsonHandler jsonHandler) |
StreamMessageConsumer(java.io.OutputStream output,
MessageJsonHandler jsonHandler) |
StreamMessageConsumer(java.io.OutputStream output,
java.lang.String encoding,
MessageJsonHandler jsonHandler) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.StringBuilder |
appendHeader(java.lang.StringBuilder builder,
java.lang.String name,
java.lang.Object value)
Append a header attribute to the given builder.
|
void |
consume(Message message)
Consume a single message.
|
protected java.lang.String |
getHeader(int contentLength)
Construct a header to be prepended to the actual content.
|
java.io.OutputStream |
getOutput() |
void |
setOutput(java.io.OutputStream output) |
public StreamMessageConsumer(MessageJsonHandler jsonHandler)
public StreamMessageConsumer(java.io.OutputStream output, MessageJsonHandler jsonHandler)
public StreamMessageConsumer(java.io.OutputStream output, java.lang.String encoding, MessageJsonHandler jsonHandler)
public java.io.OutputStream getOutput()
public void setOutput(java.io.OutputStream output)
public void consume(Message message)
MessageConsumer
consume
in interface MessageConsumer
protected java.lang.String getHeader(int contentLength)
Content-Length
and Content-Type
attributes according to the LSP specification.protected java.lang.StringBuilder appendHeader(java.lang.StringBuilder builder, java.lang.String name, java.lang.Object value)