README.md in jruby-hornetq-0.3.1 vs README.md in jruby-hornetq-0.3.2
- old
+ new
@@ -114,11 +114,11 @@
Producer: Write messages to a queue:
require 'rubygems'
require 'hornetq'
- HornetQ::Client::Factory.create_session(:connector=> {:uri => 'hornetq://localhost'}) do |session|
+ HornetQ::Client::Factory.create_session(:connection => {:uri => 'hornetq://localhost'}) do |session|
# Create Producer so that we can send messages to the Address 'jms.queue.ExampleQueue'
producer = session.create_producer('jms.queue.ExampleQueue')
# Create a non-durable message to send
message = session.create_message(HornetQ::Client::Message::TEXT_TYPE,false)
@@ -131,11 +131,11 @@
Consumer: Read message from a queue:
require 'rubygems'
require 'hornetq'
- HornetQ::Client::Factory.start(:connector=> {:uri => 'hornetq://localhost'}) do |session|
+ HornetQ::Client::Factory.start(:connection => {:uri => 'hornetq://localhost'}) do |session|
consumer = session.create_consumer('jms.queue.ExampleQueue')
# Receive a single message, return immediately if no message available
if message = consumer.receive_immediate
puts "Received:[#{message.body}]"
@@ -154,11 +154,11 @@
require 'hornetq'
# Shutdown Server after 5 minutes of inactivity, set to 0 to wait forever
timeout = 300000
- HornetQ::Client::Factory.start(:connector=> {:uri => 'hornetq://localhost'}) do |session|
+ HornetQ::Client::Factory.start(:connection => {:uri => 'hornetq://localhost'}) do |session|
server = session.create_server('jms.queue.ExampleQueue', timeout)
puts "Waiting for Requests..."
server.run do |request_message|
puts "Received:[#{request_message.body}]"
@@ -182,10 +182,10 @@
require 'hornetq'
# Wait 5 seconds for a reply
timeout = 5000
- HornetQ::Client::Factory.start(:connector=> {:uri => 'hornetq://localhost'}) do |session|
+ HornetQ::Client::Factory.start(:connection => {:uri => 'hornetq://localhost'}) do |session|
requestor = session.create_requestor('jms.queue.ExampleQueue')
# Create non-durable message
message = session.create_message(HornetQ::Client::Message::TEXT_TYPE,false)
message.body = "Request Current Time"
\ No newline at end of file