Class DefaultGenericGateway

java.lang.Object

io.fluxzero.sdk.common.AbstractNamespaced<GenericGateway>

io.fluxzero.sdk.publishing.DefaultGenericGateway

All Implemented Interfaces:

Namespaced<GenericGateway>, GenericGateway, HasLocalHandlers

public class DefaultGenericGateway
extends AbstractNamespaced<GenericGateway>
implements GenericGateway

Constructor Summary

Constructors

Constructor	Description
DefaultGenericGateway()

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this gateway and releases any underlying resources.
protected GenericGateway	createForNamespace(String namespace)
protected CompletableFuture<Message>	emptyReturnMessage()
CompletableFuture<Void>	sendAndForget(Guarantee guarantee, Message... messages)	Sends multiple Message objects with a guarantee.
CompletableFuture<Void>	sendAndForget(Guarantee guarantee, UnaryOperator<SerializedMessage> interceptor, Message... messages)	Sends multiple Message objects with a guarantee.
<R> R	sendAndWait(Message message)	Sends a message and blocks for a result with a configurable timeout.
CompletableFuture<Message>	sendForMessage(Message message, Duration timeout)	Sends a single request message with the given effective timeout.
List<CompletableFuture<Message>>	sendForMessages(Message... messages)	Sends multiple messages and returns futures for their full Message responses.
CompletableFuture<Void>	setRetentionTime(Duration duration, Guarantee guarantee)	Set a new retention duration for the underlying gateway's message log.
CompletableFuture<Void>	truncate(Guarantee guarantee)	Truncates this gateway's message log and clears associated tracking positions.

Methods inherited from class AbstractNamespaced

forNamespace

Methods inherited from class Object

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

Methods inherited from interface GenericGateway

send, send, send, send, send, send, sendAndForget, sendAndForget, sendAndForget, sendAndForget, sendAndForget, sendAndForget, sendAndWait, sendAndWait, sendAndWait, sendAndWait, sendForMessage, setRetentionTime, truncate

Methods inherited from interface HasLocalHandlers

hasLocalHandlers, registerHandler, registerHandler, setSelfHandlerFilter

Methods inherited from interface Namespaced

forDefaultNamespace, forNamespace

Constructor Details

DefaultGenericGateway

public DefaultGenericGateway()

Method Details

createForNamespace

protected GenericGateway createForNamespace(String namespace)

Specified by:

createForNamespace in class AbstractNamespaced<GenericGateway>

sendAndForget

public CompletableFuture<Void> sendAndForget(Guarantee guarantee,
 Message... messages)

Description copied from interface: GenericGateway

Sends multiple Message objects with a guarantee.

Specified by:

sendAndForget in interface GenericGateway

sendAndForget

public CompletableFuture<Void> sendAndForget(Guarantee guarantee,
 UnaryOperator<SerializedMessage> interceptor,
 Message... messages)

Description copied from interface: GenericGateway

Sends multiple Message objects with a guarantee.

Before the messages are appended to the message log in Fluxzero, they can be inspected, blocked or modified using the given interceptor.

Specified by:

sendAndForget in interface GenericGateway

sendForMessages

public List<CompletableFuture<Message>> sendForMessages(Message... messages)

Description copied from interface: GenericGateway

Sends multiple messages and returns futures for their full Message responses.

Specified by:

sendForMessages in interface GenericGateway

sendAndWait

public <R> R sendAndWait(Message message)

Description copied from interface: GenericGateway

Sends a message and blocks for a result with a configurable timeout.

Timeout can be customized using @Timeout on the payload class.

Specified by:

sendAndWait in interface GenericGateway

sendForMessage

public CompletableFuture<Message> sendForMessage(Message message,
 Duration timeout)

Description copied from interface: GenericGateway

Sends a single request message with the given effective timeout.

The effective timeout is used for the returned future and is propagated as request metadata so tracking handlers can skip stale indexed requests before invocation. If timeout is null, the gateway falls back to timeout metadata already present on the message, then @Timeout on the payload class, and finally the request handler default. A negative timeout disables timeout handling for this request.

Specified by:

sendForMessage in interface GenericGateway

Parameters:

message - the message to send

timeout - the timeout for this request; null uses the gateway/request handler defaults

Returns:

a future that completes with the response message

setRetentionTime

public CompletableFuture<Void> setRetentionTime(Duration duration,
 Guarantee guarantee)

Description copied from interface: GenericGateway

Set a new retention duration for the underlying gateway's message log.

The retention setting determines how long messages in this log are retained by the system, after which they may be evicted or deleted depending on the platform policy.

Specified by:

setRetentionTime in interface GenericGateway

Parameters:

duration - the new retention duration

guarantee - the delivery guarantee to apply to the update operation

Returns:

a CompletableFuture that completes once the retention setting is updated

truncate

public CompletableFuture<Void> truncate(Guarantee guarantee)

Description copied from interface: GenericGateway

Truncates this gateway's message log and clears associated tracking positions.

Specified by:

truncate in interface GenericGateway

Parameters:

guarantee - the delivery guarantee to apply to the truncate operation

Returns:

a CompletableFuture that completes once the log is truncated

emptyReturnMessage

protected CompletableFuture<Message> emptyReturnMessage()

close

public void close()

Description copied from interface: GenericGateway

Closes this gateway and releases any underlying resources.

Specified by:

close in interface GenericGateway

Overrides:

close in class AbstractNamespaced<GenericGateway>