Interface LogicCollectCommunication

All Superinterfaces:
PublisherCommunication
All Known Subinterfaces:
CommunicationAggregation
All Known Implementing Classes:
DefaultCommunicationAggregation
public interface LogicCollectCommunication extends PublisherCommunication
Communication interface for collecting aggregated responses from multiple logic servers.

Extends PublisherCommunication and provides both synchronous and asynchronous (future-based) methods for broadcasting a request to all logic servers that handle the target command and gathering their individual responses into a single ResponseCollect.

Since:
25.1
Author:
渔民小镇
date:
2025-09-04

  • Method Details

    • callCollectFuture

      CompletableFuture<ResponseCollect> callCollectFuture(RequestMessage message)
      Asynchronously call all matching logic servers and collect their responses.
      Parameters:
      message - the request message to broadcast
      Returns:
      a future that completes with the aggregated response from all logic servers

    • callCollect

      ResponseCollect callCollect(RequestMessage message)
      Synchronously call all matching logic servers and collect their responses.
      Parameters:
      message - the request message to broadcast
      Returns:
      the aggregated response from all logic servers