diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2008-11-13 02:45:18 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2008-11-13 02:45:18 +0000 |
| commit | 92239a7a1362501ec492f176909eb3c092771cb9 (patch) | |
| tree | d5392e5a3355dfd6929216e99a6141fda7276506 /qpid/ruby/tests/basic.rb | |
| parent | 726494e8b3d6eb93a500d2e06a707fea5ce3dfd3 (diff) | |
| download | qpid-python-92239a7a1362501ec492f176909eb3c092771cb9.tar.gz | |
merged 0-10 ruby client from QPID-1443 into existing ruby client
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@713616 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/ruby/tests/basic.rb')
| -rw-r--r-- | qpid/ruby/tests/basic.rb | 69 |
1 files changed, 0 insertions, 69 deletions
diff --git a/qpid/ruby/tests/basic.rb b/qpid/ruby/tests/basic.rb deleted file mode 100644 index 0018050fe2..0000000000 --- a/qpid/ruby/tests/basic.rb +++ /dev/null @@ -1,69 +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. -# - -require "test/unit" -require "qpid/test" -require "qpid" - -class Basic < Test::Unit::TestCase - - include Qpid::Test - - def publish(body, headers = {}) - cli = connect() - ch = cli.channel(1) - ch.channel_open() - content = Qpid::Content.new(headers, body) - ch.basic_publish(:content => content) - msg = ch.channel_close() - assert msg.method.qname == :channel_close_ok - end - - def consume(body, headers = {}) - cli = connect() - ch = cli.channel(1) - ch.channel_open() - ch.queue_declare(:queue => "test-queue") - ch.queue_bind(:queue_name => "test-queue") - ch.basic_consume(:queue => "test-queue", :consumer_tag => "ctag") - content = Qpid::Content.new(headers, body) - ch.basic_publish(:routing_key => "test-queue", :content => content) - queue = cli.queue("ctag") - msg = queue.pop() - assert content.headers == msg.content.headers - assert content.body == msg.content.body - assert content.children == msg.content.children - ch.basic_ack(msg.delivery_tag) - msg = ch.channel_close() - assert msg.method.qname == :channel_close_ok - end - - def test_publish(); publish("hello world") end - - def test_publish_empty(); publish("") end - - def test_publish_headers(); publish("hello world", :content_type => "text/plain") end - - def test_consume(); consume("hello world") end - - def test_consume_empty(); consume("") end - - def test_consume_headers(); consume("hello_world", :content_type => "text/plain") end - -end |
