Class: Liebre::Bridge
- Inherits:
-
Object
- Object
- Liebre::Bridge
- Defined in:
- lib/liebre/bridge.rb,
lib/liebre/bridge/channel_builder.rb
Defined Under Namespace
Classes: ChannelBuilder
Constant Summary collapse
- NotStarted =
Class.new(StandardError)
Instance Method Summary collapse
-
#initialize(config) ⇒ Bridge
constructor
A new instance of Bridge.
- #open_channel(opts) ⇒ Object
- #start ⇒ Object
- #started? ⇒ Boolean
- #stop ⇒ Object
Constructor Details
#initialize(config) ⇒ Bridge
Returns a new instance of Bridge.
9 10 11 12 |
# File 'lib/liebre/bridge.rb', line 9 def initialize config @config = config @started = false end |
Instance Method Details
#open_channel(opts) ⇒ Object
29 30 31 32 33 34 35 36 |
# File 'lib/liebre/bridge.rb', line 29 def open_channel opts if started? builder = ChannelBuilder.new(connections, opts) builder.call else raise NotStarted end end |
#start ⇒ Object
18 19 20 21 22 23 24 25 26 27 |
# File 'lib/liebre/bridge.rb', line 18 def start if not started? connections.each do |name, conn| conn.start logger.info("Connection started: #{name.inspect}") end self.started = true end end |
#started? ⇒ Boolean
14 15 16 |
# File 'lib/liebre/bridge.rb', line 14 def started? @started end |
#stop ⇒ Object
38 39 40 41 42 43 44 |
# File 'lib/liebre/bridge.rb', line 38 def stop if started? connections.each { |_name, conn| conn.stop } self.started = false end end |