public class StatusMessageFlyweight extends HeaderFlyweight
Status Message wiki page.
Modifier and Type | Field and Description |
---|---|
static int |
HEADER_LENGTH
Length of the Status Message Frame
|
static short |
SEND_SETUP_FLAG
Publisher should send SETUP frame
|
CURRENT_VERSION, FLAGS_FIELD_OFFSET, FRAME_LENGTH_FIELD_OFFSET, HDR_TYPE_DATA, HDR_TYPE_ERR, HDR_TYPE_EXT, HDR_TYPE_NAK, HDR_TYPE_PAD, HDR_TYPE_RTTM, HDR_TYPE_SETUP, HDR_TYPE_SM, MIN_HEADER_LENGTH, TYPE_FIELD_OFFSET, VERSION_FIELD_OFFSET
Constructor and Description |
---|
StatusMessageFlyweight() |
StatusMessageFlyweight(java.nio.ByteBuffer buffer) |
StatusMessageFlyweight(org.agrona.concurrent.UnsafeBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
int |
applicationSpecificFeedback(byte[] destination)
Retrieve the Application Specific Feedback (if present) from the Status Message.
|
StatusMessageFlyweight |
applicationSpecificFeedback(byte[] source,
int offset,
int length)
Set the Application Specific Feedback for the Status Message.
|
int |
consumptionTermId()
return highest consumption term id field
|
StatusMessageFlyweight |
consumptionTermId(int termId)
set highest consumption term id field
|
int |
consumptionTermOffset()
return highest consumption term offset field
|
StatusMessageFlyweight |
consumptionTermOffset(int termOffset)
set highest consumption term offset field
|
long |
receiverId()
Identifier for the receiver to distinguish them for FlowControl strategies.
|
StatusMessageFlyweight |
receiverId(long id)
Identifier for the receiver to distinguish them for FlowControl strategies.
|
int |
receiverWindowLength()
return receiver window field
|
StatusMessageFlyweight |
receiverWindowLength(int receiverWindowLength)
set receiver window field
|
int |
sessionId()
return session id field
|
StatusMessageFlyweight |
sessionId(int sessionId)
set session id field
|
int |
streamId()
return stream id field
|
StatusMessageFlyweight |
streamId(int streamId)
set stream id field
|
java.lang.String |
toString() |
flags, flags, frameLength, frameLength, headerType, headerType, version, version
addIntOrdered, addLongOrdered, addressOffset, boundsCheck, byteArray, byteBuffer, capacity, checkLimit, compareAndSetInt, compareAndSetLong, compareTo, equals, getAndAddInt, getAndAddLong, getAndSetInt, getAndSetLong, getByte, getBytes, getBytes, getBytes, getBytes, getBytes, getByteVolatile, getChar, getChar, getCharVolatile, getDouble, getDouble, getFloat, getFloat, getInt, getInt, getIntVolatile, getLong, getLong, getLongVolatile, getShort, getShort, getShortVolatile, getStringAscii, getStringAscii, getStringAscii, getStringUtf8, getStringUtf8, getStringUtf8, getStringWithoutLengthAscii, getStringWithoutLengthUtf8, hashCode, isExpandable, parseIntAscii, parseLongAscii, parseNaturalIntAscii, parseNaturalLongAscii, putByte, putBytes, putBytes, putBytes, putBytes, putBytes, putByteVolatile, putChar, putChar, putCharVolatile, putDouble, putDouble, putFloat, putFloat, putInt, putInt, putIntAscii, putIntOrdered, putIntVolatile, putLong, putLong, putLongAscii, putLongOrdered, putLongVolatile, putNaturalIntAscii, putNaturalIntAsciiFromEnd, putNaturalLongAscii, putNaturalPaddedIntAscii, putShort, putShort, putShortVolatile, putStringAscii, putStringAscii, putStringUtf8, putStringUtf8, putStringUtf8, putStringUtf8, putStringWithoutLengthAscii, putStringWithoutLengthAscii, putStringWithoutLengthUtf8, setMemory, verifyAlignment, wrap, wrap, wrap, wrap, wrap, wrap, wrap, wrapAdjustment
public static final int HEADER_LENGTH
public static final short SEND_SETUP_FLAG
public StatusMessageFlyweight()
public StatusMessageFlyweight(java.nio.ByteBuffer buffer)
public StatusMessageFlyweight(org.agrona.concurrent.UnsafeBuffer buffer)
public int sessionId()
public StatusMessageFlyweight sessionId(int sessionId)
sessionId
- field valuepublic int streamId()
public StatusMessageFlyweight streamId(int streamId)
streamId
- field valuepublic int consumptionTermOffset()
public StatusMessageFlyweight consumptionTermOffset(int termOffset)
termOffset
- field valuepublic int consumptionTermId()
public StatusMessageFlyweight consumptionTermId(int termId)
termId
- field valuepublic int receiverWindowLength()
public StatusMessageFlyweight receiverWindowLength(int receiverWindowLength)
receiverWindowLength
- field valuepublic long receiverId()
public StatusMessageFlyweight receiverId(long id)
id
- for the receiver to distinguish them for FlowControl strategies.public int applicationSpecificFeedback(byte[] destination)
destination
- to store the feedbackpublic StatusMessageFlyweight applicationSpecificFeedback(byte[] source, int offset, int length)
source
- of the feedback to setoffset
- of the feedback in the sourcelength
- of the feedback in bytespublic java.lang.String toString()
toString
in class org.agrona.concurrent.UnsafeBuffer
Copyright © 2014-2018 Real Logic Ltd. All Rights Reserved.