io.aeron.command

Class PublicationMessageFlyweight

java.lang.Object

io.aeron.command.CorrelatedMessageFlyweight

io.aeron.command.PublicationMessageFlyweight

public class PublicationMessageFlyweight
extends CorrelatedMessageFlyweight

Control message for adding or removing a publication

   0                   1                   2                   3
   0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
  +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
  |                       Correlation ID                          |
  |                                                               |
  +---------------------------------------------------------------+
  |                          Stream ID                            |
  +---------------------------------------------------------------+
  |                       Channel Length                          |
  +---------------------------------------------------------------+
  |                       Channel (ASCII)                        ...
 ...                                                              |
  +---------------------------------------------------------------+
 

Field Summary

Fields inherited from class io.aeron.command.CorrelatedMessageFlyweight

buffer, CLIENT_ID_FIELD_OFFSET, CORRELATION_ID_FIELD_OFFSET, LENGTH, offset

Constructor Summary

Constructors

Constructor and Description
PublicationMessageFlyweight()

Method Summary

Modifier and Type	Method and Description
java.lang.String	channel() Get the channel field in ASCII
PublicationMessageFlyweight	channel(java.lang.String channel) Set the channel field in ASCII
int	length() Get the length of the current message
int	streamId() Get the stream id field
PublicationMessageFlyweight	streamId(int streamId) Set the stream id field

Methods inherited from class io.aeron.command.CorrelatedMessageFlyweight

clientId, clientId, correlationId, correlationId, wrap

Methods inherited from class java.lang.Object

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

Constructor Detail

PublicationMessageFlyweight

public PublicationMessageFlyweight()

Method Detail

streamId

public int streamId()

Get the stream id field

Returns:

stream id field

streamId

public PublicationMessageFlyweight streamId(int streamId)

Set the stream id field

Parameters:

streamId - field value

Returns:

flyweight

channel

public java.lang.String channel()

Get the channel field in ASCII

Returns:

channel field

channel

public PublicationMessageFlyweight channel(java.lang.String channel)

Set the channel field in ASCII

Parameters:

channel - field value

Returns:

flyweight

length

public int length()

Get the length of the current message

NB: must be called after the data is written in order to be accurate.

Returns:

the length of the current message