Example of publishing messages at a high speed with TorqueBox

highspeedpublish.rb

queue = TorqueBox::Messaging::Queue.new('/queue/foo')
options = { :startup_timeout => 500, :persistent => false, :tx => false }
normalized_options = queue.normalize_options(options)
queue.wait_for_destination(options[:startup_timeout]) do
  queue.with_session(options) do |session|
    # loop here and publish each message
    5.times { session.publish(queue, Time.now.to_s, normalized_options) }
  end
end