io.aeron.command

Class SubscriptionMessageFlyweight

java.lang.Object

io.aeron.command.CorrelatedMessageFlyweight

io.aeron.command.SubscriptionMessageFlyweight

public class SubscriptionMessageFlyweight
extends CorrelatedMessageFlyweight

Control message for adding or removing a subscription.

   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
  +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
  |                    Command Correlation ID                     |
  |                                                               |
  +---------------------------------------------------------------+
  |                 Registration 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
SubscriptionMessageFlyweight()

Method Summary

Modifier and Type	Method and Description
java.lang.String	channel() Get the channel field in ASCII
SubscriptionMessageFlyweight	channel(java.lang.String channel) Set channel field in ASCII
int	length()
long	registrationCorrelationId() return correlation id used in registration field
SubscriptionMessageFlyweight	registrationCorrelationId(long correlationId) set registration correlation id field
int	streamId() return the stream id
SubscriptionMessageFlyweight	streamId(int streamId) Set the stream id

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

SubscriptionMessageFlyweight

public SubscriptionMessageFlyweight()

Method Detail

registrationCorrelationId

public long registrationCorrelationId()

return correlation id used in registration field

Returns:

correlation id field

registrationCorrelationId

public SubscriptionMessageFlyweight registrationCorrelationId(long correlationId)

set registration correlation id field

Parameters:

correlationId - field value

Returns:

flyweight

streamId

public int streamId()

return the stream id

Returns:

the stream id

streamId

public SubscriptionMessageFlyweight streamId(int streamId)

Set the stream id

Parameters:

streamId - the channel id

Returns:

flyweight

channel

public java.lang.String channel()

Get the channel field in ASCII

Returns:

channel field

channel

public SubscriptionMessageFlyweight channel(java.lang.String channel)

Set channel field in ASCII

Parameters:

channel - field value

Returns:

flyweight

length

public int length()