def initialize(options = {})
@options = options
if options[:monitoring] != false
Global.subscribers.each do |topic, subscribers|
subscribers.each do |subscriber|
subscribe(topic, subscriber)
end
end
subscribe(COMMAND, CommandLogSubscriber.new(options))
subscribe(SERVER_OPENING, ServerOpeningLogSubscriber.new(options))
subscribe(SERVER_CLOSED, ServerClosedLogSubscriber.new(options))
subscribe(SERVER_DESCRIPTION_CHANGED, ServerDescriptionChangedLogSubscriber.new(options))
subscribe(TOPOLOGY_OPENING, TopologyOpeningLogSubscriber.new(options))
subscribe(TOPOLOGY_CHANGED, TopologyChangedLogSubscriber.new(options))
subscribe(TOPOLOGY_CLOSED, TopologyClosedLogSubscriber.new(options))
end
end