lib/kafka/connection.rb in ruby-kafka-0.5.1.beta1 vs lib/kafka/connection.rb in ruby-kafka-0.5.1.beta2
- old
+ new
@@ -87,13 +87,13 @@
api: api_name,
request_size: 0,
response_size: 0,
}
+ raise IdleConnection if idle?
+
@instrumenter.instrument("request.connection", notification) do
open unless open?
-
- raise IdleConnection if idle?
@correlation_id += 1
@logger.debug "Sending #{api_name} API request #{@correlation_id} to #{to_s}"