Interface LogicCallCollectCommunicationDecorator

All Superinterfaces:

CommonDecorator, LogicCommunicationDecorator

All Known Subinterfaces:

Communication, FlowContext, FlowLogicCallCollectCommunication

All Known Implementing Classes:

DefaultCommunication, DefaultFlowContext

public interface LogicCallCollectCommunicationDecorator
extends CommonDecorator, LogicCommunicationDecorator

Decorator providing cross-logic-server collect-style calls that aggregate responses from multiple logic servers.

All methods in this interface are enterprise-only and throw EnterpriseSupportException by default. The enterprise implementation overrides these defaults with actual collect-call logic.

Since:

25.1

Author:

渔民小镇

date:

2025-09-28

Method Summary

Modifier and Type	Method	Description
default ResponseCollect	callCollect(CmdInfo cmdInfo)	Synchronous collect-call with no payload.
default ResponseCollect	callCollect(CmdInfo cmdInfo, boolean data)	Synchronous collect-call with boolean payload.
default ResponseCollect	callCollect(CmdInfo cmdInfo, byte[] data)	Call all logic servers that handle the given command and collect their responses synchronously.
default ResponseCollect	callCollect(CmdInfo cmdInfo, int data)	Synchronous collect-call with int payload.
default ResponseCollect	callCollect(CmdInfo cmdInfo, long data)	Synchronous collect-call with long payload.
default ResponseCollect	callCollect(CmdInfo cmdInfo, Object data)	Synchronous collect-call with Object payload.
default ResponseCollect	callCollect(CmdInfo cmdInfo, String data)	Synchronous collect-call with String payload.
default ResponseCollect	callCollect(CmdInfo cmdInfo, List<?> dataList)	Synchronous collect-call with List payload.
default ResponseCollect	callCollect(RequestMessage message)	Synchronous collect-call using a pre-built request message.
default void	callCollectAsync(CmdInfo cmdInfo, boolean data, Consumer<ResponseCollect> action)	Async collect-call with boolean payload.
default void	callCollectAsync(CmdInfo cmdInfo, byte[] data, Consumer<ResponseCollect> action)	Call all logic servers asynchronously, invoking the callback with the aggregated response.
default void	callCollectAsync(CmdInfo cmdInfo, int data, Consumer<ResponseCollect> action)	Async collect-call with int payload.
default void	callCollectAsync(CmdInfo cmdInfo, long data, Consumer<ResponseCollect> action)	Async collect-call with long payload.
default void	callCollectAsync(CmdInfo cmdInfo, Object data, Consumer<ResponseCollect> action)	Async collect-call with Object payload.
default void	callCollectAsync(CmdInfo cmdInfo, String data, Consumer<ResponseCollect> action)	Async collect-call with String payload.
default void	callCollectAsync(CmdInfo cmdInfo, Consumer<ResponseCollect> action)	Async collect-call with no payload.
default void	callCollectAsync(CmdInfo cmdInfo, List<?> dataList, Consumer<ResponseCollect> action)	Async collect-call with List payload.
default void	callCollectAsync(RequestMessage message, Consumer<ResponseCollect> action)	Async collect-call using a pre-built request message with the current executor.
default void	callCollectAsync(RequestMessage message, Consumer<ResponseCollect> action, Executor executor)	Async collect-call using a pre-built request message with a custom executor.
default void	callCollectAsyncListBool(CmdInfo cmdInfo, List<Boolean> dataList, Consumer<ResponseCollect> action)	Async collect-call with List<Boolean> payload.
default void	callCollectAsyncListInt(CmdInfo cmdInfo, List<Integer> dataList, Consumer<ResponseCollect> action)	Async collect-call with List<Integer> payload.
default void	callCollectAsyncListLong(CmdInfo cmdInfo, List<Long> dataList, Consumer<ResponseCollect> action)	Async collect-call with List<Long> payload.
default void	callCollectAsyncListString(CmdInfo cmdInfo, List<String> dataList, Consumer<ResponseCollect> action)	Async collect-call with List<String> payload.
default CompletableFuture<ResponseCollect>	callCollectFuture(CmdInfo cmdInfo)	Future-based collect-call with no payload.
default CompletableFuture<ResponseCollect>	callCollectFuture(CmdInfo cmdInfo, boolean data)	Future-based collect-call with boolean payload.
default CompletableFuture<ResponseCollect>	callCollectFuture(CmdInfo cmdInfo, byte[] data)	Call all logic servers that handle the given command and return a CompletableFuture for the aggregated response.
default CompletableFuture<ResponseCollect>	callCollectFuture(CmdInfo cmdInfo, int data)	Future-based collect-call with int payload.
default CompletableFuture<ResponseCollect>	callCollectFuture(CmdInfo cmdInfo, long data)	Future-based collect-call with long payload.
default CompletableFuture<ResponseCollect>	callCollectFuture(CmdInfo cmdInfo, Object data)	Future-based collect-call with Object payload.
default CompletableFuture<ResponseCollect>	callCollectFuture(CmdInfo cmdInfo, String data)	Future-based collect-call with String payload.
default CompletableFuture<ResponseCollect>	callCollectFuture(CmdInfo cmdInfo, List<?> dataList)	Future-based collect-call with List payload.
default CompletableFuture<ResponseCollect>	callCollectFuture(RequestMessage message)	Future-based collect-call using a pre-built request message.
default CompletableFuture<ResponseCollect>	callCollectFutureListBool(CmdInfo cmdInfo, List<Boolean> dataList)	Future-based collect-call with List<Boolean> payload.
default CompletableFuture<ResponseCollect>	callCollectFutureListInt(CmdInfo cmdInfo, List<Integer> dataList)	Future-based collect-call with List<Integer> payload.
default CompletableFuture<ResponseCollect>	callCollectFutureListLong(CmdInfo cmdInfo, List<Long> dataList)	Future-based collect-call with List<Long> payload.
default CompletableFuture<ResponseCollect>	callCollectFutureListString(CmdInfo cmdInfo, List<String> dataList)	Future-based collect-call with List<String> payload.
default ResponseCollect	callCollectListBool(CmdInfo cmdInfo, List<Boolean> dataList)	Synchronous collect-call with List<Boolean> payload.
default ResponseCollect	callCollectListInt(CmdInfo cmdInfo, List<Integer> dataList)	Synchronous collect-call with List<Integer> payload.
default ResponseCollect	callCollectListLong(CmdInfo cmdInfo, List<Long> dataList)	Synchronous collect-call with List<Long> payload.
default ResponseCollect	callCollectListString(CmdInfo cmdInfo, List<String> dataList)	Synchronous collect-call with List<String> payload.

Methods inherited from interface CommonDecorator

getCommunicationAggregation, getCurrentExecutor, getTraceId

Methods inherited from interface LogicCommunicationDecorator

ofRequestMessage, ofRequestMessage, ofRequestMessage, ofRequestMessage, ofRequestMessage, ofRequestMessage, ofRequestMessage, ofRequestMessageListBool, ofRequestMessageListInt, ofRequestMessageListLong, ofRequestMessageListString

Method Details

callCollect

default ResponseCollect callCollect(RequestMessage message)

Synchronous collect-call using a pre-built request message. @see #callCollect(CmdInfo, byte[])

callCollect

default ResponseCollect callCollect(CmdInfo cmdInfo,
 byte[] data)

Call all logic servers that handle the given command and collect their responses synchronously.

Parameters:

cmdInfo - the target command route

data - the raw byte payload

Returns:

the aggregated response from all matching logic servers

callCollect

default ResponseCollect callCollect(CmdInfo cmdInfo)

Synchronous collect-call with no payload. @see #callCollect(CmdInfo, byte[])

callCollect

default ResponseCollect callCollect(CmdInfo cmdInfo,
 int data)

Synchronous collect-call with int payload. @see #callCollect(CmdInfo, byte[])

callCollect

default ResponseCollect callCollect(CmdInfo cmdInfo,
 long data)

Synchronous collect-call with long payload. @see #callCollect(CmdInfo, byte[])

callCollect

default ResponseCollect callCollect(CmdInfo cmdInfo,
 boolean data)

Synchronous collect-call with boolean payload. @see #callCollect(CmdInfo, byte[])

callCollect

default ResponseCollect callCollect(CmdInfo cmdInfo,
 String data)

Synchronous collect-call with String payload. @see #callCollect(CmdInfo, byte[])

callCollect

default ResponseCollect callCollect(CmdInfo cmdInfo,
 Object data)

Synchronous collect-call with Object payload. @see #callCollect(CmdInfo, byte[])

callCollect

default ResponseCollect callCollect(CmdInfo cmdInfo,
 List<?> dataList)

Synchronous collect-call with List payload. @see #callCollect(CmdInfo, byte[])

callCollectListInt

default ResponseCollect callCollectListInt(CmdInfo cmdInfo,
 List<Integer> dataList)

Synchronous collect-call with List<Integer> payload. @see #callCollect(CmdInfo, byte[])

callCollectListLong

default ResponseCollect callCollectListLong(CmdInfo cmdInfo,
 List<Long> dataList)

Synchronous collect-call with List<Long> payload. @see #callCollect(CmdInfo, byte[])

callCollectListBool

default ResponseCollect callCollectListBool(CmdInfo cmdInfo,
 List<Boolean> dataList)

Synchronous collect-call with List<Boolean> payload. @see #callCollect(CmdInfo, byte[])

callCollectListString

default ResponseCollect callCollectListString(CmdInfo cmdInfo,
 List<String> dataList)

Synchronous collect-call with List<String> payload. @see #callCollect(CmdInfo, byte[])

callCollectFuture

default CompletableFuture<ResponseCollect> callCollectFuture(RequestMessage message)

Future-based collect-call using a pre-built request message. @see #callCollectFuture(CmdInfo, byte[])

callCollectFuture

default CompletableFuture<ResponseCollect> callCollectFuture(CmdInfo cmdInfo,
 byte[] data)

Call all logic servers that handle the given command and return a CompletableFuture for the aggregated response.

Parameters:

cmdInfo - the target command route

data - the raw byte payload

Returns:

a CompletableFuture that completes with the aggregated response

callCollectFuture

default CompletableFuture<ResponseCollect> callCollectFuture(CmdInfo cmdInfo)

Future-based collect-call with no payload. @see #callCollectFuture(CmdInfo, byte[])

callCollectFuture

default CompletableFuture<ResponseCollect> callCollectFuture(CmdInfo cmdInfo,
 int data)

Future-based collect-call with int payload. @see #callCollectFuture(CmdInfo, byte[])

callCollectFuture

default CompletableFuture<ResponseCollect> callCollectFuture(CmdInfo cmdInfo,
 long data)

Future-based collect-call with long payload. @see #callCollectFuture(CmdInfo, byte[])

callCollectFuture

default CompletableFuture<ResponseCollect> callCollectFuture(CmdInfo cmdInfo,
 boolean data)

Future-based collect-call with boolean payload. @see #callCollectFuture(CmdInfo, byte[])

callCollectFuture

default CompletableFuture<ResponseCollect> callCollectFuture(CmdInfo cmdInfo,
 String data)

Future-based collect-call with String payload. @see #callCollectFuture(CmdInfo, byte[])

callCollectFuture

default CompletableFuture<ResponseCollect> callCollectFuture(CmdInfo cmdInfo,
 Object data)

Future-based collect-call with Object payload. @see #callCollectFuture(CmdInfo, byte[])

callCollectFuture

default CompletableFuture<ResponseCollect> callCollectFuture(CmdInfo cmdInfo,
 List<?> dataList)

Future-based collect-call with List payload. @see #callCollectFuture(CmdInfo, byte[])

callCollectFutureListInt

default CompletableFuture<ResponseCollect> callCollectFutureListInt(CmdInfo cmdInfo,
 List<Integer> dataList)

Future-based collect-call with List<Integer> payload. @see #callCollectFuture(CmdInfo, byte[])

callCollectFutureListLong

default CompletableFuture<ResponseCollect> callCollectFutureListLong(CmdInfo cmdInfo,
 List<Long> dataList)

Future-based collect-call with List<Long> payload. @see #callCollectFuture(CmdInfo, byte[])

callCollectFutureListBool

default CompletableFuture<ResponseCollect> callCollectFutureListBool(CmdInfo cmdInfo,
 List<Boolean> dataList)

Future-based collect-call with List<Boolean> payload. @see #callCollectFuture(CmdInfo, byte[])

callCollectFutureListString

default CompletableFuture<ResponseCollect> callCollectFutureListString(CmdInfo cmdInfo,
 List<String> dataList)

Future-based collect-call with List<String> payload. @see #callCollectFuture(CmdInfo, byte[])

callCollectAsync

default void callCollectAsync(RequestMessage message,
 Consumer<ResponseCollect> action)

Async collect-call using a pre-built request message with the current executor. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsync

default void callCollectAsync(RequestMessage message,
 Consumer<ResponseCollect> action,
 Executor executor)

Async collect-call using a pre-built request message with a custom executor. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsync

default void callCollectAsync(CmdInfo cmdInfo,
 byte[] data,
 Consumer<ResponseCollect> action)

Call all logic servers asynchronously, invoking the callback with the aggregated response.

Parameters:

cmdInfo - the target command route

data - the raw byte payload

action - the callback to invoke with the aggregated response

callCollectAsync

default void callCollectAsync(CmdInfo cmdInfo,
 Consumer<ResponseCollect> action)

Async collect-call with no payload. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsync

default void callCollectAsync(CmdInfo cmdInfo,
 int data,
 Consumer<ResponseCollect> action)

Async collect-call with int payload. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsync

default void callCollectAsync(CmdInfo cmdInfo,
 long data,
 Consumer<ResponseCollect> action)

Async collect-call with long payload. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsync

default void callCollectAsync(CmdInfo cmdInfo,
 boolean data,
 Consumer<ResponseCollect> action)

Async collect-call with boolean payload. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsync

default void callCollectAsync(CmdInfo cmdInfo,
 String data,
 Consumer<ResponseCollect> action)

Async collect-call with String payload. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsync

default void callCollectAsync(CmdInfo cmdInfo,
 Object data,
 Consumer<ResponseCollect> action)

Async collect-call with Object payload. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsync

default void callCollectAsync(CmdInfo cmdInfo,
 List<?> dataList,
 Consumer<ResponseCollect> action)

Async collect-call with List payload. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsyncListInt

default void callCollectAsyncListInt(CmdInfo cmdInfo,
 List<Integer> dataList,
 Consumer<ResponseCollect> action)

Async collect-call with List<Integer> payload. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsyncListLong

default void callCollectAsyncListLong(CmdInfo cmdInfo,
 List<Long> dataList,
 Consumer<ResponseCollect> action)

Async collect-call with List<Long> payload. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsyncListBool

default void callCollectAsyncListBool(CmdInfo cmdInfo,
 List<Boolean> dataList,
 Consumer<ResponseCollect> action)

Async collect-call with List<Boolean> payload. @see #callCollectAsync(CmdInfo, byte[], Consumer)

callCollectAsyncListString

default void callCollectAsyncListString(CmdInfo cmdInfo,
 List<String> dataList,
 Consumer<ResponseCollect> action)

Async collect-call with List<String> payload. @see #callCollectAsync(CmdInfo, byte[], Consumer)