Class: BPS::Publisher::NATS::Topic

Inherits:

Abstract::Topic

• Object
• Abstract::Topic
• BPS::Publisher::NATS::Topic

Defined in:

lib/bps/publisher/nats.rb

Instance Method Summary

• #flush ⇒ Object
• #initialize(client, topic) ⇒ Topic constructor

  A new instance of Topic.

• #publish(message, **_opts) ⇒ Object

Constructor Details

#initialize(client, topic) ⇒ Topic

Returns a new instance of Topic.

# File 'lib/bps/publisher/nats.rb', line 10

def initialize(client, topic)
  super()

  @client = client
  @topic = topic
end

Instance Method Details

#flush ⇒ Object

# File 'lib/bps/publisher/nats.rb', line 21

def flush(**)
  @client.flush(FLUSH_TIMEOUT)
end

#publish(message, **_opts) ⇒ Object

# File 'lib/bps/publisher/nats.rb', line 17

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