Class DefaultResultGateway

java.lang.Object

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

io.fluxzero.sdk.publishing.DefaultResultGateway

All Implemented Interfaces:

Namespaced<ResultGateway>, ResultGateway

public class DefaultResultGateway
extends AbstractNamespaced<ResultGateway>
implements ResultGateway

Default implementation of the ResultGateway interface for sending response messages.

This class is responsible for handling responses to commands, queries, dispatching the result message to the specified target using a GatewayClient.

The dispatch process utilizes the DispatchInterceptor and ResponseMapper to modify or monitor messages before they are sent.

See Also:

• ResultGateway

Constructor Summary

Constructors

Constructor	Description
DefaultResultGateway()

Method Summary

Modifier and Type	Method	Description
protected ResultGateway	createForNamespace(String namespace)
protected SerializedMessage	interceptDispatch(Object payload, Metadata metadata)
CompletableFuture<Void>	respond(Object payload, Metadata metadata, String target, Integer requestId, Guarantee guarantee)	Sends a response with the specified payload, metadata, target, request ID, and delivery guarantee.

Methods inherited from class AbstractNamespaced

close, forNamespace

Methods inherited from class Object

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

Methods inherited from interface Namespaced

forDefaultNamespace, forNamespace

Methods inherited from interface ResultGateway

respond

Constructor Details

DefaultResultGateway

public DefaultResultGateway()

Method Details

createForNamespace

protected ResultGateway createForNamespace(String namespace)

Specified by:

createForNamespace in class AbstractNamespaced<ResultGateway>

respond

public CompletableFuture<Void> respond(Object payload,
 Metadata metadata,
 String target,
 Integer requestId,
 Guarantee guarantee)

Description copied from interface: ResultGateway

Sends a response with the specified payload, metadata, target, request ID, and delivery guarantee.

This method gives full control over how and when the response is delivered.

Specified by:

respond in interface ResultGateway

Parameters:

payload - the payload of the response

metadata - additional metadata to include

target - the intended recipient of the response

requestId - the identifier of the original request

guarantee - delivery guarantee (e.g., Guarantee.SENT or Guarantee.STORED)

Returns:

a CompletableFuture that completes when the response is dispatched (depending on the guarantee)

interceptDispatch

protected SerializedMessage interceptDispatch(Object payload,
 Metadata metadata)