lib/mongo/monitoring/publishable.rb in mongo-2.13.0.beta1 vs lib/mongo/monitoring/publishable.rb in mongo-2.13.0.rc1
- old
+ new
@@ -30,11 +30,11 @@
end
def publish_sdam_event(topic, event)
return unless monitoring?
- log_debug("EVENT: #{event.summary}")
+ #log_debug("EVENT: #{event.summary}")
monitoring.succeeded(topic, event)
end
def publish_cmap_event(event)
return unless monitoring?
@@ -43,16 +43,19 @@
end
private
def command_started(address, operation_id, payload,
- socket_object_id: nil, connection_id: nil, connection_generation: nil
+ socket_object_id: nil, connection_id: nil, connection_generation: nil,
+ server_connection_id: nil
)
monitoring.started(
Monitoring::COMMAND,
Event::CommandStarted.generate(address, operation_id, payload,
socket_object_id: socket_object_id, connection_id: connection_id,
- connection_generation: connection_generation)
+ connection_generation: connection_generation,
+ server_connection_id: server_connection_id,
+ )
)
end
def command_completed(result, address, operation_id, payload, duration)
document = result ? (result.documents || []).first : nil