examples/advanced/transaction-failover/producer.rb in jruby-hornetq-0.2.3.alpha vs examples/advanced/transaction-failover/producer.rb in jruby-hornetq-0.2.5.alpha
- old
+ new
@@ -12,10 +12,9 @@
config = YAML.load_file(File.dirname(__FILE__) + '/hornetq.yml')
constants = config['constants']
# Create a HornetQ session
HornetQ::Client::Factory.session(config['client']) do |session|
- session.delete_queue(constants[:queue]) rescue nil
session.create_queue(constants[:address], constants[:queue], constants[:durable])
producer = session.create_producer(constants[:address])
start_time = Time.now
puts "Sending messages"