diff options
Diffstat (limited to 'cpp/bindings/qpid/ruby/examples')
| -rw-r--r-- | cpp/bindings/qpid/ruby/examples/client.rb | 50 | ||||
| -rw-r--r-- | cpp/bindings/qpid/ruby/examples/drain.rb | 111 | ||||
| -rw-r--r-- | cpp/bindings/qpid/ruby/examples/hello_world.rb | 49 | ||||
| -rw-r--r-- | cpp/bindings/qpid/ruby/examples/map_receiver.rb | 63 | ||||
| -rw-r--r-- | cpp/bindings/qpid/ruby/examples/map_sender.rb | 52 | ||||
| -rw-r--r-- | cpp/bindings/qpid/ruby/examples/server.rb | 51 | ||||
| -rw-r--r-- | cpp/bindings/qpid/ruby/examples/spout.rb | 126 |
7 files changed, 0 insertions, 502 deletions
diff --git a/cpp/bindings/qpid/ruby/examples/client.rb b/cpp/bindings/qpid/ruby/examples/client.rb deleted file mode 100644 index f42f25cfc9..0000000000 --- a/cpp/bindings/qpid/ruby/examples/client.rb +++ /dev/null @@ -1,50 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# - -$:.unshift File.join(File.dirname(__FILE__), "..", "lib") - -require 'qpid' - -if __FILE__ == $0 - broker = ARGV[1] || "amqp:tcp:localhost:5672" - options = ARGV[2] || "" - - connection = Qpid::Messaging::Connection.new broker, options - connection.open - session = connection.create_session - sender = session.create_sender "service_queue" - response_queue = Qpid::Messaging::Address.new("#response-queue", "", - :create => :always, - :delete => :always) - receiver = session.create_receiver response_queue - - ["Twas brillig, and the slithy toves", - "Did gire and gymble in the wabe.", - "All mimsy were the borogroves,", - "And the mome raths outgrabe."].each do |line| - request = Qpid::Messaging::Message.new :content => line - request.reply_to = response_queue - sender.send request - response = receiver.fetch - puts "#{request.content} -> #{response.content}" - end - - connection.close -end - diff --git a/cpp/bindings/qpid/ruby/examples/drain.rb b/cpp/bindings/qpid/ruby/examples/drain.rb deleted file mode 100644 index a6cf35e189..0000000000 --- a/cpp/bindings/qpid/ruby/examples/drain.rb +++ /dev/null @@ -1,111 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# - -$:.unshift File.join(File.dirname(__FILE__), "..", "lib") - -require 'qpid' -require 'optparse' - -options = { - :broker => "localhost", - :timeout => Qpid::Messaging::Duration::IMMEDIATE, - :count => 1, - :forever => false, - :connection_options => "" -} - -opts = OptionParser.new do |opts| - opts.banner = "Usage: drain.rb [OPTIONS] ADDRESS" - - opts.separator "" - opts.separator "Drains messages from the specified address" - opts.separator "" - - opts.on("-h", "--help", - "show this message") do - puts opts - exit - end - - opts.on("-b", "--broker VALUE", - "url of broker to connect to") do |broker| - options[:broker] = broker - end - - opts.on("-t", "--timeout VALUE", Integer, - "timeout in seconds to wait before exiting") do |timeout| - options[:timeout] = Qpid::Messaging::Duration.new timeout * 1000 - end - - opts.on("-f", "--forever", - "ignore timeout and wait forever") do - options[:forever] = true - end - - opts.on("--connection-options VALUE", - "connection options string in the form {name1:value,name2:value2}") do |conopts| - options[:connection_options] = conopts - end - - opts.on("-c", "--count VALUE", Integer, - "number of messages to read before exiting") do |count| - options[:count] = count - end -end - -opts.parse!(ARGV) - -options[:address] = ARGV[0] || "" - -connection = Qpid::Messaging::Connection.new options[:broker], options[:connection_options] -connection.open - -def render_map map - print "{" - map.keys.sort.each_with_index {|key,index| print "#{index > 0 ? ', ' : ''}#{key}:#{map[key]}"} - print "}" -end - -begin - session = connection.create_session - receiver = session.create_receiver options[:address] - done = false - count = 0 - options[:timeout] = Qpid::Messaging::Duration::FOREVER if options[:forever] - - while !done && (count < options[:count]) - message = receiver.fetch(options[:timeout]) - print "Message(properties=" - render_map message.properties - print ", content=" - if message.content_type == "amqp/map" - print "'#{render_map message.content}')" - else - print "'#{message.content}'" - end - print ")\n" - session.acknowledge message - count += 1 - end -rescue Exception => error - puts "Exception: #{error.to_s}" -end - -connection.close - diff --git a/cpp/bindings/qpid/ruby/examples/hello_world.rb b/cpp/bindings/qpid/ruby/examples/hello_world.rb deleted file mode 100644 index 703febeba1..0000000000 --- a/cpp/bindings/qpid/ruby/examples/hello_world.rb +++ /dev/null @@ -1,49 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# - -$:.unshift File.join(File.dirname(__FILE__), "..", "lib") - -require 'qpid' - -# This is your classic Hello World application, written in -# Ruby, that uses Qpid. It demonstrates how to send and -# also receive messages. -# -if __FILE__ == $0 - broker = ARGV[0] || "localhost:5672" - address = ARGV[1] || "amq.topic" - options = ARGV[2] || "" - - connection = Qpid::Messaging::Connection.new broker - connection.open - session = connection.create_session - receiver = session.create_receiver address - sender = session.create_sender address - - # Send a simple message - sender.send Qpid::Messaging::Message.new :content => "Hello world!" - - # Now receive the message - message = receiver.fetch Qpid::Messaging::Duration::SECOND - puts "#{message.content}" - session.acknowledge - - connection.close -end - diff --git a/cpp/bindings/qpid/ruby/examples/map_receiver.rb b/cpp/bindings/qpid/ruby/examples/map_receiver.rb deleted file mode 100644 index 805943a0a4..0000000000 --- a/cpp/bindings/qpid/ruby/examples/map_receiver.rb +++ /dev/null @@ -1,63 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# - -$:.unshift File.join(File.dirname(__FILE__), "..", "lib") - -require 'qpid' - -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.open - -def display_value value - case value - when Array - result = "" - value.each_with_index {|element, index| result += "#{', ' if index > 0}#{element}"} - return "[#{result}]" - end - - value.to_s -end - -begin - session = connection.create_session - receiver = session.create_receiver address - - message = receiver.fetch - content = message.content - - print "content-type:#{message.content_type}" - print "{" - content.keys.sort.each_with_index do |key, index| - print "#{', ' if index > 0}#{key}:#{display_value content[key]}" - end - print "}\n" - - session.acknowledge - -rescue Exception => error - puts "Exception: #{error.message}" -end - -connection.close - diff --git a/cpp/bindings/qpid/ruby/examples/map_sender.rb b/cpp/bindings/qpid/ruby/examples/map_sender.rb deleted file mode 100644 index fa0c6e4562..0000000000 --- a/cpp/bindings/qpid/ruby/examples/map_sender.rb +++ /dev/null @@ -1,52 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# - -$:.unshift File.join(File.dirname(__FILE__), "..", "lib") - -require 'qpid' - -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.open - -begin - session = connection.create_session - sender = session.create_sender address - message = Qpid::Messaging::Message.new - - content = { - :id => 987654321, - :name => "Widget", - :percent => 0.99, - :colors => ["red", "green", "blue"] - } - - message.content = content - - sender.send message - -rescue Exception => error - puts "Exception: #{error.message}" -end - -connection.close - diff --git a/cpp/bindings/qpid/ruby/examples/server.rb b/cpp/bindings/qpid/ruby/examples/server.rb deleted file mode 100644 index ead9d58472..0000000000 --- a/cpp/bindings/qpid/ruby/examples/server.rb +++ /dev/null @@ -1,51 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# - -$:.unshift File.join(File.dirname(__FILE__), "..", "lib") - -require 'qpid' - -if __FILE__ == $0 - broker = ARGV[0] || "amqp:tcp:localhost:5672" - options = ARGV[1] || "" - - connection = Qpid::Messaging::Connection.new broker, options - connection.open - session = connection.create_session - receiver = session.create_receiver "service_queue; {create:always}" - - loop do - request = receiver.fetch - address = request.reply_to - - if !address.nil? - sender = session.create_sender address - response = Qpid::Messaging::Message.new :content => request.content.upcase - sender.send response - puts "Processed request: #{request.content} -> #{response.content}" - session.acknowledge - else - puts "Error: no reply address specified for request: #{request.content}" - session.reject request - end - end - - connection.close -end - diff --git a/cpp/bindings/qpid/ruby/examples/spout.rb b/cpp/bindings/qpid/ruby/examples/spout.rb deleted file mode 100644 index c012e31f9d..0000000000 --- a/cpp/bindings/qpid/ruby/examples/spout.rb +++ /dev/null @@ -1,126 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# - -$:.unshift File.join(File.dirname(__FILE__), "..", "lib") - -require 'qpid' -require 'optparse' - -options = { - :broker => "127.0.0.1", - :address => "", - :timeout => 0, - :count => 1, - :properties => {}, - :content => nil, - :mapped => {} -} - -opts = OptionParser.new do |opts| - opts.banner = "Usage: spout.rb [OPTIONS] ADDRESS" - - opts.on("-h", "--help", - "show this message") do |help| - puts opts - exit - end - - opts.on("-b","--broker VALUE", - "url of broker to connect to ") do |broker| - options[:broker] = broker - end - - opts.on("-t", "--timeout VALUE", Integer, - "exit after the specified time") do |timeout| - options[:timeout] = Qpid::Messaging::Duration.new timeout * 1000 - end - - opts.on("-c", "--count VALUE", Integer, - "stop after count messages have been sent, zero disables") do |count| - options[:count] = count - end - - opts.on("-i", "--id VALUE", - "use the supplied id instead of generating one") do |id| - options[:id] = id - end - - opts.on("--reply-to VALUE", - "specify reply-to address") do |replyto| - options[:replyto] = replyto - end - - opts.on("-P", "--property VALUE", - "specify message property") do |property| - name = property.split(/=/)[0] - value = property.split(/=/)[1] - options[:properties][name] = value - end - - opts.on("-M", "--map VALUE", - "specify entry for map content") do |mapped| - name = mapped.split(/=/)[0] - value = mapped.split(/=/)[1] - options[:mapped][name] = value - end - - opts.on("--content VALUE", - "specify textual content") do |content| - options[:content] = content - end - - opts.on(nil, "--connection-options VALUE", - "connection options string in the form {name1:value1, name2:value2}") do |conopts| - options[:connection_options] = conopts - end -end - -begin - opts.parse!(ARGV) -rescue => error - opts.parse(["-h"]) -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.open -session = connection.create_session -sender = session.create_sender options[:address] -message = Qpid::Messaging::Message.new - -options[:properties].each_key {|key| message.properties[key] = options[:properties][key]} - -(1..options[:count]).each do |count| - if !options[:mapped].keys.empty? - message.content = options[:mapped] - elsif options[:content] - message.content = options[:content] - end - message.content = options[:content] unless options[:content].nil? - message.properties["spout-id"] = "#{count}" - message.reply_to = options[:replyto] unless options[:replyto].nil? || options[:replyto].empty? - sender.send message -end - -# session.sync - -connection.close - |