lib/syslogstash/logstash_writer.rb in syslogstash-1.0.2 vs lib/syslogstash/logstash_writer.rb in syslogstash-1.1.0

@@ -27,10 +27,13 @@
 	# #run.
 	#
 	def send_entry(e)
 		@entries_mutex.synchronize do
 			@entries << { content: e, arrival_timestamp: Time.now }
-			@entries.shift while @entries.length > @backlog
+			while @entries.length > @backlog
+				@entries.shift
+				@metrics.dropped
+			end
 		end
 		@worker.run if @worker
 	end
 
 	# Start sending messages to logstash servers.  This method will return