Module: GRPC::Kit::Queue::Publisher

Defined in:
lib/grpc/kit/queue/publisher.rb

Constant Summary collapse

@@topics = 
{}

Class Method Summary collapse

Class Method Details

.publish(topic_name, message) ⇒ Object 



11
12
13
 
# File 'lib/grpc/kit/queue/publisher.rb', line 11

def publish(topic_name, message)
  topic(topic_name).publish(message)
end

.pubsub ⇒ Object 



19
20
21
 
# File 'lib/grpc/kit/queue/publisher.rb', line 19

def pubsub
  @@pubsub ||= Google::Cloud::Pubsub.new
end

.topic(name) ⇒ Object 



15
16
17
 
# File 'lib/grpc/kit/queue/publisher.rb', line 15

def topic(name)
  @@topics[name] ||= pubsub.topic(name) || pubsub.create_topic(name)
end