def apply opts
sasl if opts[:sasl_enabled]
unless opts.include?(:sasl_enabled) && !opts[:sasl_enabled]
sasl.allowed_mechs = opts[:sasl_allowed_mechs] if opts.include? :sasl_allowed_mechs
sasl.allow_insecure_mechs = opts[:sasl_allow_insecure_mechs] if opts.include? :sasl_allow_insecure_mechs
end
self.channel_max= opts[:max_sessions] if opts.include? :max_sessions
self.max_frame = opts[:max_frame_size] if opts.include? :max_frame_size
self.idle_timeout= (opts[:idle_timeout]*1000).round if opts.include? :idle_timeout
self.ssl(opts[:ssl_domain]) if opts[:ssl_domain]
end