public abstract class RawMessageWriter extends java.lang.Object implements Publishable
| Constructor and Description |
|---|
RawMessageWriter() |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
endBlock()
End a block started with either
startEnvelope() or startTransaction() |
abstract void |
setBuffer(java.nio.ByteBuffer buffer)
Set the buffet to publish.
|
static void |
setStream(java.nio.ByteBuffer buffer,
Stream stream)
Helper that method allows redirecting the buffer to a different stream.
|
abstract void |
startEnvelope()
Start an envelope block
|
abstract void |
startTransaction()
Start a transaction block
|
static boolean |
validateBuffer(java.nio.ByteBuffer buffer)
Sanity checks the buffer.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetBuffers, getPublisher, waitUntilEmptypublic abstract void startTransaction()
public abstract void startEnvelope()
public abstract void endBlock()
startEnvelope() or startTransaction()public abstract void setBuffer(java.nio.ByteBuffer buffer)
buffer - public static final boolean validateBuffer(java.nio.ByteBuffer buffer)
<in progress>
buffer - public static final void setStream(java.nio.ByteBuffer buffer,
Stream stream)
buffer - stream -