Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.connector.impl

Class FlowControlledReplyChannelWriter<T>

java.lang.Object

io.axoniq.axonserver.connector.impl.FlowControlledReplyChannelWriter<T>

Type Parameters:

T - the type of message

All Implemented Interfaces:

FlowControl

public class FlowControlledReplyChannelWriter<T>
extends Object
implements FlowControl

A FlowControl implementation that on request(long) retrieves messages from the buffer. These are in turn send via a ReplyChannel.

Since:

4.6.0

Author:

Milan Savic, Stefan Dragisic, Allard Buijze

Constructor Summary

Constructors

Constructor	Description
FlowControlledReplyChannelWriter(DisposableReadonlyBuffer<T> source, ReplyChannel<T> destination)	Instantiates this flow control with the given DisposableReadonlyBuffer as source, and a ReplyChannel as the destination.
FlowControlledReplyChannelWriter(List<? extends DisposableReadonlyBuffer<T>> sources, ReplyChannel<T> destination)	Instantiates this flow control with given buffers as sources, and ReplyChannel as the destination.

Method Summary

Modifier and Type	Method	Description
void	cancel()	Cancels response sending.
void	request(long requested)	Requests the requested amount of responses to be sent.

Methods inherited from class java.lang.Object

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

Constructor Detail

FlowControlledReplyChannelWriter

public FlowControlledReplyChannelWriter(List<? extends DisposableReadonlyBuffer<T>> sources,
                                        ReplyChannel<T> destination)

Instantiates this flow control with given buffers as sources, and ReplyChannel as the destination. Buffers will be organized in a round-robin fashion.

Parameters:

sources - DisposableReadonlyBuffers to read messages from

destination - ReplyChannel to write messages to

See Also:

RoundRobinMultiReadonlyBuffer

FlowControlledReplyChannelWriter

public FlowControlledReplyChannelWriter(DisposableReadonlyBuffer<T> source,
                                        ReplyChannel<T> destination)

Instantiates this flow control with the given DisposableReadonlyBuffer as source, and a ReplyChannel as the destination.

Parameters:

source - DisposableReadonlyBuffer to read messages from

destination - ReplyChannel to write messages to

Method Detail

request

public void request(long requested)

Description copied from interface: FlowControl

Requests the requested amount of responses to be sent.

Specified by:

request in interface FlowControl

Parameters:

requested - number of responses to be sent

cancel

public void cancel()

Description copied from interface: FlowControl

Cancels response sending.

Specified by:

cancel in interface FlowControl