gcloud-java pubsub接口:如何设置立即返回标志

Question

使用gcloud-java pubsub API 0.2.6 -如何通过订阅拉取将"Return Immediately“标志设置为TRUE？

Answer 1

在用于拉取调用的gcloud-java pubsub API中，缺省情况下将“立即返回”标志设置为真。虽然这个特定的库是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();