草庐IT

AmazonSQSBufferedAsyncClient

全部标签

java - 如何强制 AmazonSQSBufferedAsyncClient 刷新消息?

我正在使用适用于Java的AWS开发工具包,并且正在使用缓冲异步sqs客户端来批处理请求,以便降低成本。当我的应用程序关闭时,我想确保没有消息在缓冲区中等待,但是我在客户端上看不到.flush()方法。调用时AmazonSQSBufferedAsyncClient.shutdown()是否刷新我的消息?我看着sourcecode目前还不清楚。该方法在它拥有的每个QueueBuffer上调用shutdown(),但在QueueBuffer.shutdown()中它说publicvoidshutdown(){//sendbufferdoesnotrequireshutdown,only//