lib/instrumental/agent.rb in instrumental_agent-0.9.5 vs lib/instrumental/agent.rb in instrumental_agent-0.9.6

@@ -276,11 +276,11 @@
           options[:allow_reconnect] = @allow_reconnect
         end
         synchronous = options.delete(:synchronous)
         if synchronous
           options[:sync_resource] ||= ConditionVariable.new
-          @queue << [message, options]
           @sync_mutex.synchronize {
+            @queue << [message, options]
             options[:sync_resource].wait(@sync_mutex)
           }
         else
           @queue << [message, options]
         end