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