def initialize
@config = Config.instance
@subscriptions = []
@base64 = false
@use_exponential_back_off = get_bool_option("rabbitmq.use_exponential_back_off", "true")
@initial_reconnect_delay = Float(get_option("rabbitmq.initial_reconnect_delay", 0.01))
@back_off_multiplier = Integer(get_option("rabbitmq.back_off_multiplier", 2))
@max_reconnect_delay = Float(get_option("rabbitmq.max_reconnect_delay", 30.0))
@reconnect_delay = @initial_reconnect_delay
Log.info("RabbitMQ connector initialized. Using stomp-gem #{stomp_version}")
end