qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jr...@apache.org
Subject qpid-cpp git commit: QPID-8072: Remove the obsolete Ruby management API
Date Tue, 09 Jan 2018 23:27:17 GMT
Repository: qpid-cpp
Updated Branches:
  refs/heads/master c191859fc -> 02b828af6


QPID-8072: Remove the obsolete Ruby management API


Project: http://git-wip-us.apache.org/repos/asf/qpid-cpp/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-cpp/commit/02b828af
Tree: http://git-wip-us.apache.org/repos/asf/qpid-cpp/tree/02b828af
Diff: http://git-wip-us.apache.org/repos/asf/qpid-cpp/diff/02b828af

Branch: refs/heads/master
Commit: 02b828af66b7fae052e29c30ac20bfd930a0ccfc
Parents: c191859
Author: Justin Ross <jross@apache.org>
Authored: Tue Jan 9 15:26:50 2018 -0800
Committer: Justin Ross <jross@apache.org>
Committed: Tue Jan 9 15:26:50 2018 -0800

----------------------------------------------------------------------
 management/ruby/.gitignore                      |  23 --
 management/ruby/.rspec                          |   1 -
 management/ruby/Gemfile                         |  30 --
 management/ruby/Gemfile.lock                    |  55 ---
 management/ruby/Rakefile                        |  27 --
 management/ruby/lib/qpid_management.rb          |  81 ----
 management/ruby/lib/qpid_management/acl.rb      |  38 --
 management/ruby/lib/qpid_management/binding.rb  |  31 --
 management/ruby/lib/qpid_management/bridge.rb   |  39 --
 management/ruby/lib/qpid_management/broker.rb   | 278 --------------
 .../ruby/lib/qpid_management/broker_agent.rb    | 173 ---------
 .../ruby/lib/qpid_management/broker_object.rb   | 126 -------
 management/ruby/lib/qpid_management/cluster.rb  |  26 --
 .../ruby/lib/qpid_management/connection.rb      |  51 ---
 management/ruby/lib/qpid_management/errors.rb   |  28 --
 management/ruby/lib/qpid_management/exchange.rb |  44 ---
 .../ruby/lib/qpid_management/ha_broker.rb       |  26 --
 management/ruby/lib/qpid_management/link.rb     |  35 --
 management/ruby/lib/qpid_management/memory.rb   |  34 --
 management/ruby/lib/qpid_management/queue.rb    |  97 -----
 management/ruby/lib/qpid_management/session.rb  |  38 --
 .../ruby/lib/qpid_management/subscription.rb    |  35 --
 management/ruby/qpid_management.gemspec         |  36 --
 management/ruby/spec/broker_agent_spec.rb       |  43 ---
 management/ruby/spec/broker_spec.rb             | 373 -------------------
 management/ruby/spec/spec_helper.rb             |  21 --
 26 files changed, 1789 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/.gitignore
----------------------------------------------------------------------
diff --git a/management/ruby/.gitignore b/management/ruby/.gitignore
deleted file mode 100644
index c89dc10..0000000
--- a/management/ruby/.gitignore
+++ /dev/null
@@ -1,23 +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.
-#
-#
-*.gem
-.bundle
-pkg/*

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/.rspec
----------------------------------------------------------------------
diff --git a/management/ruby/.rspec b/management/ruby/.rspec
deleted file mode 100644
index 4e1e0d2..0000000
--- a/management/ruby/.rspec
+++ /dev/null
@@ -1 +0,0 @@
---color

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/Gemfile
----------------------------------------------------------------------
diff --git a/management/ruby/Gemfile b/management/ruby/Gemfile
deleted file mode 100644
index 1bd80c1..0000000
--- a/management/ruby/Gemfile
+++ /dev/null
@@ -1,30 +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.
-#
-
-source "http://rubygems.org"
-
-# Specify your gem's dependencies in qpid_config.gemspec
-gemspec
-
-# development deps
-gem 'rspec'
-gem 'pry'
-gem 'pry-stack_explorer'
-gem 'pry-debugger'
-gem 'yard'

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/Gemfile.lock
----------------------------------------------------------------------
diff --git a/management/ruby/Gemfile.lock b/management/ruby/Gemfile.lock
deleted file mode 100644
index bf35564..0000000
--- a/management/ruby/Gemfile.lock
+++ /dev/null
@@ -1,55 +0,0 @@
-PATH
-  remote: .
-  specs:
-    qpid_management (1.0)
-      qpid_messaging
-
-GEM
-  remote: http://rubygems.org/
-  specs:
-    binding_of_caller (0.7.1)
-      debug_inspector (>= 0.0.1)
-    coderay (1.0.9)
-    columnize (0.3.6)
-    debug_inspector (0.0.2)
-    debugger (1.4.0)
-      columnize (>= 0.3.1)
-      debugger-linecache (~> 1.1.1)
-      debugger-ruby_core_source (~> 1.2.0)
-    debugger-linecache (1.1.2)
-      debugger-ruby_core_source (>= 1.1.1)
-    debugger-ruby_core_source (1.2.0)
-    diff-lcs (1.2.1)
-    method_source (0.8.1)
-    pry (0.9.12)
-      coderay (~> 1.0.5)
-      method_source (~> 0.8)
-      slop (~> 3.4)
-    pry-debugger (0.2.2)
-      debugger (~> 1.3)
-      pry (~> 0.9.10)
-    pry-stack_explorer (0.4.9)
-      binding_of_caller (>= 0.7)
-      pry (~> 0.9.11)
-    qpid_messaging (0.20.2)
-    rspec (2.13.0)
-      rspec-core (~> 2.13.0)
-      rspec-expectations (~> 2.13.0)
-      rspec-mocks (~> 2.13.0)
-    rspec-core (2.13.0)
-    rspec-expectations (2.13.0)
-      diff-lcs (>= 1.1.3, < 2.0)
-    rspec-mocks (2.13.0)
-    slop (3.4.3)
-    yard (0.8.5.2)
-
-PLATFORMS
-  ruby
-
-DEPENDENCIES
-  pry
-  pry-debugger
-  pry-stack_explorer
-  qpid_management!
-  rspec
-  yard

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/Rakefile
----------------------------------------------------------------------
diff --git a/management/ruby/Rakefile b/management/ruby/Rakefile
deleted file mode 100644
index 7f295ed..0000000
--- a/management/ruby/Rakefile
+++ /dev/null
@@ -1,27 +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 "bundler/gem_tasks"
-require 'rspec/core/rake_task'
-
-require 'rake/clean'
-CLOBBER.include('pkg')
-
-RSpec::Core::RakeTask.new('spec')
-

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management.rb b/management/ruby/lib/qpid_management.rb
deleted file mode 100644
index 0529710..0000000
--- a/management/ruby/lib/qpid_management.rb
+++ /dev/null
@@ -1,81 +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 'qpid_management/broker_agent'
-require 'qpid_management/broker_object'
-require 'qpid_management/acl'
-require 'qpid_management/binding'
-require 'qpid_management/bridge'
-require 'qpid_management/broker'
-require 'qpid_management/cluster'
-require 'qpid_management/connection'
-require 'qpid_management/errors'
-require 'qpid_management/exchange'
-require 'qpid_management/ha_broker'
-require 'qpid_management/link'
-require 'qpid_management/memory'
-require 'qpid_management/queue'
-require 'qpid_management/session'
-require 'qpid_management/subscription'
-
-module Qpid
-  # The Qpid Management framework is a management framework for Qpid brokers
-  # that uses QMF2.
-  #
-  # ==== Example Usage
-  #
-  # Here is a simple example. It TODO.
-  #
-  #   require 'rubygems'
-  #   require 'qpid_messaging'
-  #   require 'qpid_management'
-  #
-  #   # create a connection and open it
-  #   conn = Qpid::Messaging::Connection.new(:url => "broker.myqpiddomain.com")
-  #   conn.open()
-  #
-  #   # create a broker agent
-  #   agent = Qpid::Management::BrokerAgent.new(conn)
-  #
-  #   # get a reference to the broker
-  #   broker = agent.broker
-  #
-  #   # print out all exchange names
-  #   puts broker.exchanges.map(&:name)
-  #
-  #   # print out info about a single exchange
-  #   amq_direct = broker.exchange('amq.direct')
-  #   puts amq_direct
-  #   puts amq_direct.msgDrops
-  #
-  #   # create an exchange
-  #   broker.add_exchange('topic', 'myexchange')
-  #
-  #   # print out all queue names
-  #   puts broker.queues.map(&:name)
-  #
-  #   # create a queue
-  #   broker.add_queue('myqueue')
-  #
-  #   # print out info about a single queue
-  #   myqueue = broker.queue('myqueue')
-  #   puts myqueue.msgDepth
-  module Management
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/acl.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/acl.rb b/management/ruby/lib/qpid_management/acl.rb
deleted file mode 100644
index 589b11f..0000000
--- a/management/ruby/lib/qpid_management/acl.rb
+++ /dev/null
@@ -1,38 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of the access control list (ACL) for the broker. Properties
-    # include:
-    # - aclDenyCount
-    # - brokerRef
-    # - connectionDenyCount
-    # - enforcingAcl
-    # - lastAclLoad
-    # - maxConnectionsPerIp
-    # - maxConnectionsPerUser
-    # - maxQueuesPerUser
-    # - policyFile
-    # - queueQuotaDenyCount
-    # - transferAcl
-    class Acl < BrokerObject
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/binding.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/binding.rb b/management/ruby/lib/qpid_management/binding.rb
deleted file mode 100644
index cc46d84..0000000
--- a/management/ruby/lib/qpid_management/binding.rb
+++ /dev/null
@@ -1,31 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of a binding in the broker. Properties include:
-    # - arguments
-    # - bindingKey
-    # - exchangeRef
-    # - msgMatched
-    # - queueRef
-    class Binding < BrokerObject
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/bridge.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/bridge.rb b/management/ruby/lib/qpid_management/bridge.rb
deleted file mode 100644
index cece0ba..0000000
--- a/management/ruby/lib/qpid_management/bridge.rb
+++ /dev/null
@@ -1,39 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of a bridge to another broker. Properties include:
-    # - channelId
-    # - dest
-    # - durable
-    # - dynamic
-    # - excludes
-    # - key
-    # - linkRef
-    # - name
-    # - src
-    # - srcIsLocal
-    # - srcIsQueue
-    # - sync
-    # - tag
-    class Bridge < BrokerObject
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/broker.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/broker.rb b/management/ruby/lib/qpid_management/broker.rb
deleted file mode 100644
index 31171bd..0000000
--- a/management/ruby/lib/qpid_management/broker.rb
+++ /dev/null
@@ -1,278 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of the broker. Properties include:
-    # - abandoned
-    # - abandonedViaAlt
-    # - acquires
-    # - byteDepth
-    # - byteFtdDepth
-    # - byteFtdDequeues
-    # - byteFtdEnqueues
-    # - bytePersistDequeues
-    # - bytePersistEnqueues
-    # - byteTotalDequeues
-    # - byteTotalEnqueues
-    # - byteTxnDequeues
-    # - byteTxnEnqueues
-    # - connBacklog
-    # - dataDir
-    # - discardsLvq
-    # - discardsNoRoute
-    # - discardsOverflow
-    # - discardsPurge
-    # - discardsRing
-    # - discardsSubscriber
-    # - discardsTtl
-    # - maxConns
-    # - mgmtPubInterval
-    # - mgmtPublish
-    # - msgDepth
-    # - msgFtdDepth
-    # - msgFtdDequeues
-    # - msgFtdEnqueues
-    # - msgPersistDequeues
-    # - msgPersistEnqueues
-    # - msgTotalDequeues
-    # - msgTotalEnqueues
-    # - msgTxnDequeues
-    # - msgTxnEnqueues
-    # - name
-    # - port
-    # - queueCount
-    # - releases
-    # - reroutes
-    # - stagingThreshold
-    # - systemRef
-    # - uptime
-    # - version
-    # - workerThreads
-    class Broker < BrokerObject
-      # Adds methods for the specified collections to be able to access all instances
-      # of a given collection, as well as a single instance by oid.
-      #
-      # == Example
-      # <tt>has_many :queues</tt> which will add:
-      # * <tt>#queues</tt> to retrieve all queues
-      # * <tt>#queue(oid)</tt> to retrieve a queue by oid (note, this is the short form of the object id, e.g. "myqueue" for a queue instead of "org.apache.qpid.broker:queue:myqueue"
-      #
-      # @param collections one or more symbols for the collections of objects a broker manages
-      def self.has_many(*collections)
-        [*collections].each do |collection|
-          singular_form = collection.to_s[0..-2]
-          capitalized_type = singular_form.gsub(/^\w/) { $&.upcase }
-
-          define_method(collection) do
-            @agent.find_all_by_class(Qpid::Management::const_get(capitalized_type))
-          end
-
-          define_method(singular_form) do |oid|
-            @agent.find_by_object_id(Qpid::Management::const_get(capitalized_type), "org.apache.qpid.broker:#{singular_form}:#{oid}")
-          end
-        end
-      end
-
-      # Adds method for the specified types to be able to access the singular
-      # instance of a given type.
-      #
-      # == Example
-      # <tt>has_one :acl</tt> which will add:
-      # * <tt>#acl</tt> to retrieve the Acl data for the Broker
-      #
-      # @param types one or more symbols for the singular objects a broker manages
-      def self.has_one(*types)
-        [*types].each do |type|
-          capitalized_type = type.to_s.gsub(/^\w/) { $&.upcase }
-
-          define_method("#{type}") do
-            @agent.find_first_by_class(Qpid::Management::const_get(capitalized_type))
-          end
-        end
-      end
-
-      has_many :connections, :sessions, :subscriptions, :exchanges, :queues, :bindings, :links, :bridges
-      has_one :acl, :memory
-
-      # Adds an exchange to the broker
-      # @param [String] type exchange type (fanout, direct, topic, headers, xml)
-      # @param [String] name exchange name
-      # @param [Hash] options exchange creation options
-      def add_exchange(type, name, options={})
-        create_broker_object('exchange', name, options.merge!({'exchange-type' => type}))
-      end
-
-      # Deletes an exchange from the broekr
-      # @param [String] name exchange name
-      def delete_exchange(name)
-        invoke_method('delete', {'type' => 'exchange', 'name' => name})
-      end
-
-      # Adds a queue to the broker
-      # @param [String] name queue name
-      # @param [Hash] options queue creation options
-      def add_queue(name, options={})
-        create_broker_object('queue', name, options)
-      end
-
-      # Deletes a queue from the broker
-      # @param [String] name queue name
-      def delete_queue(name)
-        invoke_method('delete', {'type' => 'queue', 'name' => name})
-      end
-
-      # Adds a binding from an exchange to a queue
-      # @param [String] exchange exchange name
-      # @param [String] queue queue name
-      # @param [String] key binding key
-      # @param [Hash] options binding creation options
-      def add_binding(exchange, queue, key="", options={})
-        create_broker_object('binding', "#{exchange}/#{queue}/#{key}", options)
-      end
-
-      # Deletes a binding from an exchange to a queue
-      # @param [String] exchange exchange name
-      # @param [String] queue queue name
-      # @param [String] key binding key
-      def delete_binding(exchange, queue, key="")
-        invoke_method('delete', {'type' => 'binding', 'name' => "#{exchange}/#{queue}/#{key}"})
-      end
-
-      # Adds a link to a remote broker
-      # @param [String] name link name
-      # @param [String] host remote broker host name or IP address
-      # @param [Fixnum] port remote broker port
-      # @param [String] transport transport mechanism used to connect to the remote broker
-      # @param [Boolean] durable should this link be persistent
-      # @param [String] auth_mechanism authentication mechanism to use
-      # @param [String] username user name to authenticate with the remote broker
-      # @param [String] password password for the user name
-      def add_link(name, host, port, transport='tcp', durable=false, auth_mechanism="", username="", password="")
-        options = {
-          'host' => host,
-          'port' => port,
-          'transport' => transport,
-          'durable' => durable,
-          'authMechanism' => auth_mechanism,
-          'username' => username,
-          'password' => password
-        }
-
-        create_broker_object('link', name, options)
-      end
-
-      # Deletes a link to a remote broker
-      # @param [String] name link name
-      def delete_link(name)
-        invoke_method('delete', {'type' => 'link', 'name' => name})
-      end
-
-      # Adds a queue route
-      # @param [String] name the name of the bridge to create
-      # @param [Hash] options options for the queue route
-      # @option options [String] :link the name of the link to use (required)
-      # @option options [String] :queue the name of the source queue from which messages are pulled (required)
-      # @option options [String] :exchange the name of the destination exchange to which messages are sent (required)
-      # @option options [Fixnum] :sync the number of messages to send before issuing an explicit session sync (required)
-      def add_queue_route(name, options={})
-        validate_options(options, [:link, :queue, :exchange, :sync])
-
-        properties = {
-          'link' => options[:link],
-          'src' => options[:queue],
-          'dest' => options[:exchange],
-          'srcIsQueue' => true,
-          'sync' => options[:sync]
-        }
-
-        create_broker_object('bridge', name, properties)
-      end
-
-      # Adds an exchange route
-      # @param [String] name the name of the bridge to create
-      # @param [Hash] options options for the exchange route
-      # @option options [String] :link the name of the link to use (required)
-      # @option options [String] :exchange the name of the exchange to use (required)
-      # @option options [String] :key routing key to federate (required)
-      # @option options [Fixnum] :sync the number of messages to send before issuing an explicit session sync (required)
-      # @option options [String] :bridge_queue name of the queue to use as a bridge queue (optional)
-      def add_exchange_route(name, options={})
-        validate_options(options, [:link, :exchange, :key, :sync])
-
-        properties = {
-          'link' => options[:link],
-          'src' => options[:exchange],
-          'dest' => options[:exchange],
-          'key' => options[:key],
-          'sync' => options[:sync]
-        }
-
-        properties['queue'] = options[:bridge_queue] if options.has_key?(:bridge_queue)
-
-        create_broker_object('bridge', name, properties)
-      end
-
-      # Adds a dynamic route
-      # @param [String] name the name of the bridge to create
-      # @param [Hash] options options for the dynamic route
-      # @option options [String] :link the name of the link to use (required)
-      # @option options [String] :exchange the name of the exchange to use (required)
-      # @option options [Fixnum] :sync the number of messages to send before issuing an explicit session sync (required)
-      # @option options [String] :bridge_queue name of the queue to use as a bridge queue (optional)
-      def add_dynamic_route(name, options={})
-        validate_options(options, [:link, :exchange, :sync])
-
-        properties = {
-          'link' => options[:link],
-          'src' => options[:exchange],
-          'dest' => options[:exchange],
-          'dynamic' => true,
-          'sync' => options[:sync]
-        }
-
-        properties['queue'] = options[:bridge_queue] if options.has_key?(:bridge_queue)
-
-        create_broker_object('bridge', name, properties)
-      end
-
-      # Deletes a bridge (route)
-      # @param [String] name bridge name
-      def delete_bridge(name)
-        invoke_method('delete', {'type' => 'bridge', 'name' => name})
-      end
-
-    private
-
-      def create_broker_object(type, name, options)
-        invoke_method('create', {'type' => type,
-                                 'name' => name,
-                                 'properties' => options,
-                                 'strict' => true})
-      end
-
-      def validate_options(options, required)
-        required.each do |req|
-          raise "Option :#{req.to_s} is required" unless options.has_key?(req)
-        end
-      end
-
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/broker_agent.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/broker_agent.rb b/management/ruby/lib/qpid_management/broker_agent.rb
deleted file mode 100644
index 800dcf2..0000000
--- a/management/ruby/lib/qpid_management/broker_agent.rb
+++ /dev/null
@@ -1,173 +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.
-#
-
-# for simplistic UUID - may want to consider something better in the future
-require 'securerandom'
-
-# Ruby 1.8 doesn't include SecureRandom#uuid, so let's add it if it's missing
-unless SecureRandom.respond_to? :uuid
-  module SecureRandom
-    def self.uuid
-      ary = self.random_bytes(16).unpack("NnnnnN")
-      ary[2] = (ary[2] & 0x0fff) | 0x4000
-      ary[3] = (ary[3] & 0x3fff) | 0x8000
-      "%08x-%04x-%04x-%04x-%04x%08x" % ary
-    end
-  end
-end
-
-module Qpid
-  module Management
-    # This is the primary class that interacts with a Qpid messaging broker for
-    # querying information from the broker and for configuring it.
-    class BrokerAgent
-      # Creates a new BrokerAgent instance. A new Qpid::Messaging::Session,
-      # Qpid::Messaging::Receiver, and Qpid::Messaging::Sender will be created
-      # so this instance of the BrokerAgent may send requests to the broker
-      # and receive replies back.
-      # @param [Qpid::Messaging::Connection] connection a valid, opened connection
-      def initialize(connection)
-        @connection = connection
-        @session = @connection.create_session()
-        @reply_to = "qmf.default.topic/direct.#{SecureRandom.uuid}; {node: {type:topic}, link:{x-declare:{auto-delete:True,exclusive:True}}}"
-        @reply_rx = @session.create_receiver(@reply_to)
-        @reply_rx.capacity = 10
-        @tx = @session.create_sender("qmf.default.direct/broker")
-      end
-
-      # Closes the Qpid::Messaging::Session for this BrokerAgent.
-      def close()
-        @session.close()
-      end
-
-      # Queries the broker for the Broker QMF object.
-      # @return [Broker] the broker QMF object
-      def broker()
-        find_first_by_class(Broker)
-      end
-
-      # Queries the broker for the Cluster QMF object.
-      # @return [Cluster] the cluster QMF object
-      def cluster
-        find_first_by_class(Cluster)
-      end
-
-      # Queries the broker for the HaBroker QMF object.
-      # @return [HaBroker] the HA broker QMF object
-      def ha_broker
-        find_first_by_class(HaBroker)
-      end
-
-      # Invokes a method on a target object.
-      # @param [String] method the name of the method to invoke
-      # @param [Hash] args the arguments to pass to the method
-      # @param [String] addr the full id of the target object
-      # @param [Fixnum] timeout the amount of time to wait for the broker to respond to the method invocation
-      def invoke_method(method, args, addr="org.apache.qpid.broker:broker:amqp-broker", timeout=10)
-        content = {'_object_id' => {'_object_name' => addr},
-                   '_method_name' => method,
-                   '_arguments' => args}
-
-        message = Qpid::Messaging::Message.new()
-        message.content = content
-        message.reply_to = @reply_to
-        message['method'] = 'request'
-        message['qmf.opcode'] = '_method_request'
-        message['x-amqp-0-10.app-id'] = 'qmf2'
-        message.subject = 'broker'
-
-        @tx.send(message)
-
-        response = @reply_rx.fetch(Qpid::Messaging::Duration.new(timeout * 1000))
-        @session.acknowledge()
-
-        raise "Exception from Agent: #{response.content['_values']}" if response.properties['qmf.opcode'] == '_exception'
-        raise "Bad response: #{response.properties}" if response.properties['qmf.opcode'] != '_method_response'
-
-        return response.content['_arguments']
-      end
-
-      def send_query(query)
-        message = Qpid::Messaging::Message.new()
-        message.content = query
-        message.reply_to = @reply_to
-        message['method'] = 'request'
-        message['qmf.opcode'] = '_query_request'
-        message['x-amqp-0-10.app-id'] = 'qmf2'
-        message.subject = 'broker'
-
-        @tx.send(message)
-
-        response = @reply_rx.fetch(Qpid::Messaging::Duration.new(10*1000))
-        @session.acknowledge()
-
-        raise 'Bad response' if response.properties['qmf.opcode'] != '_query_response'
-
-        items = response.content
-
-        while response.properties.has_key?('partial')
-          response = @reply_rx.fetch(Qpid::Messaging::Duration.new(10*1000))
-          items += response.content
-          @session.acknowledge()
-        end
-
-        return items
-      end
-
-      def find_all_by_class(clazz)
-        query = {
-          '_what' => 'OBJECT',
-          '_schema_id' => {
-            '_class_name' => BrokerObject.qmf_class(clazz)
-          }
-        }
-
-        items = send_query(query)
-
-        [].tap do |objs|
-          for item in items
-            objs << clazz.new(self, item)
-          end
-        end
-      end
-
-      def find_first_by_class(clazz)
-        objects = find_all_by_class(clazz)
-        return objects[0] if objects.size > 0
-        return nil
-      end
-
-      def find_by_object_id(clazz, oid)
-        query = {
-          '_what' => 'OBJECT',
-          '_object_id' => {
-            '_object_name' => oid
-          }
-        }
-
-        results = send_query(query)
-
-        return clazz.new(self, results[0]) if results.count == 1 and not results[0].nil?
-
-        # return nil if not found
-        return nil
-      end
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/broker_object.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/broker_object.rb b/management/ruby/lib/qpid_management/broker_object.rb
deleted file mode 100644
index fbbe5ff..0000000
--- a/management/ruby/lib/qpid_management/broker_object.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.
-#
-
-module Qpid
-  module Management
-    # Representation of an object in the broker retrieved via QMF
-    class BrokerObject
-      attr_reader :content
-
-      # Creates a new BrokerObject
-      # @param [BrokerAgent] agent the agent used to query the data from the broker
-      # @param [Hash] content the raw QMF response data from the broker
-      def initialize(agent, content)
-        @agent = agent
-        @content = content
-        @values = content['_values']
-      end
-
-      # Refreshes the information associated with this instance by requerying the broker
-      # @raise [ObjectDeletedError] if the object has been deleted
-      def refresh!
-        refreshed = @agent.named_object(self.class, id)
-        if refreshed
-          @content = refreshed.content
-          @values = @content['_values']
-        else
-          raise ObjectDeletedError
-        end
-      end
-
-      # Returns the full object id
-      # @return [String] the full object id
-      def id
-        @content['_object_id']['_object_name']
-      end
-
-      # Helper method to convert a Class to its QMF name counterpart. For
-      # example, QpidConfig::Connection will be converted to connection.
-      # @param [Class] clazz the Class to convert
-      # @return [String] the converted QMF name counterpart for this Class
-      def self.qmf_class(clazz)
-        clazz.name.split(/::/).last.downcase
-      end
-
-      # Returns the short object id, i.e. without the leading org.apache.qpid.broker:<class name>:
-      # @return [String] the short object id
-      def short_id
-        clazz = BrokerObject.qmf_class(self.class)
-        if id =~ /org.apache.qpid.broker:#{clazz}:(.*)/
-          return $1;
-        end
-        return nil
-      end
-
-      # Returns the time at which this object was created
-      # @return [Time] the time at which this object was created
-      def created_at
-        Time.at(content['_create_ts'] / 1000000000.0)
-      end
-
-      # Returns the time at which this object was deleted. Only ever applies to
-      # BrokerObject instances created from a QMF event.
-      # @return [Time] the time at which this object was deleted
-      def deleted_at
-        Time.at(content['_delete_ts'] / 1000000000.0)
-      end
-
-      # Returns the time at which this object was last updated
-      # @return [Time] the time at which this object was last updated
-      def updated_at
-        Time.at(content['_update_ts'] / 1000000000.0)
-      end
-      
-      # Exposes data from the QMF response
-      # @param [String] key the key to look up a value, e.g. msgDepth for a queue
-      # @return the value associated with the key, or nil if not found
-      def [](key)
-        return nil unless @values.has_key?(key)
-        value = @values[key]
-        if value.is_a?(Hash) and value.has_key?('_object_name')
-          full_name = value['_object_name']
-          colon = full_name.index(':')
-          unless colon.nil?
-            full_name = full_name[colon+1..-1]
-            colon = full_name.index(':')
-            return full_name[colon+1..-1] unless colon.nil?
-          end
-        end
-
-        return value
-      end
-
-      # Exposes data from the QMF response via methods, e.g. queue.msgDepth
-      def method_missing(method, *args, &block)
-        key = method.to_s
-        return self[key] if args.empty? and not self[key].nil?
-        super
-      end
-
-      def to_s
-        @values.to_s
-      end
-
-      # Invokes a QMF method
-      # @see BrokerAgent#invoke_method
-      def invoke_method(*args)
-        @agent.invoke_method(*args)
-      end
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/cluster.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/cluster.rb b/management/ruby/lib/qpid_management/cluster.rb
deleted file mode 100644
index 4fa7f14..0000000
--- a/management/ruby/lib/qpid_management/cluster.rb
+++ /dev/null
@@ -1,26 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of a cluster
-    class Cluster < BrokerObject
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/connection.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/connection.rb b/management/ruby/lib/qpid_management/connection.rb
deleted file mode 100644
index 153ccee..0000000
--- a/management/ruby/lib/qpid_management/connection.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.
-#
-
-module Qpid
-  module Management
-    # Representation of a client connection. Properties include:
-    # - SystemConnection
-    # - address
-    # - authIdentity
-    # - bytesFromClient
-    # - bytesToClient
-    # - closing
-    # - federationLink
-    # - framesFromClient
-    # - framesToClient
-    # - incoming
-    # - msgsFromClient
-    # - msgsToClient
-    # - remoteParentPid
-    # - remotePid
-    # - remoteProcessName
-    # - remoteProperties
-    # - saslMechanism
-    # - saslSsf
-    # - shadow
-    # - userProxyAuth
-    # - vhostRef
-    class Connection < BrokerObject
-      # Closes this connection to the broker
-      def close
-        invoke_method('close', {}, "org.apache.qpid.broker:connection:#{address}")
-      end
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/errors.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/errors.rb b/management/ruby/lib/qpid_management/errors.rb
deleted file mode 100644
index b922cda..0000000
--- a/management/ruby/lib/qpid_management/errors.rb
+++ /dev/null
@@ -1,28 +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.
-#
-
-module Qpid
-  module Management
-    class ObjectNotFoundError < RuntimeError
-    end
-
-    class ObjectDeletedError < RuntimeError
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/exchange.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/exchange.rb b/management/ruby/lib/qpid_management/exchange.rb
deleted file mode 100644
index 5a3223a..0000000
--- a/management/ruby/lib/qpid_management/exchange.rb
+++ /dev/null
@@ -1,44 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of an exchange. Properties include:
-    # - arguments
-    # - autoDelete
-    # - bindingCount
-    # - bindingCountHigh
-    # - bindingCountLow
-    # - byteDrops
-    # - byteReceives
-    # - byteRoutes
-    # - durable
-    # - msgDrops
-    # - msgReceives
-    # - msgRoutes
-    # - name
-    # - producerCount
-    # - producerCountHigh
-    # - producerCountLow
-    # - type
-    # - vhostRef
-    class Exchange < BrokerObject
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/ha_broker.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/ha_broker.rb b/management/ruby/lib/qpid_management/ha_broker.rb
deleted file mode 100644
index 1ac9ea7..0000000
--- a/management/ruby/lib/qpid_management/ha_broker.rb
+++ /dev/null
@@ -1,26 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of an HA broker
-    class HaBroker < BrokerObject
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/link.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/link.rb b/management/ruby/lib/qpid_management/link.rb
deleted file mode 100644
index 455b26a..0000000
--- a/management/ruby/lib/qpid_management/link.rb
+++ /dev/null
@@ -1,35 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of a link to a remote broker. Properties include:
-    # - connectionRef
-    # - durable
-    # - host
-    # - lastError
-    # - name
-    # - port
-    # - state
-    # - transport
-    # - vhostRef
-    class Link < BrokerObject
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/memory.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/memory.rb b/management/ruby/lib/qpid_management/memory.rb
deleted file mode 100644
index 39dd803..0000000
--- a/management/ruby/lib/qpid_management/memory.rb
+++ /dev/null
@@ -1,34 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of the broker's memory. Properties include:
-    # - malloc_arena
-    # - malloc_fordblks
-    # - malloc_hblkhd
-    # - malloc_hblks
-    # - malloc_keepcost
-    # - malloc_ordblks
-    # - malloc_uordblks
-    # - name
-    class Memory < BrokerObject
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/queue.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/queue.rb b/management/ruby/lib/qpid_management/queue.rb
deleted file mode 100644
index c4fae3a..0000000
--- a/management/ruby/lib/qpid_management/queue.rb
+++ /dev/null
@@ -1,97 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of a queue. Properties include:
-    # - acquires
-    # - arguments
-    # - autoDelete
-    # - bindingCount
-    # - bindingCountHigh
-    # - bindingCountLow
-    # - byteDepth
-    # - byteFtdDepth
-    # - byteFtdDequeues
-    # - byteFtdEnqueues
-    # - bytePersistDequeues
-    # - bytePersistEnqueues
-    # - byteTotalDequeues
-    # - byteTotalEnqueues
-    # - byteTxnDequeues
-    # - byteTxnEnqueues
-    # - consumerCount
-    # - consumerCountHigh
-    # - consumerCountLow
-    # - discardsLvq
-    # - discardsOverflow
-    # - discardsPurge
-    # - discardsRing
-    # - discardsSubscriber
-    # - discardsTtl
-    # - durable
-    # - exclusive
-    # - flowStopped
-    # - flowStoppedCount
-    # - messageLatencyAvg
-    # - messageLatencyCount
-    # - messageLatencyMax
-    # - messageLatencyMin
-    # - msgDepth
-    # - msgFtdDepth
-    # - msgFtdDequeues
-    # - msgFtdEnqueues
-    # - msgPersistDequeues
-    # - msgPersistEnqueues
-    # - msgTotalDequeues
-    # - msgTotalEnqueues
-    # - msgTxnDequeues
-    # - msgTxnEnqueues
-    # - name
-    # - releases
-    # - reroutes
-    # - unackedMessages
-    # - unackedMessagesHigh
-    # - unackedMessagesLow
-    # - vhostRef
-    class Queue < BrokerObject
-      # Purges (removes) messages from this queue
-      # @param [Fixnum] message_count number of messages to remove from the queue, or 0 for all messages
-      # @param [Hash] filter an optional filter to use when removing messages
-      def purge(message_count, filter={})
-        invoke_method('purge', {'request' => message_count, 'filter' => filter}, "org.apache.qpid.broker:queue:#{name}")
-      end
-
-      # Reroutes messages from this queue to an exchange, either the queue's
-      # alternate exchange, or the specified exchange
-      # @param [Fixnum] message_count number of messages to reroute from the queue, or 0 for all messages
-      # @param [Boolean] use_alternate_exchange whether to use the queue's alternate exchange as the destination
-      # @param [String] exchange name of destination exchange
-      # @param [Hash] filter an optional filter to use when rerouting messages
-      def reroute(message_count, use_alternate_exchange, exchange, filter)
-        args = {'request' => message_count,
-                'useAltExchange' => use_alternate_exchange,
-                'exchange' => exchange,
-                'filter' => filter}
-
-        invoke_method('reroute', args, "org.apache.qpid.broker:queue:#{name}")
-      end
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/session.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/session.rb b/management/ruby/lib/qpid_management/session.rb
deleted file mode 100644
index b4fcc7d..0000000
--- a/management/ruby/lib/qpid_management/session.rb
+++ /dev/null
@@ -1,38 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of a session to the broker. Properties include:
-    # - TxnCommits
-    # - TxnCount
-    # - TxnRejects
-    # - TxnStarts
-    # - attached
-    # - channelId
-    # - clientCredit
-    # - connectionRef
-    # - detachedLifespan
-    # - name
-    # - unackedMessages
-    # - vhostRef
-    class Session < BrokerObject
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/lib/qpid_management/subscription.rb
----------------------------------------------------------------------
diff --git a/management/ruby/lib/qpid_management/subscription.rb b/management/ruby/lib/qpid_management/subscription.rb
deleted file mode 100644
index fcff283..0000000
--- a/management/ruby/lib/qpid_management/subscription.rb
+++ /dev/null
@@ -1,35 +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.
-#
-
-module Qpid
-  module Management
-    # Representation of a subscription. Properties include:
-    # - acknowledged
-    # - arguments
-    # - browsing
-    # - creditMode
-    # - delivered
-    # - exclusive
-    # - name
-    # - queueRef
-    # - sessionRef
-    class Subscription < BrokerObject
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/qpid_management.gemspec
----------------------------------------------------------------------
diff --git a/management/ruby/qpid_management.gemspec b/management/ruby/qpid_management.gemspec
deleted file mode 100644
index a6cc1b8..0000000
--- a/management/ruby/qpid_management.gemspec
+++ /dev/null
@@ -1,36 +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.
-#
-
-# -*- encoding: utf-8 -*-
-$:.push File.expand_path("../lib", __FILE__)
-
-Gem::Specification.new do |s|
-  s.name        = "qpid_management"
-  s.version     = "1.0"
-  s.authors     = ["Apache Qpid Project"]
-  s.email       = ["dev@qpid.apache.org"]
-  s.homepage    = "http://qpid.apache.org"
-  s.summary     = %q{Qpid management library}
-  s.description = %q{Qpid management library}
-  s.files         = `git ls-files`.split("\n")
-  s.test_files    = `git ls-files -- {test,spec,features}/*`.split("\n")
-  s.executables   = `git ls-files -- bin/*`.split("\n").map{ |f| File.basename(f) }
-  s.require_paths = ["lib"]
-  s.add_runtime_dependency 'qpid_messaging'
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/spec/broker_agent_spec.rb
----------------------------------------------------------------------
diff --git a/management/ruby/spec/broker_agent_spec.rb b/management/ruby/spec/broker_agent_spec.rb
deleted file mode 100644
index 7ffbf84..0000000
--- a/management/ruby/spec/broker_agent_spec.rb
+++ /dev/null
@@ -1,43 +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 'spec_helper'
-
-describe Qpid::Management::BrokerAgent do
-  before(:each) do
-    @broker_port = `qpidd --no-data-dir --auth=no --no-module-dir --daemon --port 0`.chop
-    @connection = Qpid::Messaging::Connection.new(url:"localhost:#{@broker_port}")
-    @connection.open()
-    @agent = Qpid::Management::BrokerAgent.new(@connection)
-  end
-
-  after(:each) do
-    @agent.close()
-    @connection.close()
-    `qpidd -q --port #{@broker_port}`
-  end
-
-  describe '#broker' do
-    let(:broker) { @agent.broker }
-
-    it 'returns the broker' do
-      broker.class.should == Qpid::Management::Broker
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/spec/broker_spec.rb
----------------------------------------------------------------------
diff --git a/management/ruby/spec/broker_spec.rb b/management/ruby/spec/broker_spec.rb
deleted file mode 100644
index 6d6e110..0000000
--- a/management/ruby/spec/broker_spec.rb
+++ /dev/null
@@ -1,373 +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 'spec_helper'
-
-describe Qpid::Management::Broker do
-  before(:each) do
-    @broker_port = `qpidd --no-data-dir --auth=no --no-module-dir --daemon --port 0`.chop
-    @connection = Qpid::Messaging::Connection.new(url:"localhost:#{@broker_port}")
-    @connection.open()
-    @agent = Qpid::Management::BrokerAgent.new(@connection)
-    @broker = @agent.broker
-  end
-
-  after(:each) do
-    @agent.close()
-    @connection.close()
-    `qpidd --quit --port #{@broker_port}`
-  end
-
-  def setup_queue_route
-    @other_port = `qpidd --no-data-dir --auth=no --no-module-dir --daemon --port 0`.chop
-    @broker.add_link('link1', 'localhost', @other_port)
-    @broker.add_queue('queue')
-    @broker.add_queue_route('qr1',
-                            link: 'link1',
-                            queue: 'queue',
-                            exchange: 'amq.direct',
-                            sync: 2)
-  end
-
-  %w(connection session subscription exchange queue binding link bridge).each do |type|
-    describe "##{type}s" do
-      before(:each) do
-        setup_queue_route if %w(link bridge).include?(type)
-      end
-
-      after(:each) do
-        if %w(link bridge).include?(type)
-          `qpidd --quit --port #{@other_port}`
-        end
-      end
-
-      let(:collection) { @broker.send("#{type}s") }
-
-      it "returns at least 1 #{type}" do
-        if type == 'subscription'
-          session = @connection.create_session
-          receiver = session.create_receiver("amq.direct/temp")
-        end
-        collection.count.should be > 0
-      end
-    end
-
-    describe "##{type}" do
-      before(:each) do
-        setup_queue_route if %w(link bridge).include?(type)
-      end
-
-      after(:each) do
-        if %w(link bridge).include?(type)
-          `qpidd --quit --port #{@other_port}`
-        end
-      end
-
-      let(:object) { @broker.send("#{type}s")[0] }
-
-      it "returns a #{type} by oid" do
-        if type == 'subscription'
-          session = @connection.create_session
-          receiver = session.create_receiver("amq.direct/temp")
-        end
-        @broker.send(type, object.short_id).id.should == object.id
-      end
-    end
-  end
-
-  describe '#add_exchange' do
-    %w(fanout direct topic headers).each do |type|
-      context "when adding a #{type} exchange" do
-        let(:exchange_name) { "#{type}1" }
-        before(:each) do
-          @before_creation = Time.now
-          @broker.add_exchange(type, exchange_name, {'qpid.replicate' => 'none'})
-        end
-
-        subject { @broker.exchange(exchange_name) }
-        its(:short_id) { should == exchange_name }
-        its(:type) { should == type }
-        its(:created_at) { should be > @before_creation }
-        it 'has the correct arguments' do
-          subject.arguments.should == {'qpid.replicate' => 'none'}
-        end
-      end
-    end
-  end
-
-  describe "#delete_exchange" do
-    before(:each) do
-      @before_creation = Time.now
-      @broker.add_exchange('fanout', 'fanout_to_delete')
-    end
-
-    let(:exchange) { @broker.exchange('fanout_to_delete') }
-
-    context "with a valid exchange name" do
-      it "deletes the exchange" do
-        @broker.delete_exchange(exchange.short_id)
-        expect { exchange.refresh! }.to raise_error
-      end
-    end
-
-    context "with an invalid exchange name" do
-      it "raises a not-found exception" do
-        expect { @broker.delete_exchange("badname") }.to raise_error(/not-found.*badname/)
-      end
-    end
-  end
-
-  describe "#add_queue" do
-    before(:each) do
-      @before_creation = Time.now
-      @queue_name = 'myqueue'
-      @broker.add_queue(@queue_name, {'qpid.replicate' => 'none'})
-    end
-
-    subject { @broker.queue(@queue_name) }
-    its(:short_id) { should == @queue_name }
-    its(:created_at) { should be > @before_creation }
-    it 'has the correct arguments' do
-      subject.arguments.should == {'qpid.replicate' => 'none'}
-    end
-  end
-
-  describe "#delete_queue" do
-    before(:each) do
-      @before_creation = Time.now
-      @broker.add_queue('queue_to_delete')
-    end
-
-    let(:queue) { @broker.queue('queue_to_delete') }
-
-    context "with a valid queue name" do
-      it "deletes the queue" do
-        @broker.delete_queue(queue.short_id)
-        expect { queue.refresh! }.to raise_error
-      end
-    end
-
-    context "with an invalid name" do
-      it "raises a not-found exception" do
-        expect { @broker.delete_queue("badname") }.to raise_error(/not-found.*badname/)
-      end
-    end
-  end
-
-  describe "#add_binding" do
-    before(:each) do
-      @broker.add_queue('queue')
-    end
-
-    it "creates a binding for a fanout exchange" do
-      @broker.add_exchange('fanout', 'fanout')
-      @broker.add_binding('fanout', 'queue')
-      expect { @broker.binding('org.apache.qpid.broker:exchange:fanout,org.apache.qpid.broker:queue:queue,') }.to_not raise_error
-    end
-
-    it "creates a binding for a direct exchange" do
-      @broker.add_exchange('direct', 'direct')
-      @broker.add_binding('direct', 'queue', 'mykey')
-      expect { @broker.binding('org.apache.qpid.broker:exchange:direct,org.apache.qpid.broker:queue:queue,mykey') }.to_not raise_error
-    end
-
-    it "creates a binding for a topic exchange" do
-      @broker.add_exchange('topic', 'topic')
-      @broker.add_binding('topic', 'queue', 'us.#')
-      expect { @broker.binding('org.apache.qpid.broker:exchange:topic,org.apache.qpid.broker:queue:queue,us.#') }.to_not raise_error
-    end
-  end
-
-  describe "#delete_binding" do
-    it "deletes an existing binding" do
-      @broker.add_queue('queue')
-      @broker.add_exchange('fanout', 'fanout')
-      @broker.add_binding('fanout', 'queue')
-      expect { @broker.delete_binding('fanout', 'queue') }.to_not raise_error
-    end
-  end
-
-  describe "#add_link" do
-    before(:each) do
-      @other_port = `/usr/sbin/qpidd --no-data-dir --auth=no --no-module-dir --daemon --port 0`.chop
-    end
-
-    after(:each) do
-      `/usr/sbin/qpidd -q --port #{@other_port}`
-    end
-
-    it "adds a link" do
-      @broker.add_link('link1', 'localhost', @other_port)
-      @broker.links.count.should == 1
-    end
-  end
-
-  describe "#delete_link" do
-    before(:each) do
-      @other_port = `/usr/sbin/qpidd --no-data-dir --auth=no --no-module-dir --daemon --port 0`.chop
-      @broker.add_link('link1', 'localhost', @other_port)
-    end
-
-    after(:each) do
-      `/usr/sbin/qpidd -q --port #{@other_port}`
-    end
-
-    it "deletes a link" do
-      @broker.delete_link('link1')
-      @broker.links.count.should == 0
-    end
-  end
-
-  describe "#add_queue_route" do
-    context "with missing options" do
-      [:link, :queue, :exchange, :sync].each do |opt|
-        opts = {link: 'l', queue: 'q', exchange: 'e', sync:2}
-        opts.delete(opt)
-        it "raises an error when :#{opt} is missing" do
-          expect { @broker.add_queue_route('name', opts) }.to raise_error(/Option :#{opt} is required/)
-        end
-      end
-    end
-
-    context "with all required options" do
-      before(:each) do
-        @other_port = `/usr/sbin/qpidd --no-data-dir --auth=no --no-module-dir --daemon --port 0`.chop
-        @broker.add_link('link1', 'localhost', @other_port)
-        @broker.add_queue('queue')
-        @broker.add_queue_route('qr1',
-                                link: 'link1',
-                                queue: 'queue',
-                                exchange: 'amq.direct',
-                                sync: 2)
-      end
-
-      after(:each) do
-        `/usr/sbin/qpidd -q --port #{@other_port}`
-      end
-
-      it "adds a queue route" do
-        @broker.bridges.count.should == 1
-      end
-
-      subject { @broker.bridges[0] }
-      its(:dest) { should == 'amq.direct' }
-      its(:durable) { should == false }
-      its(:dynamic) { should == false }
-      its(:excludes) { should == "" }
-      its(:key) { should == "" }
-      its(:name) { should == "qr1" }
-      its(:src) { should == "queue" }
-      its(:srcIsLocal) { should == false }
-      its(:srcIsQueue) { should == true }
-      its(:sync) { should == 2 }
-      its(:tag) { should == "" }
-    end
-  end
-
-  describe "#add_exchange_route" do
-    context "with missing options" do
-      [:link, :exchange, :key, :sync].each do |opt|
-        opts = {link: 'l', exchange: 'e', key:'rk', sync:2}
-        opts.delete(opt)
-        it "raises an error when :#{opt} is missing" do
-          expect { @broker.add_exchange_route('name', opts) }.to raise_error(/Option :#{opt} is required/)
-        end
-      end
-    end
-
-    context "with all required options" do
-      before(:each) do
-        @other_port = `/usr/sbin/qpidd --no-data-dir --auth=no --no-module-dir --daemon --port 0`.chop
-        @broker.add_link('link1', 'localhost', @other_port)
-        @broker.add_queue('queue')
-        @broker.add_exchange_route('er1',
-                                link: 'link1',
-                                exchange: 'amq.direct',
-                                key: 'foo',
-                                sync: 2)
-      end
-
-      after(:each) do
-        `/usr/sbin/qpidd -q --port #{@other_port}`
-      end
-
-      it "adds an exchange route" do
-        @broker.bridges.count.should == 1
-      end
-
-      subject { @broker.bridges[0] }
-      its(:dest) { should == 'amq.direct' }
-      its(:durable) { should == false }
-      its(:dynamic) { should == false }
-      its(:excludes) { should == "" }
-      its(:key) { should == "foo" }
-      its(:name) { should == "er1" }
-      its(:src) { should == "amq.direct" }
-      its(:srcIsLocal) { should == false }
-      its(:srcIsQueue) { should == false }
-      its(:sync) { should == 2 }
-      its(:tag) { should == "" }
-    end
-  end
-
-  describe "#add_dynamic_route" do
-    context "with missing options" do
-      [:link, :exchange, :sync].each do |opt|
-        opts = {link: 'l', exchange: 'e', sync:2}
-        opts.delete(opt)
-        it "raises an error when :#{opt} is missing" do
-          expect { @broker.add_dynamic_route('name', opts) }.to raise_error(/Option :#{opt} is required/)
-        end
-      end
-    end
-
-    context "with all required options" do
-      before(:each) do
-        @other_port = `/usr/sbin/qpidd --no-data-dir --auth=no --no-module-dir --daemon --port 0`.chop
-        @broker.add_link('link1', 'localhost', @other_port)
-        @broker.add_queue('queue')
-        @broker.add_dynamic_route('dr1',
-                                link: 'link1',
-                                exchange: 'amq.direct',
-                                sync: 2)
-      end
-
-      after(:each) do
-        `/usr/sbin/qpidd -q --port #{@other_port}`
-      end
-
-      it "adds an exchange route" do
-        @broker.bridges.count.should == 1
-      end
-
-      subject { @broker.bridges[0] }
-      its(:dest) { should == 'amq.direct' }
-      its(:durable) { should == false }
-      its(:dynamic) { should == true }
-      its(:excludes) { should == "" }
-      its(:key) { should == "" }
-      its(:name) { should == "dr1" }
-      its(:src) { should == "amq.direct" }
-      its(:srcIsLocal) { should == false }
-      its(:srcIsQueue) { should == false }
-      its(:sync) { should == 2 }
-      its(:tag) { should == "" }
-    end
-  end
-end

http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/02b828af/management/ruby/spec/spec_helper.rb
----------------------------------------------------------------------
diff --git a/management/ruby/spec/spec_helper.rb b/management/ruby/spec/spec_helper.rb
deleted file mode 100644
index f552c55..0000000
--- a/management/ruby/spec/spec_helper.rb
+++ /dev/null
@@ -1,21 +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 'qpid_messaging'
-require 'qpid_management'


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message