torquebox_messaging_patch.rb

require 'torquebox/messaging'
require 'torquebox/messaging/connection_factory'
require 'torquebox/messaging/destination'

module TorqueBox
  module Messaging
    class Destination
      def publish_each(messages, options = {})
        wait_for_destination(options[:startup_timeout]) do
          with_session(options) do |session|
            messages.each do |message|
              message_options = options.dup
              yield message, message_options if block_given?
              session.publish self, message, normalize_options(message_options)
            end
          end
        end
      end
    end
  end
end