Package io.fluxcapacitor.javaclient.publishing

Class DefaultWebRequestGateway

java.lang.Object
io.fluxcapacitor.javaclient.publishing.DefaultWebRequestGateway
All Implemented Interfaces:
WebRequestGateway, HasLocalHandlers
public class DefaultWebRequestGateway extends Object implements WebRequestGateway
Default implementation of the WebRequestGateway interface that delegates requests to a configured GenericGateway. This class acts as a bridge for handling outbound web requests using Flux Platform’s proxy mechanism.

It supports sending web requests in both asynchronous (fire-and-forget, future-based) and synchronous (blocking) manners, utilizing the underlying delegate to process the actual interactions with the Flux platform.

See Also:

  • Constructor Details

    • DefaultWebRequestGateway

      public DefaultWebRequestGateway()

  • Method Details

    • sendAndForget

      public CompletableFuture<Void> sendAndForget(Guarantee guarantee, WebRequest... requests)
      Description copied from interface: WebRequestGateway
      Sends one or more web requests without waiting for a response.

      Use this for fire-and-forget scenarios (e.g., async webhook posts).

      Specified by:
      sendAndForget in interface WebRequestGateway
      Parameters:
      guarantee - indicates whether to wait until the request is sent or stored
      requests - the web requests to send
      Returns:
      a future that completes once the requests have been sent or stored

    • send

      public CompletableFuture<WebResponse> send(WebRequest request)
      Description copied from interface: WebRequestGateway
      Sends the given web request and returns a future that completes with the response.

      The request must have an absolute URL to be forwarded by the Flux proxy.

      Specified by:
      send in interface WebRequestGateway
      Parameters:
      request - the web request to send
      Returns:
      a future completed with the WebResponse

    • sendAndWait

      public WebResponse sendAndWait(WebRequest request, WebRequestSettings settings)
      Description copied from interface: WebRequestGateway
      Sends the given web request and waits for the response synchronously using the specified request settings.

      This method blocks the calling thread until the request is completed or times out.

      Specified by:
      sendAndWait in interface WebRequestGateway
      Parameters:
      request - the web request to send
      settings - configuration settings for this request (e.g., timeouts, accepted encodings)
      Returns:
      the received WebResponse