io.aeron.command

Class DestinationMessageFlyweight

java.lang.Object

io.aeron.command.CorrelatedMessageFlyweight

io.aeron.command.DestinationMessageFlyweight

public class DestinationMessageFlyweight
extends CorrelatedMessageFlyweight

Control message for adding or removing a destination for a Publication in multi-destination-cast or a Subscription in multi-destination 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
  +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
  |                          Client ID                            |
  |                                                               |
  +---------------------------------------------------------------+
  |                    Command Correlation ID                     |
  |                                                               |
  +---------------------------------------------------------------+
  |                  Registration Correlation 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
DestinationMessageFlyweight()

Method Summary

Modifier and Type	Method and Description
java.lang.String	channel() Get the channel field in ASCII
DestinationMessageFlyweight	channel(java.lang.String channel) Set channel field in ASCII
int	length()
long	registrationCorrelationId() return correlation id used in registration field
DestinationMessageFlyweight	registrationCorrelationId(long correlationId) set registration correlation 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

DestinationMessageFlyweight

public DestinationMessageFlyweight()

Method Detail

registrationCorrelationId

public long registrationCorrelationId()

return correlation id used in registration field

Returns:

correlation id field

registrationCorrelationId

public DestinationMessageFlyweight registrationCorrelationId(long correlationId)

set registration correlation id field

Parameters:

correlationId - field value

Returns:

flyweight

channel

public java.lang.String channel()

Get the channel field in ASCII

Returns:

channel field

channel

public DestinationMessageFlyweight channel(java.lang.String channel)

Set channel field in ASCII

Parameters:

channel - field value

Returns:

flyweight

length

public int length()