从GCP的文档中它说:
否则,系统可能会等待(在有限的时间内)直到至少有一个消息可用,而不是不返回消息。
有没有办法配置这个"(在有限的时间内)"?我使用的是spring-cloud-gcp
如文档所述,不推荐使用returnImmediately
。
但是,您可以通过在streamingpullfuture# result中提到超时值来设置超时为任何Asynchronous Pull
。如果不设置timeout
,则result()
将无限期阻塞,除非首先遇到异常。
您可以通过发布/订阅接收消息快速入门来更好地理解。您也可以查看有关不同类型的pull订阅的文档。