如何在GCP PubSubTemplate上配置拉超时?



从GCP的文档中它说:

否则,系统可能会等待(在有限的时间内)直到至少有一个消息可用,而不是不返回消息。

有没有办法配置这个"(在有限的时间内)"?我使用的是spring-cloud-gcp

如文档所述,不推荐使用returnImmediately
但是,您可以通过在streamingpullfuture# result中提到超时值来设置超时为任何Asynchronous Pull。如果不设置timeout,则result()将无限期阻塞,除非首先遇到异常。

您可以通过发布/订阅接收消息快速入门来更好地理解。您也可以查看有关不同类型的pull订阅的文档。

最新更新