Method: PubsubClient::Subscriber#listener

Defined in:
lib/pubsub_client/subscriber.rb

#listener(concurrency: DEFAULT_CONCURRENCY, auto_ack: true, &block) ⇒ Google::Cloud::PubSub::Subscriber

to remove it from the topic. Default is true.

Parameters:

  • concurrency (Integer) (defaults to: DEFAULT_CONCURRENCY) —

    • The number of threads to run the subscriber with. Default is 8.

  • auto_ack (Boolean) (defaults to: true) —

    • Flag to acknowledge the Pub/Sub message. A message must be acked

Returns:

  • (Google::Cloud::PubSub::Subscriber) 


19
20
21
22
23
24
25
26
 
# File 'lib/pubsub_client/subscriber.rb', line 19

def listener(concurrency: DEFAULT_CONCURRENCY, auto_ack: true, &block)
  @listener ||= begin
    @subscription.listen(threads: { callback: concurrency }) do |received_message|
      yield received_message.data, received_message
      received_message.acknowledge! if auto_ack
    end
  end
end