summaryrefslogtreecommitdiff
path: root/cpp/bindings/qpid/ruby/examples
diff options
context:
space:
mode:
authorTed Ross <tross@apache.org>2011-11-21 18:27:48 +0000
committerTed Ross <tross@apache.org>2011-11-21 18:27:48 +0000
commitce5f4ee0721e08b6ab60bf3f6b7a8ea0c4fcd5ba (patch)
treed5fc01bab33e1c52d5c4af110218bc30f053ed9c /cpp/bindings/qpid/ruby/examples
parent101972afe4f983349634520ca336b758d8870145 (diff)
downloadqpid-python-ce5f4ee0721e08b6ab60bf3f6b7a8ea0c4fcd5ba.tar.gz
QPID-3551 - Refactors the Qpid::Messaging::Connection APIs.
Applied patch from Darryl Pierce. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1204640 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/bindings/qpid/ruby/examples')
-rw-r--r--cpp/bindings/qpid/ruby/examples/client.rb2
-rw-r--r--cpp/bindings/qpid/ruby/examples/drain.rb2
-rw-r--r--cpp/bindings/qpid/ruby/examples/hello_world.rb2
-rw-r--r--cpp/bindings/qpid/ruby/examples/map_receiver.rb2
-rw-r--r--cpp/bindings/qpid/ruby/examples/map_sender.rb2
-rw-r--r--cpp/bindings/qpid/ruby/examples/server.rb2
-rw-r--r--cpp/bindings/qpid/ruby/examples/spout.rb2
7 files changed, 7 insertions, 7 deletions
diff --git a/cpp/bindings/qpid/ruby/examples/client.rb b/cpp/bindings/qpid/ruby/examples/client.rb
index f42f25cfc9..86ec1b7254 100644
--- a/cpp/bindings/qpid/ruby/examples/client.rb
+++ b/cpp/bindings/qpid/ruby/examples/client.rb
@@ -25,7 +25,7 @@ if __FILE__ == $0
broker = ARGV[1] || "amqp:tcp:localhost:5672"
options = ARGV[2] || ""
- connection = Qpid::Messaging::Connection.new broker, options
+ connection = Qpid::Messaging::Connection.new :url => broker, :options => options
connection.open
session = connection.create_session
sender = session.create_sender "service_queue"
diff --git a/cpp/bindings/qpid/ruby/examples/drain.rb b/cpp/bindings/qpid/ruby/examples/drain.rb
index a6cf35e189..9e8f699e8b 100644
--- a/cpp/bindings/qpid/ruby/examples/drain.rb
+++ b/cpp/bindings/qpid/ruby/examples/drain.rb
@@ -73,7 +73,7 @@ opts.parse!(ARGV)
options[:address] = ARGV[0] || ""
-connection = Qpid::Messaging::Connection.new options[:broker], options[:connection_options]
+connection = Qpid::Messaging::Connection.new :url => options[:broker], :options => options[:connection_options]
connection.open
def render_map map
diff --git a/cpp/bindings/qpid/ruby/examples/hello_world.rb b/cpp/bindings/qpid/ruby/examples/hello_world.rb
index 703febeba1..c014fb8bd5 100644
--- a/cpp/bindings/qpid/ruby/examples/hello_world.rb
+++ b/cpp/bindings/qpid/ruby/examples/hello_world.rb
@@ -30,7 +30,7 @@ if __FILE__ == $0
address = ARGV[1] || "amq.topic"
options = ARGV[2] || ""
- connection = Qpid::Messaging::Connection.new broker
+ connection = Qpid::Messaging::Connection.new :url => broker, :options => options
connection.open
session = connection.create_session
receiver = session.create_receiver address
diff --git a/cpp/bindings/qpid/ruby/examples/map_receiver.rb b/cpp/bindings/qpid/ruby/examples/map_receiver.rb
index 805943a0a4..e08bd295ba 100644
--- a/cpp/bindings/qpid/ruby/examples/map_receiver.rb
+++ b/cpp/bindings/qpid/ruby/examples/map_receiver.rb
@@ -25,7 +25,7 @@ broker = ARGV[0] || "amqp:tcp:127.0.0.1:5672"
address = ARGV[1] || "message_queue; {create: always}"
options = ARGV[2] || ""
-connection = Qpid::Messaging::Connection.new broker, options
+connection = Qpid::Messaging::Connection.new :url => broker, :options => options
connection.open
def display_value value
diff --git a/cpp/bindings/qpid/ruby/examples/map_sender.rb b/cpp/bindings/qpid/ruby/examples/map_sender.rb
index fa0c6e4562..3fb7ca58e3 100644
--- a/cpp/bindings/qpid/ruby/examples/map_sender.rb
+++ b/cpp/bindings/qpid/ruby/examples/map_sender.rb
@@ -25,7 +25,7 @@ broker = ARGV[0] || "amqp:tcp:127.0.0.1:5672"
address = ARGV[1] || "message_queue; {create: always}"
options = ARGV[2] || []
-connection = Qpid::Messaging::Connection.new broker, options
+connection = Qpid::Messaging::Connection.new :url => broker, :options => options
connection.open
begin
diff --git a/cpp/bindings/qpid/ruby/examples/server.rb b/cpp/bindings/qpid/ruby/examples/server.rb
index ead9d58472..0cc0e30216 100644
--- a/cpp/bindings/qpid/ruby/examples/server.rb
+++ b/cpp/bindings/qpid/ruby/examples/server.rb
@@ -25,7 +25,7 @@ if __FILE__ == $0
broker = ARGV[0] || "amqp:tcp:localhost:5672"
options = ARGV[1] || ""
- connection = Qpid::Messaging::Connection.new broker, options
+ connection = Qpid::Messaging::Connection.new :url => broker, :options =>options
connection.open
session = connection.create_session
receiver = session.create_receiver "service_queue; {create:always}"
diff --git a/cpp/bindings/qpid/ruby/examples/spout.rb b/cpp/bindings/qpid/ruby/examples/spout.rb
index c012e31f9d..ecc47fb15a 100644
--- a/cpp/bindings/qpid/ruby/examples/spout.rb
+++ b/cpp/bindings/qpid/ruby/examples/spout.rb
@@ -100,7 +100,7 @@ end
# now get the non-arg options
options[:address] = ARGV[0] unless ARGV[0].nil?
-connection = Qpid::Messaging::Connection.new options[:broker], options[:connection_options]
+connection = Qpid::Messaging::Connection.new :url => options[:broker], :options => options[:connection_options]
connection.open
session = connection.create_session
sender = session.create_sender options[:address]