CoreMessageSender.scheduleMessageAsync(Message[] messages, TransactionContext transaction, Duration timeout) 方法
定义
public CompletableFuture<long[]> scheduleMessageAsync(Message[] messages, TransactionContext transaction, Duration timeout)
参数
- messages
- Message []
- transaction
- TransactionContext
- timeout
- Duration
返回
CompletableFuture<long[]>