Class: Liebre::Actor::Publisher::Core

Inherits:

Object

• Object
• Liebre::Actor::Publisher::Core

Defined in:

lib/liebre/actor/publisher/core.rb

Instance Method Summary

• #clean ⇒ Object
• #initialize(resources, context) ⇒ Core constructor

  A new instance of Core.

• #publish(payload, opts) ⇒ Object
• #start ⇒ Object
• #stop ⇒ Object

Constructor Details

#initialize(resources, context) ⇒ Core

Returns a new instance of Core.

# File 'lib/liebre/actor/publisher/core.rb', line 6

def initialize resources, context
  @resources = resources
  @context   = context
end

Instance Method Details

#clean ⇒ Object

# File 'lib/liebre/actor/publisher/core.rb', line 23

def clean
  exchange.delete
end

#publish(payload, opts) ⇒ Object

# File 'lib/liebre/actor/publisher/core.rb', line 19

def publish payload, opts
  exchange.publish(payload, opts)
end

#start ⇒ Object

# File 'lib/liebre/actor/publisher/core.rb', line 11

def start
  exchange
end

#stop ⇒ Object

# File 'lib/liebre/actor/publisher/core.rb', line 15

def stop
  chan.close
end