Package io.fluxcapacitor.javaclient.web
Class WebResponseGateway
java.lang.Object
io.fluxcapacitor.javaclient.web.WebResponseGateway
- All Implemented Interfaces:
ResultGateway
Specialized implementation of the
ResultGateway
interface for sending web response messages.
This class is responsible for handling responses to web requests, dispatching the result message to the specified
target using a GatewayClient
.
The dispatch process utilizes the DispatchInterceptor
and WebResponseMapper
to modify or monitor
web responses
before they are sent.
- See Also:
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionSends a response with the specified payload, metadata, target, request ID, and delivery guarantee.protected CompletableFuture
<Void> sendResponse
(WebResponse response, Function<SerializedMessage, CompletableFuture<Void>> dispatcher) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.fluxcapacitor.javaclient.publishing.ResultGateway
respond
-
Field Details
-
MAX_RESPONSE_SIZE
public static final int MAX_RESPONSE_SIZE- See Also:
-
-
Constructor Details
-
WebResponseGateway
public WebResponseGateway()
-
-
Method Details
-
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 interfaceResultGateway
- Parameters:
payload
- the payload of the responsemetadata
- additional metadata to includetarget
- the intended recipient of the responserequestId
- the identifier of the original requestguarantee
- delivery guarantee (e.g.,Guarantee.SENT
orGuarantee.STORED
)- Returns:
- a
CompletableFuture
that completes when the response is dispatched (depending on the guarantee)
-
sendResponse
protected CompletableFuture<Void> sendResponse(WebResponse response, Function<SerializedMessage, CompletableFuture<Void>> dispatcher)
-