Class: BoomNats::Topic

Inherits:

Object

• Object
• BoomNats::Topic

Defined in:

lib/boom_nats/topic.rb

Instance Method Summary

• #consume ⇒ Object
• #initialize(message, reply_to, nats, serializer, parser) ⇒ Topic constructor

  A new instance of Topic.

Constructor Details

#initialize(message, reply_to, nats, serializer, parser) ⇒ Topic

Returns a new instance of Topic.

# File 'lib/boom_nats/topic.rb', line 3

def initialize(message, reply_to, nats, serializer, parser)
  @message = message
  @reply_to = reply_to
  @nats = nats
  @serializer = serializer
  @parser = parser

  start
end

Instance Method Details

#consume ⇒ Object

Raises:

• (Error)

# File 'lib/boom_nats/topic.rb', line 13

def consume
  raise Error, "consume method do not implement yet"
end