io.zeebe.util.sched.channel

Class OneToOneRingBufferChannel

java.lang.Object

org.agrona.concurrent.ringbuffer.OneToOneRingBuffer

io.zeebe.util.sched.channel.OneToOneRingBufferChannel

All Implemented Interfaces:

ConsumableChannel, org.agrona.concurrent.ringbuffer.RingBuffer

public class OneToOneRingBufferChannel
extends org.agrona.concurrent.ringbuffer.OneToOneRingBuffer
implements ConsumableChannel

Field Summary

Fields inherited from class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer

PADDING_MSG_TYPE_ID

Constructor Summary

Constructors

Constructor and Description
OneToOneRingBufferChannel(org.agrona.concurrent.AtomicBuffer buffer)

Method Summary

Modifier and Type	Method and Description
boolean	hasAvailable()
void	registerConsumer(ActorCondition onDataAvailable)
void	removeConsumer(ActorCondition onDataAvailable)
boolean	write(int msgTypeId, org.agrona.DirectBuffer srcBuffer, int srcIndex, int length)

Methods inherited from class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer

buffer, capacity, consumerHeartbeatTime, consumerHeartbeatTime, consumerPosition, maxMsgLength, nextCorrelationId, producerPosition, read, read, size, unblock

Methods inherited from class java.lang.Object

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

Constructor Detail

OneToOneRingBufferChannel

public OneToOneRingBufferChannel(org.agrona.concurrent.AtomicBuffer buffer)

Method Detail

hasAvailable

public boolean hasAvailable()

Specified by:

hasAvailable in interface ConsumableChannel

registerConsumer

public void registerConsumer(ActorCondition onDataAvailable)

Specified by:

registerConsumer in interface ConsumableChannel

removeConsumer

public void removeConsumer(ActorCondition onDataAvailable)

Specified by:

removeConsumer in interface ConsumableChannel

write

public boolean write(int msgTypeId,
                     org.agrona.DirectBuffer srcBuffer,
                     int srcIndex,
                     int length)

Specified by:

write in interface org.agrona.concurrent.ringbuffer.RingBuffer

Overrides:

write in class org.agrona.concurrent.ringbuffer.OneToOneRingBuffer