class Liebre::Actor::Publisher::Core

Attributes

context[R]
resources[R]

Public Class Methods

new(resources, context) click to toggle source
# File lib/liebre/actor/publisher/core.rb, line 6
def initialize resources, context
  @resources = resources
  @context   = context
end

Public Instance Methods

clean() click to toggle source
# File lib/liebre/actor/publisher/core.rb, line 23
def clean
  exchange.delete
end
publish(payload, opts) click to toggle source
# File lib/liebre/actor/publisher/core.rb, line 19
def publish payload, opts
  exchange.publish(payload, opts)
end
start() click to toggle source
# File lib/liebre/actor/publisher/core.rb, line 11
def start
  exchange
end
stop() click to toggle source
# File lib/liebre/actor/publisher/core.rb, line 15
def stop
  chan.close
end

Private Instance Methods

chan() click to toggle source
# File lib/liebre/actor/publisher/core.rb, line 33
def chan
  context.chan
end
exchange() click to toggle source
# File lib/liebre/actor/publisher/core.rb, line 29
def exchange
  resources.exchange
end