module GRPC::Kit::Queue::Publisher
Public Instance Methods
publish(topic_name, message)
click to toggle source
# File lib/grpc/kit/queue/publisher.rb, line 11 def publish(topic_name, message) topic(topic_name).publish(message) end
pubsub()
click to toggle source
# File lib/grpc/kit/queue/publisher.rb, line 19 def pubsub @@pubsub ||= Google::Cloud::Pubsub.new end
topic(name)
click to toggle source
# File lib/grpc/kit/queue/publisher.rb, line 15 def topic(name) @@topics[name] ||= pubsub.topic(name) || pubsub.create_topic(name) end