Method: Klomp::Connection#reconnect

Defined in:
lib/klomp/connection.rb

#reconnect ⇒ Object 



77
78
79
80
81
82
83
84
85
86
87
88
89
 
# File 'lib/klomp/connection.rb', line 77

def reconnect
  return if connected?
  logger.warn "reconnect server=#{options['server'].join(':')}" if logger
  connect
  subs = subscriptions.dup
  subscriptions.clear
  subs.each do |queue, subscription|
    subscribe(queue, subscription.subscriber, subscription.headers)
  end
  @sentinel = nil
ensure
  @subscriptions = subs if subs && subs.size != @subscriptions.size
end