Class DefaultErrorGateway

java.lang.Object

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

io.fluxzero.sdk.publishing.DefaultErrorGateway

All Implemented Interfaces:

Namespaced<ErrorGateway>, ErrorGateway, HasLocalHandlers

public class DefaultErrorGateway
extends AbstractNamespaced<ErrorGateway>
implements ErrorGateway

Default implementation of the ErrorGateway interface.

This class delegates all functionality to an underlying GenericGateway instance, enabling the use of error gateway methods while leveraging the generic gateway's capabilities.

See Also:

• ErrorGateway
• GenericGateway

Constructor Summary

Constructors

Constructor	Description
DefaultErrorGateway()

Method Summary

Modifier and Type	Method	Description
protected ErrorGateway	createForNamespace(String namespace)
DefaultErrorGateway	forNamespace(String namespace)	Returns the resource scoped to the specified namespace.
CompletableFuture<Void>	report(Guarantee guarantee, Message... errors)	Reports one or more error messages with the given delivery guarantee.
CompletableFuture<Void>	report(Object payload, Metadata metadata, Guarantee guarantee)	Reports an error with the given payload, metadata, and delivery guarantee.

Methods inherited from class AbstractNamespaced

close

Methods inherited from class Object

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

Methods inherited from interface ErrorGateway

report, report

Methods inherited from interface HasLocalHandlers

hasLocalHandlers, registerHandler, registerHandler, setSelfHandlerFilter

Methods inherited from interface Namespaced

forApplicationNamespace, forDefaultNamespace

Constructor Details

DefaultErrorGateway

public DefaultErrorGateway()

Method Details

report

public CompletableFuture<Void> report(Object payload,
 Metadata metadata,
 Guarantee guarantee)

Description copied from interface: ErrorGateway

Reports an error with the given payload, metadata, and delivery guarantee.

Returns a future that completes once the error message is sent or stored based on the provided guarantee.

Specified by:

report in interface ErrorGateway

Parameters:

payload - the error payload

metadata - metadata describing the context of the error

guarantee - whether to ensure message is sent (Guarantee.SENT) or stored (Guarantee.STORED)

Returns:

a future that completes once the message has been handled appropriately

report

public CompletableFuture<Void> report(Guarantee guarantee,
 Message... errors)

Description copied from interface: ErrorGateway

Reports one or more error messages with the given delivery guarantee.

This method returns a future and does not block the caller while waiting for publication to complete.

Specified by:

report in interface ErrorGateway

Parameters:

guarantee - whether to ensure messages are sent or stored

errors - the error messages to report

Returns:

a future that completes once the messages have been handled according to the guarantee

createForNamespace

protected ErrorGateway createForNamespace(String namespace)

Specified by:

createForNamespace in class AbstractNamespaced<ErrorGateway>

forNamespace

public DefaultErrorGateway forNamespace(String namespace)

Description copied from interface: Namespaced

Returns the resource scoped to the specified namespace. Passing null selects the namespace configured for this application.

Specified by:

forNamespace in interface Namespaced<ErrorGateway>

Overrides:

forNamespace in class AbstractNamespaced<ErrorGateway>

Parameters:

namespace - the namespace to which the returned resource is scoped, or null for the application namespace

Returns:

the resource associated with the specified namespace