gcloud-java pubsub API：如何設置「立即返回」標誌

Question

使用gcloud-java pubsub API 0.2.6 - 如何通過訂閱拉來將「立即返回」標誌設置爲TRUE？

Answer 1

默認情況下，gcloud-java pubsub API中的「立即返回」標誌設置爲true以進行拉式調用。目前沒有辦法設置標誌，儘管該特定的庫位於alpha中，因此可能會改變。

Answer 2

（警告：我是gcloud-java團隊的一部分）

gcloud-java提供提取消息的方式有三種：

Future<Iterator<ReceivedMessage>> pullAsync(String subscription, int maxMessages); 

Iterator<ReceivedMessage> pull(String subscription, int maxMessages); 

MessageConsumer pullAsync(String subscription, MessageProcessor callback, PullOption... options); 

前兩種方法都默認設置「立即返回」標誌設置爲true 。

相反，最後一個代表用戶處理連續提取的方法始終將「立即返回」標誌設置爲false。一個使用示例可能如下

MessageProcessor messageProcessor = new MessageProcessor() { 

    @Override 
    public void process(Message message) throws Exception { 
    // handle message 
    } 
}; 

MessageConsumer consumer = pubsub.pullAsync(subscription, messageProcessor); 

// close the consumer to stop pulling 
consumer.close();