lib/racecar/consumer.rb
# Delivers messages that got produced.
Delivers messages that got produced.
Delivers messages that got produced .
def deliver!
      @delivery_handles ||= []
      if @delivery_handles.any?
        instrumentation_payload = { delivered_message_count: @delivery_handles.size }
        @instrumenter.instrument('deliver_messages', instrumentation_payload) do
          @delivery_handles.each(&:wait)
        end
      end
      @delivery_handles.clear
    end
def deliver! @delivery_handles ||= [ ] if @delivery_handles . any? instrumentation_payload = { delivered_message_count : @delivery_handles . size } @instrumenter . instrument ( 'deliver_messages' , instrumentation_payload ) do @delivery_handles . each ( & :wait ) end end @delivery_handles . clear end
Delivers messages that got produced.
Delivers messages that got produced .