You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by jr...@apache.org on 2018/01/09 23:27:17 UTC
qpid-cpp git commit: QPID-8072: Remove the obsolete Ruby management
API
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 <jr...@apache.org>
Authored: Tue Jan 9 15:26:50 2018 -0800
Committer: Justin Ross <jr...@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