udp_sender.rb in jaeger-client-0.6.1

- old
+ new

@@ -5,14 +5,15 @@
 require 'thread'
 
 module Jaeger
   module Client
     class UdpSender
-      def initialize(service_name:, host:, port:, collector:, flush_interval:)
+      def initialize(service_name:, host:, port:, collector:, flush_interval:, logger:)
         @service_name = service_name
         @collector = collector
         @flush_interval = flush_interval
+        @logger = logger
 
         @tags = [
           Jaeger::Thrift::Tag.new(
             'key' => 'jaeger.version',
             'vType' => Jaeger::Thrift::TagType::STRING,
@@ -65,9 +66,11 @@
           ),
           'spans' => thrift_spans
         )
 
         @client.emitBatch(batch)
+      rescue StandardError => error
+        @logger.error("Failure while sending a batch of spans: #{error}")
       end
     end
   end
 end