Class DefaultGenericGateway

java.lang.Object
io.fluxzero.sdk.common.AbstractNamespaced<GenericGateway>
io.fluxzero.sdk.publishing.DefaultGenericGateway
All Implemented Interfaces:
Namespaced<GenericGateway>, GenericGateway, HasLocalHandlers, AutoCloseable
public class DefaultGenericGateway extends AbstractNamespaced<GenericGateway> implements GenericGateway

  • Constructor Details

  • Method Details

    • createForNamespace

      protected GenericGateway createForNamespace(String namespace)
      Specified by:
      createForNamespace in class AbstractNamespaced<GenericGateway>

    • sendAndForget

      public CompletableFuture<Void> sendAndForget(io.fluxzero.common.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(io.fluxzero.common.Guarantee guarantee, UnaryOperator<io.fluxzero.common.api.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

    • sendForMessages

      public List<CompletableFuture<Message>> sendForMessages(io.fluxzero.common.Guarantee guarantee, Message... messages)
      Description copied from interface: GenericGateway
      Sends full request messages with one publication guarantee and returns business response futures in input order. Custom gateways retain their existing batch behavior for DEFAULT; unsupported explicit guarantees fail.
      Specified by:
      sendForMessages in interface GenericGateway

    • sendAndWait

      public <R> R sendAndWait(Object input)
      Description copied from interface: GenericGateway
      Sends a message and blocks until a response is received.
      Specified by:
      sendAndWait 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

    • sendAndWait

      public <R> R sendAndWait(Object payload, io.fluxzero.common.api.Metadata metadata, io.fluxzero.common.Guarantee guarantee)
      Description copied from interface: GenericGateway
      Sends a request with a per-call publication guarantee and waits for its business response. Storage acknowledgment does not replace or delay an already available business response.
      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

    • sendForMessage

      public CompletableFuture<Message> sendForMessage(Message message, Duration timeout, io.fluxzero.common.Guarantee guarantee)
      Description copied from interface: GenericGateway
      Sends a full request with a per-call publication guarantee and effective timeout. Timeout interpretation is identical to GenericGateway.sendForMessage(Message, Duration). Custom gateways retain their existing timeout behavior for DEFAULT; unsupported explicit guarantees fail.
      Specified by:
      sendForMessage in interface GenericGateway

    • setRetentionTime

      public CompletableFuture<Void> setRetentionTime(Duration duration, io.fluxzero.common.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 according to the selected delivery guarantee

    • truncate

      public CompletableFuture<Void> truncate(io.fluxzero.common.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 according to the selected delivery guarantee

    • emptyReturnMessage

      protected CompletableFuture<Message> emptyReturnMessage()

    • withRequestGuarantee

      public DefaultGenericGateway withRequestGuarantee(io.fluxzero.common.Guarantee guarantee)
      Configures remote request/reply delivery before first use. Direct construction defaults to SENT; the standard builder resolves fluxzero.publishing.requestGuarantee and the defaults version from its own property source. Namespace gateways inherit this value. Business response completion does not await storage.
      Parameters:
      guarantee - SENT for compatibility or STORED for storage-acknowledged publication
      Returns:
      this gateway

    • withDefaultGuarantee

      public DefaultGenericGateway withDefaultGuarantee(io.fluxzero.common.Guarantee guarantee)
      Configures the concrete application delivery default before first use. Namespace gateways inherit this value. The standard builder resolves fluxzero.publishing.defaultGuarantee from its own property source. Request/reply publication uses withRequestGuarantee(Guarantee) independently of this default.
      Parameters:
      guarantee - concrete delivery guarantee; DEFAULT is not allowed
      Returns:
      this gateway

    • withShutdownTimeout

      public DefaultGenericGateway withShutdownTimeout(Supplier<Duration> timeout)
      Sets the response grace period supplier before first use; namespace-specific gateways inherit it when created. This is a programmatic alternative to DefaultRequestHandler.SHUTDOWN_TIMEOUT_PROPERTY.
      Parameters:
      timeout - supplies a non-negative response grace period when closing; zero skips waiting for outstanding responses
      Returns:
      this gateway

    • close

      public void close()
      Description copied from interface: GenericGateway
      Closes this gateway and releases any underlying resources.
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface GenericGateway
      Overrides:
      close in class AbstractNamespaced<GenericGateway>