gcloud-java pubsub API : "즉시 반환"플래그를 설정하는 방법

Question

gcloud-java pubsub API 0.2.6 사용 - 구독을 가져 오면 "Return Immediately"플래그를 TRUE로 설정하려면 어떻게해야합니까?

Answer 1

풀 호출을 위해 gcloud-java pubsub API에서 "return immediately"플래그가 기본적으로 true로 설정됩니다. 특정 라이브러리가 알파 상태이기 때문에 플래그를 설정할 방법이 없으므로 변경 될 수 있습니다.

Answer 2

(경고 : 나는 gcloud-java 팀의 일원이다) : 첫 번째 두 가지 방법이 기본적으로 true로 "즉시 반환"플래그를 설정하는

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

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

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

gcloud-java는 당겨 메시지의 세 가지 방법을 제공합니다 .

반대로 사용자를 대신하여 연속적으로 처리하는 마지막 방법은 항상 "즉시 반환"플래그를 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();