Class DefaultGenericGateway
java.lang.Object
io.fluxcapacitor.javaclient.publishing.DefaultGenericGateway
- All Implemented Interfaces:
GenericGateway
,HasLocalHandlers
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
Closes this gateway and releases any underlying resources.protected CompletableFuture
<Message> sendAndForget
(Guarantee guarantee, Message... messages) Sends multipleMessage
objects with a guarantee.sendForMessages
(Message... messages) Sends multiple messages and returns futures for their fullMessage
responses.setRetentionTime
(Duration duration, Guarantee guarantee) Set a new retention duration for the underlying gateway's message log.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.GenericGateway
send, send, send, send, send, send, sendAndForget, sendAndForget, sendAndForget, sendAndForget, sendAndForget, sendAndForget, sendAndWait, sendAndWait, sendAndWait, sendAndWait, sendAndWait, sendForMessage, setRetentionTime
Methods inherited from interface io.fluxcapacitor.javaclient.tracking.handling.HasLocalHandlers
hasLocalHandlers, registerHandler, registerHandler, setSelfHandlerFilter
-
Constructor Details
-
DefaultGenericGateway
public DefaultGenericGateway()
-
-
Method Details
-
sendAndForget
Description copied from interface:GenericGateway
Sends multipleMessage
objects with a guarantee.- Specified by:
sendAndForget
in interfaceGenericGateway
-
sendForMessages
Description copied from interface:GenericGateway
Sends multiple messages and returns futures for their fullMessage
responses.- Specified by:
sendForMessages
in interfaceGenericGateway
-
setRetentionTime
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 interfaceGenericGateway
- Parameters:
duration
- the new retention durationguarantee
- the delivery guarantee to apply to the update operation- Returns:
- a
CompletableFuture
that completes once the retention setting is updated
-
emptyReturnMessage
-
close
public void close()Description copied from interface:GenericGateway
Closes this gateway and releases any underlying resources.- Specified by:
close
in interfaceGenericGateway
-