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.
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.

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, sendAndWait, sendForMessage, setRetentionTime

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

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

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>