您可以向Message添加确认和否定确认函数，在其中可以完成future。然后，可以在发送消息后等待该未来。

@Inject
@Channel("example-channel")
@OnOverflow(value = OnOverflow.Strategy.THROW_EXCEPTION)
Emitter<ObjectToSend> objectEmitter;

@Blocking
public void emitNewObject(ObjectToSend objectToSend) {
    try {
        CompletableFuture<Void> future = new CompletableFuture<>();

        Message<ObjectToSend> message = buildMessage(objectToSend, future);
        objectEmitter.send(message);

        future.get();
    } catch (InterruptedException | ExecutionException e) {
        log.error("Error sending message", e);
        throw new RuntimeException(e);
    }
}

private Message<ObjectToSend> buildMessage(ObjectToSend objectToSend, CompletableFuture<Void> future) {
    return Message.of(objectToSend)
        .withAck(() -> {
            future.complete(null);
            return CompletableFuture.completedFuture(null);
        }).withNack(reason -> {
            future.completeExceptionally(reason);
            return CompletableFuture.completedFuture(null);
        });
}

字符串
事实上，您在问题中提到的方法的发射器实现也做了同样的事情。