diff options
author | Gordon Sim <gsim@apache.org> | 2011-02-15 14:18:19 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2011-02-15 14:18:19 +0000 |
commit | d97ee33e56a3235254b9831ef64fb9c7c4632eec (patch) | |
tree | 15a33817a3902e2711c67d2c5dddbc483c45d91a | |
parent | c195945c0845e0040c58ca75fd006848a993dd09 (diff) | |
download | qpid-python-d97ee33e56a3235254b9831ef64fb9c7c4632eec.tar.gz |
QPID-3002: Configurable threshold alerts for queues; added spec change and tests missing from last commit
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1070914 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | qpid/specs/management-schema.xml | 3 | ||||
-rw-r--r-- | qpid/tests/src/py/qpid_tests/broker_0_10/__init__.py | 1 | ||||
-rw-r--r-- | qpid/tests/src/py/qpid_tests/broker_0_10/threshold.py | 124 |
3 files changed, 128 insertions, 0 deletions
diff --git a/qpid/specs/management-schema.xml b/qpid/specs/management-schema.xml index b59f4c79d1..65d8d4f11d 100644 --- a/qpid/specs/management-schema.xml +++ b/qpid/specs/management-schema.xml @@ -380,6 +380,8 @@ <arg name="reason" type="lstr" desc="Reason for a failure"/> <arg name="rhost" type="sstr" desc="Address (i.e. DNS name, IP address, etc.) of a remotely connected host"/> <arg name="user" type="sstr" desc="Authentication identity"/> + <arg name="msgDepth" type="count32" desc="Current size of queue in messages"/> + <arg name="byteDepth" type="count32" desc="Current size of queue in bytes"/> </eventArguments> <event name="clientConnect" sev="inform" args="rhost, user"/> @@ -395,5 +397,6 @@ <event name="unbind" sev="inform" args="rhost, user, exName, qName, key"/> <event name="subscribe" sev="inform" args="rhost, user, qName, dest, excl, args"/> <event name="unsubscribe" sev="inform" args="rhost, user, dest"/> + <event name="queueThresholdExceeded" sev="warn" args="qName, msgDepth, byteDepth"/> </schema> diff --git a/qpid/tests/src/py/qpid_tests/broker_0_10/__init__.py b/qpid/tests/src/py/qpid_tests/broker_0_10/__init__.py index b70828224d..46d56ee0c0 100644 --- a/qpid/tests/src/py/qpid_tests/broker_0_10/__init__.py +++ b/qpid/tests/src/py/qpid_tests/broker_0_10/__init__.py @@ -31,3 +31,4 @@ from queue import * from tx import * from lvq import * from priority import * +from threshold import * diff --git a/qpid/tests/src/py/qpid_tests/broker_0_10/threshold.py b/qpid/tests/src/py/qpid_tests/broker_0_10/threshold.py new file mode 100644 index 0000000000..d8e36f47ec --- /dev/null +++ b/qpid/tests/src/py/qpid_tests/broker_0_10/threshold.py @@ -0,0 +1,124 @@ +# +# 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. +# + +from qpid.messaging import * +from qpid.tests.messaging import Base +import math + +class ThresholdTests (Base): + """ + Test queue threshold events are sent and received correctly + """ + + def setup_connection(self): + return Connection.establish(self.broker, **self.connection_options()) + + def setup_session(self): + return self.conn.session() + + def do_threshold_test(self, key, value, messages): + rcv = self.ssn.receiver("qmf.default.topic/agent.ind.event.org_apache_qpid_broker.queueThresholdExceeded.#") + snd = self.ssn.sender("ttq; {create:always, node: {x-declare:{auto_delete:True,exclusive:True,arguments:{'%s':%s}}}}" % (key, value)) + size = 0 + count = 0 + for m in messages: + snd.send(m) + count = count + 1 + size = size + len(m.content) + event = rcv.fetch() + schema = event.content[0]["_schema_id"] + assert schema["_class_name"] == "queueThresholdExceeded" + values = event.content[0]["_values"] + assert values["qName"] == "ttq" + assert values["msgDepth"] == count, "msgDepth %s, expected %s" % (values["msgDepth"], count) + assert values["byteDepth"] == size, "byteDepth %s, expected %s" % (values["byteDepth"], size) + + def test_alert_count(self): + self.do_threshold_test("qpid.alert_count", 5, [Message("msg-%s" % i) for i in range(5)]) + + def test_alert_size(self): + self.do_threshold_test("qpid.alert_size", 25, [Message("msg-%s" % i) for i in range(5)]) + + def test_alert_count_alias(self): + self.do_threshold_test("x-qpid-maximum-message-count", 10, [Message("msg-%s" % i) for i in range(10)]) + + def test_alert_size_alias(self): + self.do_threshold_test("x-qpid-maximum-message-size", 15, [Message("msg-%s" % i) for i in range(3)]) +# +# 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. +# + +from qpid.messaging import * +from qpid.tests.messaging import Base +import math + +class ThresholdTests (Base): + """ + Test queue threshold events are sent and received correctly + """ + + def setup_connection(self): + return Connection.establish(self.broker, **self.connection_options()) + + def setup_session(self): + return self.conn.session() + + def do_threshold_test(self, key, value, messages): + rcv = self.ssn.receiver("qmf.default.topic/agent.ind.event.org_apache_qpid_broker.queueThresholdExceeded.#") + snd = self.ssn.sender("ttq; {create:always, node: {x-declare:{auto_delete:True,exclusive:True,arguments:{'%s':%s}}}}" % (key, value)) + size = 0 + count = 0 + for m in messages: + snd.send(m) + count = count + 1 + size = size + len(m.content) + event = rcv.fetch() + schema = event.content[0]["_schema_id"] + assert schema["_class_name"] == "queueThresholdExceeded" + values = event.content[0]["_values"] + assert values["qName"] == "ttq" + assert values["msgDepth"] == count, "msgDepth %s, expected %s" % (values["msgDepth"], count) + assert values["byteDepth"] == size, "byteDepth %s, expected %s" % (values["byteDepth"], size) + + def test_alert_count(self): + self.do_threshold_test("qpid.alert_count", 5, [Message("msg-%s" % i) for i in range(5)]) + + def test_alert_size(self): + self.do_threshold_test("qpid.alert_size", 25, [Message("msg-%s" % i) for i in range(5)]) + + def test_alert_count_alias(self): + self.do_threshold_test("x-qpid-maximum-message-count", 10, [Message("msg-%s" % i) for i in range(10)]) + + def test_alert_size_alias(self): + self.do_threshold_test("x-qpid-maximum-message-size", 15, [Message("msg-%s" % i) for i in range(3)]) |