Module: Fluent

Defined in:
lib/fluent/plugin/out_cloud_pubsub.rb

Defined Under Namespace

Classes: CloudPubSubOutput

Instance Method Summary collapse

Instance Method Details

#publish(msgs) ⇒ Object 



67
68
69
70
71
72
73
 
# File 'lib/fluent/plugin/out_cloud_pubsub.rb', line 67

def publish(msgs)
  @client.publish do |batch|
    msgs.each do |m|
      batch.publish m
    end
  end
end