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