io.aeron.command

Class CorrelatedMessageFlyweight

java.lang.Object

io.aeron.command.CorrelatedMessageFlyweight

Direct Known Subclasses:

CounterMessageFlyweight, DestinationMessageFlyweight, PublicationMessageFlyweight, RemoveMessageFlyweight, SubscriptionMessageFlyweight

public class CorrelatedMessageFlyweight
extends java.lang.Object

Base flyweight that can be extended to track a client request. 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 | | | +---------------------------------------------------------------+ | Correlation ID | | | +---------------------------------------------------------------+

Field Summary

Fields

Modifier and Type	Field and Description
protected org.agrona.MutableDirectBuffer	buffer
static int	CLIENT_ID_FIELD_OFFSET
static int	CORRELATION_ID_FIELD_OFFSET
static int	LENGTH
protected int	offset

Constructor Summary

Constructors

Constructor and Description
CorrelatedMessageFlyweight()

Method Summary

Modifier and Type	Method and Description
long	clientId() return client id field
CorrelatedMessageFlyweight	clientId(long clientId) set client id field
long	correlationId() return correlation id field
CorrelatedMessageFlyweight	correlationId(long correlationId) set correlation id field
CorrelatedMessageFlyweight	wrap(org.agrona.MutableDirectBuffer buffer, int offset) Wrap the buffer at a given offset for updates.

Methods inherited from class java.lang.Object

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

Field Detail

CLIENT_ID_FIELD_OFFSET

public static final int CLIENT_ID_FIELD_OFFSET

See Also:

Constant Field Values

CORRELATION_ID_FIELD_OFFSET

public static final int CORRELATION_ID_FIELD_OFFSET

See Also:

Constant Field Values

LENGTH

public static final int LENGTH

See Also:

Constant Field Values

buffer

protected org.agrona.MutableDirectBuffer buffer

offset

protected int offset

Constructor Detail

CorrelatedMessageFlyweight

public CorrelatedMessageFlyweight()

Method Detail

wrap

public final CorrelatedMessageFlyweight wrap(org.agrona.MutableDirectBuffer buffer,
                                             int offset)

Wrap the buffer at a given offset for updates.

Parameters:

buffer - to wrap

offset - at which the message begins.

Returns:

for fluent API

clientId

public long clientId()

return client id field

Returns:

client id field

clientId

public CorrelatedMessageFlyweight clientId(long clientId)

set client id field

Parameters:

clientId - field value

Returns:

for fluent API

correlationId

public long correlationId()

return correlation id field

Returns:

correlation id field

correlationId

public CorrelatedMessageFlyweight correlationId(long correlationId)

set correlation id field

Parameters:

correlationId - field value

Returns:

for fluent API