Class: BPS::Publisher::STAN::Topic

Inherits:
Abstract::Topic
  • Object
show all
Defined in:
lib/bps/publisher/stan.rb

Instance Method Summary collapse

Constructor Details

#initialize(client, topic) ⇒ Topic

Returns a new instance of Topic.



8
9
10
11
12
13
 
# File 'lib/bps/publisher/stan.rb', line 8

def initialize(client, topic)
  super()

  @client = client
  @topic = topic
end

Instance Method Details

#flush ⇒ Object 



19
20
21
 
# File 'lib/bps/publisher/stan.rb', line 19

def flush(**)
  # noop
end

#publish(message, **_opts) ⇒ Object 



15
16
17
 
# File 'lib/bps/publisher/stan.rb', line 15

def publish(message, **_opts)
  @client.publish(@topic, message)
end