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