[rhmessaging-commits] rhmessaging commits: r1359 - in mgmt: cumin/python/wooly and 1 other directories.
rhmessaging-commits at lists.jboss.org
rhmessaging-commits at lists.jboss.org
Mon Nov 26 14:21:17 EST 2007
Author: justi9
Date: 2007-11-26 14:21:17 -0500 (Mon, 26 Nov 2007)
New Revision: 1359
Modified:
mgmt/cumin/python/cumin/exchange.py
mgmt/cumin/python/cumin/model.py
mgmt/cumin/python/wooly/__init__.py
mgmt/mint/python/mint/schema.py
mgmt/mint/python/mint/schema.sql
Log:
Ted's more detailed exchange data exposed leftover model-migration
problems. This change fixes those. It also introduces some exchange
metadata for displaying exchange stats.
Updates the schema.
Modified: mgmt/cumin/python/cumin/exchange.py
===================================================================
--- mgmt/cumin/python/cumin/exchange.py 2007-11-26 16:33:58 UTC (rev 1358)
+++ mgmt/cumin/python/cumin/exchange.py 2007-11-26 19:21:17 UTC (rev 1359)
@@ -68,19 +68,19 @@
def render_item_received(self, session, exchange):
unit = self.unit.get(session)
key = unit == "b" and "byteReceives" or "msgReceives"
- value = getattr(exchange.mintExchangeStats, key)
+ value = getattr(exchange.stats, key)
return fmt_rate(value, unit == "b" and "byte" or "msg", "sec")
def render_item_routed(self, session, exchange):
unit = self.unit.get(session)
key = unit == "b" and "byteRoutes" or "msgRoutes"
- value = getattr(exchange.mintExchangeStats, key)
+ value = getattr(exchange.stats, key)
return fmt_rate(value, unit == "b" and "byte" or "msg", "sec")
def render_item_dropped(self, session, exchange):
unit = self.unit.get(session)
key = unit == "b" and "byteDrops" or "msgDrops"
- return getattr(exchange.mintExchangeStats, key)
+ return getattr(exchange.stats, key)
def render_item_status(self, session, exchange):
return fmt_ostatus(exchange)
@@ -108,8 +108,9 @@
# XXX not awesome
def get_object(self, session, object):
exchange = self.param.get(session)
- exchange.get_measurement("producers").link_cb = show_producers
- exchange.get_measurement("bindings").link_cb = show_bindings
+ # XXX
+ #self.app.cmodel.get_stat(exchange, "producers").link_cb = show_producers
+ #self.app.cmodel.get_stat(exchange, "bindings").link_cb = show_bindings
return exchange
def get_title(self, session, exchange):
@@ -120,26 +121,26 @@
return "exchange.xml?id=%i" % exchange.id
def render_messages_received(self, session, exchange):
- value = exchange.get_measurement("msgReceives").get_rate()
+ value = exchange.stats.msgReceives # XXX rate me
return fmt_rate(value, "msg", "sec")
def render_messages_routed(self, session, exchange):
- value = exchange.get_measurement("msgRoutes").get_rate()
+ value = exchange.stats.msgRoutes # XXX rate me
return fmt_rate(value, "msg", "sec")
def render_messages_dropped(self, session, exchange):
- return exchange.get_measurement("msgDrops").get_value()
+ return exchange.stats.msgDrops
def render_bytes_received(self, session, exchange):
- value = exchange.get_measurement("byteReceives").get_rate()
+ value = exchange.stats.byteReceives # XXX rate me
return fmt_rate(value, "byte", "sec")
def render_bytes_routed(self, session, exchange):
- value = exchange.get_measurement("byteRoutes").get_rate()
+ value = exchange.stats.byteRoutes # XXX rate me
return fmt_rate(value, "byte", "sec")
def render_bytes_dropped(self, session, exchange):
- return exchange.get_measurement("byteDrops").get_value()
+ return exchange.stats.byteDrops
class ExchangeView(Widget):
def __init__(self, app, name):
@@ -199,20 +200,20 @@
def render_item_href(self, session, binding):
branch = session.branch()
- self.page().show_queue(branch, binding.mintQueue)
+ self.page().show_queue(branch, binding.queue)
return branch.marshal()
def render_item_name(self, session, binding):
- return binding.mintQueue.name
+ return binding.queue.name
def render_item_binding_key(self, session, binding):
return binding.bindingKey
def render_item_messages_matched(self, session, binding):
- return binding.mintBindingStats.msgMatched
+ return binding.stats.msgMatched
def render_item_messages_matched_rate(self, session, binding):
- value = binding.mintBindingStats.msgMatched
+ value = binding.stats.msgMatched
return fmt_rate(value, "msg", "sec")
class ExchangeForm(CuminForm):
@@ -376,17 +377,17 @@
return producer.name
def render_item_messages_produced(self, session, producer):
- return producer.mintProducerStats.msgsProduced
+ return producer.stats.msgsProduced
def render_item_messages_produced_rate(self, session, producer):
- value = producer.mintProducerStats.msgsProduced
+ value = producer.stats.msgsProduced
return fmt_rate(value, "msg", "sec")
def render_item_bytes_produced(self, session, producer):
- return producer.mintProducerStats.bytesProduced
+ return producer.stats.bytesProduced
def render_item_bytes_produced_rate(self, session, producer):
- value = producer.mintProducerStats.bytesProduced
+ value = producer.stats.bytesProduced
return fmt_rate(value, "byte", "sec")
class ExchangeXmlPage(CuminXmlPage):
Modified: mgmt/cumin/python/cumin/model.py
===================================================================
--- mgmt/cumin/python/cumin/model.py 2007-11-26 16:33:58 UTC (rev 1358)
+++ mgmt/cumin/python/cumin/model.py 2007-11-26 19:21:17 UTC (rev 1359)
@@ -11,12 +11,18 @@
self.queue = CuminQueue(self)
self.add_class(self.queue)
+ self.exchange = CuminExchange(self)
+ self.add_class(self.exchange)
+
def add_class(self, cls):
self.classes[cls.mint_class] = cls
def get_class(self, mint_object):
return self.classes[mint_object.__class__]
+ def get_stat(self, mint_object, name):
+ return self.get_class(mint_object).get_stat(name)
+
class CuminClass(object):
def __init__(self, model, mint_class):
self.model = model
@@ -156,10 +162,10 @@
#stat.title = "Page size"
#stat.categories = ("disk")
- stat = CuminStat(self, "diskPages", "int")
- stat.title = "Disk Pages"
- stat.unit = "page"
- stat.categories = ("general")
+ #stat = CuminStat(self, "diskPages", "int")
+ #stat.title = "Disk Pages"
+ #stat.unit = "page"
+ #stat.categories = ("general")
#stat = CuminStat(self, "diskAvailableSize", "int")
#stat.title = "Available size"
@@ -260,6 +266,54 @@
writer.write("</queue>")
+class CuminExchange(CuminClass):
+ def __init__(self, model):
+ super(CuminExchange, self).__init__(model, mint.Exchange)
+
+ self.mint_stats_class = mint.ExchangeStats
+
+ stat = CuminStat(self, "producers", "int")
+ stat.title = "Producers"
+ stat.unit = "producer"
+ stat.categories = ("general")
+ stat.highlow = True
+
+ stat = CuminStat(self, "bindings", "int")
+ stat.title = "Bindings"
+ stat.unit = "binding"
+ stat.categories = ("general")
+ stat.highlow = True
+
+ stat = CuminStat(self, "msgReceives", "int")
+ stat.title = "Msgs. Received"
+ stat.unit = "message"
+ stat.categories = ("general")
+
+ stat = CuminStat(self, "msgRoutes", "int")
+ stat.title = "Msgs. Routed"
+ stat.unit = "message"
+ stat.categories = ("general")
+
+ stat = CuminStat(self, "msgDrops", "int")
+ stat.title = "Msgs. Dropped"
+ stat.unit = "message"
+ stat.categories = ("general")
+
+ stat = CuminStat(self, "byteReceives", "int")
+ stat.title = "Bytes Received"
+ stat.unit = "message"
+ stat.categories = ("general")
+
+ stat = CuminStat(self, "byteRoutes", "int")
+ stat.title = "Bytes Routed"
+ stat.unit = "message"
+ stat.categories = ("general")
+
+ stat = CuminStat(self, "byteDrops", "int")
+ stat.title = "Bytes Dropped"
+ stat.unit = "message"
+ stat.categories = ("general")
+
class DummyModel(Model):
def __init__(self):
super(DummyModel, self).__init__()
Modified: mgmt/cumin/python/wooly/__init__.py
===================================================================
--- mgmt/cumin/python/wooly/__init__.py 2007-11-26 16:33:58 UTC (rev 1358)
+++ mgmt/cumin/python/wooly/__init__.py 2007-11-26 19:21:17 UTC (rev 1359)
@@ -482,7 +482,7 @@
self.trunk = trunk
self.page = None
self.values = dict()
- self.errors = dict() # widget => list of str
+ self.errors = dict() # widget => list of str # XXX remove this
if self.app.debug:
self.debug = self.Debug(self)
@@ -519,7 +519,7 @@
def set_page(self, page):
self.page = page
- def get(self, key):
+ def get(self, key): # XXX we can make this a little faster, no?
if key in self.values:
value = self.values[key]
elif self.trunk:
@@ -561,7 +561,7 @@
def marshal_url_vars(self, separator=";"):
params = self.get_page().get_saved_parameters(self)
- if params:
+ if params: # XXX removing this may make sense; it's an uncommon case
vars = list()
for param in params:
Modified: mgmt/mint/python/mint/schema.py
===================================================================
--- mgmt/mint/python/mint/schema.py 2007-11-26 16:33:58 UTC (rev 1358)
+++ mgmt/mint/python/mint/schema.py 2007-11-26 19:21:17 UTC (rev 1359)
@@ -115,13 +115,13 @@
model.getConnectedBroker(managedBrokerLabel).method(methodId, self.idOriginal, \
classToSchemaNameMap[self.__class__.__name__], "purge", args=actualArgs, packageName="qpid")
- def increaseDiskSize(self, model, managedBrokerLabel, callbackMethod, pages):
+ def increaseJournalSize(self, model, managedBrokerLabel, callbackMethod, pages):
"""Increase number of disk pages allocated for this queue"""
actualArgs = dict()
actualArgs["pages"] = pages
methodId = model.registerCallback(callbackMethod)
model.getConnectedBroker(managedBrokerLabel).method(methodId, self.idOriginal, \
- classToSchemaNameMap[self.__class__.__name__], "increaseDiskSize", args=actualArgs, packageName="qpid")
+ classToSchemaNameMap[self.__class__.__name__], "increaseJournalSize", args=actualArgs, packageName="qpid")
Vhost.sqlmeta.addJoin(MultipleJoin('Queue', joinMethodName='queues'))
@@ -130,9 +130,34 @@
idOriginal = BigIntCol(default=None)
recTime = TimestampCol(default=None)
queue = ForeignKey('Queue', cascade='null', default=None)
- diskPageSize = IntCol(default=None)
- diskPages = IntCol(default=None)
- diskAvailableSize = IntCol(default=None)
+ journalLocation = StringCol(length=1000, default=None)
+ journalBaseFileName = StringCol(length=1000, default=None)
+ journalInitialFileCount = IntCol(default=None)
+ journalCurrentFileCount = IntCol(default=None)
+ journalDataFileSize = IntCol(default=None)
+ journalFreeFileCount = IntCol(default=None)
+ journalFreeFileCountLow = IntCol(default=None)
+ journalFreeFileCountHigh = IntCol(default=None)
+ journalAvailableFileCount = IntCol(default=None)
+ journalAvailableFileCountLow = IntCol(default=None)
+ journalAvailableFileCountHigh = IntCol(default=None)
+ journalRecordDepth = IntCol(default=None)
+ journalRecordDepthLow = IntCol(default=None)
+ journalRecordDepthHigh = IntCol(default=None)
+ journalRecordEnqueues = BigIntCol(default=None)
+ journalRecordDequeues = BigIntCol(default=None)
+ journalWriteWaitFailures = BigIntCol(default=None)
+ journalWriteBusyFailures = BigIntCol(default=None)
+ journalReadRecordCount = BigIntCol(default=None)
+ journalReadBusyFailures = BigIntCol(default=None)
+ journalWritePageCacheDepth = IntCol(default=None)
+ journalWritePageCacheDepthLow = IntCol(default=None)
+ journalWritePageCacheDepthHigh = IntCol(default=None)
+ journalWritePageSize = IntCol(default=None)
+ journalReadPageCacheDepth = IntCol(default=None)
+ journalReadPageCacheDepthLow = IntCol(default=None)
+ journalReadPageCacheDepthHigh = IntCol(default=None)
+ journalReadPageSize = IntCol(default=None)
msgTotalEnqueues = BigIntCol(default=None)
msgTotalDequeues = BigIntCol(default=None)
msgTxnEnqueues = BigIntCol(default=None)
Modified: mgmt/mint/python/mint/schema.sql
===================================================================
--- mgmt/mint/python/mint/schema.sql 2007-11-26 16:33:58 UTC (rev 1358)
+++ mgmt/mint/python/mint/schema.sql 2007-11-26 19:21:17 UTC (rev 1359)
@@ -1,408 +1,24 @@
-CREATE TABLE binding (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- creation_time TIMESTAMP,
- deletion_time TIMESTAMP,
- managed_broker VARCHAR(1000),
- stats_id INT,
- stats_prev_id INT,
- queue_id INT,
- exchange_id INT,
- binding_key VARCHAR(1000)
-);
-
-CREATE TABLE binding_stats (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- binding_id INT,
- msg_matched BIGINT
-);
-
-CREATE TABLE broker (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- creation_time TIMESTAMP,
- deletion_time TIMESTAMP,
- managed_broker VARCHAR(1000),
- stats_id INT,
- stats_prev_id INT,
- system_id INT,
- port SMALLINT,
- worker_threads SMALLINT,
- max_conns SMALLINT,
- conn_backlog SMALLINT,
- staging_threshold INT,
- store_lib VARCHAR(1000),
- async_store BOOL,
- mgmt_pub_interval SMALLINT,
- initial_disk_page_size INT,
- initial_pages_per_queue INT,
- cluster_name VARCHAR(1000),
- version VARCHAR(1000)
-);
-
-CREATE TABLE broker_stats (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- broker_id INT
-);
-
-CREATE TABLE client (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- creation_time TIMESTAMP,
- deletion_time TIMESTAMP,
- managed_broker VARCHAR(1000),
- stats_id INT,
- stats_prev_id INT,
- vhost_id INT,
- ip_addr INT,
- port SMALLINT
-);
-
-CREATE TABLE client_stats (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- client_id INT,
- auth_identity VARCHAR(1000),
- msgs_produced BIGINT,
- msgs_consumed BIGINT,
- bytes_produced BIGINT,
- bytes_consumed BIGINT
-);
-
-CREATE TABLE consumer (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- creation_time TIMESTAMP,
- deletion_time TIMESTAMP,
- managed_broker VARCHAR(1000),
- stats_id INT,
- stats_prev_id INT,
- destination_id INT,
- queue_id INT
-);
-
-CREATE TABLE consumer_stats (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- consumer_id INT,
- msgs_consumed BIGINT,
- bytes_consumed BIGINT,
- unacked_messages INT,
- unacked_messages_low INT,
- unacked_messages_high INT
-);
-
-CREATE TABLE destination (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- creation_time TIMESTAMP,
- deletion_time TIMESTAMP,
- managed_broker VARCHAR(1000),
- stats_id INT,
- stats_prev_id INT,
- session_id INT,
- name VARCHAR(1000)
-);
-
-CREATE TABLE destination_stats (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- destination_id INT,
- flow_mode SMALLINT,
- max_msg_credits INT,
- max_byte_credits INT,
- msg_credits INT,
- byte_credits INT
-);
-
-CREATE TABLE exchange (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- creation_time TIMESTAMP,
- deletion_time TIMESTAMP,
- managed_broker VARCHAR(1000),
- stats_id INT,
- stats_prev_id INT,
- vhost_id INT,
- name VARCHAR(1000),
- type VARCHAR(1000)
-);
-
-CREATE TABLE exchange_stats (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- exchange_id INT,
- producers INT,
- producers_low INT,
- producers_high INT,
- bindings INT,
- bindings_low INT,
- bindings_high INT,
- msg_receives BIGINT,
- msg_drops BIGINT,
- msg_routes BIGINT,
- byte_receives BIGINT,
- byte_drops BIGINT,
- byte_routes BIGINT
-);
-
-CREATE TABLE producer (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- creation_time TIMESTAMP,
- deletion_time TIMESTAMP,
- managed_broker VARCHAR(1000),
- stats_id INT,
- stats_prev_id INT,
- destination_id INT,
- exchange_id INT
-);
-
-CREATE TABLE producer_stats (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- producer_id INT,
- msgs_produced BIGINT,
- bytes_produced BIGINT
-);
-
-CREATE TABLE queue (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- creation_time TIMESTAMP,
- deletion_time TIMESTAMP,
- managed_broker VARCHAR(1000),
- stats_id INT,
- stats_prev_id INT,
- vhost_id INT,
- name VARCHAR(1000),
- durable BOOL,
- auto_delete BOOL,
- exclusive BOOL,
- page_memory_limit INT
-);
-
-CREATE TABLE queue_stats (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- queue_id INT,
- disk_page_size INT,
- disk_pages INT,
- disk_available_size INT,
- msg_total_enqueues BIGINT,
- msg_total_dequeues BIGINT,
- msg_txn_enqueues BIGINT,
- msg_txn_dequeues BIGINT,
- msg_persist_enqueues BIGINT,
- msg_persist_dequeues BIGINT,
- msg_depth INT,
- msg_depth_low INT,
- msg_depth_high INT,
- byte_total_enqueues BIGINT,
- byte_total_dequeues BIGINT,
- byte_txn_enqueues BIGINT,
- byte_txn_dequeues BIGINT,
- byte_persist_enqueues BIGINT,
- byte_persist_dequeues BIGINT,
- byte_depth INT,
- byte_depth_low INT,
- byte_depth_high INT,
- enqueue_txn_starts BIGINT,
- enqueue_txn_commits BIGINT,
- enqueue_txn_rejects BIGINT,
- enqueue_txn_count INT,
- enqueue_txn_count_low INT,
- enqueue_txn_count_high INT,
- dequeue_txn_starts BIGINT,
- dequeue_txn_commits BIGINT,
- dequeue_txn_rejects BIGINT,
- dequeue_txn_count INT,
- dequeue_txn_count_low INT,
- dequeue_txn_count_high INT,
- consumers INT,
- consumers_low INT,
- consumers_high INT,
- bindings INT,
- bindings_low INT,
- bindings_high INT,
- unacked_messages INT,
- unacked_messages_low INT,
- unacked_messages_high INT
-);
-
-CREATE TABLE session (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- creation_time TIMESTAMP,
- deletion_time TIMESTAMP,
- managed_broker VARCHAR(1000),
- stats_id INT,
- stats_prev_id INT,
- vhost_id INT,
- name VARCHAR(1000),
- client_id INT,
- detached_lifespan INT
-);
-
-CREATE TABLE session_stats (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- session_id INT,
- attached BOOL,
- remaining_lifespan INT,
- frames_outstanding INT
-);
-
-CREATE TABLE system (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- creation_time TIMESTAMP,
- deletion_time TIMESTAMP,
- managed_broker VARCHAR(1000),
- stats_id INT,
- stats_prev_id INT,
- sys_id VARCHAR(1000)
-);
-
-CREATE TABLE system_stats (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- system_id INT
-);
-
-CREATE TABLE vhost (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- creation_time TIMESTAMP,
- deletion_time TIMESTAMP,
- managed_broker VARCHAR(1000),
- stats_id INT,
- stats_prev_id INT,
- broker_id INT,
- name VARCHAR(1000)
-);
-
-CREATE TABLE vhost_stats (
- id SERIAL PRIMARY KEY,
- id_original BIGINT,
- rec_time TIMESTAMP,
- vhost_id INT
-);
-
-ALTER TABLE binding ADD CONSTRAINT stats_id_exists FOREIGN KEY (stats_id) REFERENCES binding_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE binding ADD CONSTRAINT stats_prev_id_exists FOREIGN KEY (stats_prev_id) REFERENCES binding_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE binding ADD CONSTRAINT queue_id_exists FOREIGN KEY (queue_id) REFERENCES queue (id) ON DELETE SET NULL;
-
-ALTER TABLE binding ADD CONSTRAINT exchange_id_exists FOREIGN KEY (exchange_id) REFERENCES exchange (id) ON DELETE SET NULL;
-
-ALTER TABLE binding_stats ADD CONSTRAINT binding_id_exists FOREIGN KEY (binding_id) REFERENCES binding (id) ON DELETE SET NULL;
-
-ALTER TABLE broker ADD CONSTRAINT stats_id_exists FOREIGN KEY (stats_id) REFERENCES broker_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE broker ADD CONSTRAINT stats_prev_id_exists FOREIGN KEY (stats_prev_id) REFERENCES broker_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE broker ADD CONSTRAINT system_id_exists FOREIGN KEY (system_id) REFERENCES system (id) ON DELETE SET NULL;
-
-ALTER TABLE broker_stats ADD CONSTRAINT broker_id_exists FOREIGN KEY (broker_id) REFERENCES broker (id) ON DELETE SET NULL;
-
-ALTER TABLE client ADD CONSTRAINT stats_id_exists FOREIGN KEY (stats_id) REFERENCES client_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE client ADD CONSTRAINT stats_prev_id_exists FOREIGN KEY (stats_prev_id) REFERENCES client_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE client ADD CONSTRAINT vhost_id_exists FOREIGN KEY (vhost_id) REFERENCES vhost (id) ON DELETE SET NULL;
-
-ALTER TABLE client_stats ADD CONSTRAINT client_id_exists FOREIGN KEY (client_id) REFERENCES client (id) ON DELETE SET NULL;
-
-ALTER TABLE consumer ADD CONSTRAINT stats_id_exists FOREIGN KEY (stats_id) REFERENCES consumer_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE consumer ADD CONSTRAINT stats_prev_id_exists FOREIGN KEY (stats_prev_id) REFERENCES consumer_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE consumer ADD CONSTRAINT destination_id_exists FOREIGN KEY (destination_id) REFERENCES destination (id) ON DELETE SET NULL;
-
-ALTER TABLE consumer ADD CONSTRAINT queue_id_exists FOREIGN KEY (queue_id) REFERENCES queue (id) ON DELETE SET NULL;
-
-ALTER TABLE consumer_stats ADD CONSTRAINT consumer_id_exists FOREIGN KEY (consumer_id) REFERENCES consumer (id) ON DELETE SET NULL;
-
-ALTER TABLE destination ADD CONSTRAINT stats_id_exists FOREIGN KEY (stats_id) REFERENCES destination_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE destination ADD CONSTRAINT stats_prev_id_exists FOREIGN KEY (stats_prev_id) REFERENCES destination_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE destination ADD CONSTRAINT session_id_exists FOREIGN KEY (session_id) REFERENCES session (id) ON DELETE SET NULL;
-
-ALTER TABLE destination_stats ADD CONSTRAINT destination_id_exists FOREIGN KEY (destination_id) REFERENCES destination (id) ON DELETE SET NULL;
-
-ALTER TABLE exchange ADD CONSTRAINT stats_id_exists FOREIGN KEY (stats_id) REFERENCES exchange_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE exchange ADD CONSTRAINT stats_prev_id_exists FOREIGN KEY (stats_prev_id) REFERENCES exchange_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE exchange ADD CONSTRAINT vhost_id_exists FOREIGN KEY (vhost_id) REFERENCES vhost (id) ON DELETE SET NULL;
-
-ALTER TABLE exchange_stats ADD CONSTRAINT exchange_id_exists FOREIGN KEY (exchange_id) REFERENCES exchange (id) ON DELETE SET NULL;
-
-ALTER TABLE producer ADD CONSTRAINT stats_id_exists FOREIGN KEY (stats_id) REFERENCES producer_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE producer ADD CONSTRAINT stats_prev_id_exists FOREIGN KEY (stats_prev_id) REFERENCES producer_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE producer ADD CONSTRAINT destination_id_exists FOREIGN KEY (destination_id) REFERENCES destination (id) ON DELETE SET NULL;
-
-ALTER TABLE producer ADD CONSTRAINT exchange_id_exists FOREIGN KEY (exchange_id) REFERENCES exchange (id) ON DELETE SET NULL;
-
-ALTER TABLE producer_stats ADD CONSTRAINT producer_id_exists FOREIGN KEY (producer_id) REFERENCES producer (id) ON DELETE SET NULL;
-
-ALTER TABLE queue ADD CONSTRAINT stats_id_exists FOREIGN KEY (stats_id) REFERENCES queue_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE queue ADD CONSTRAINT stats_prev_id_exists FOREIGN KEY (stats_prev_id) REFERENCES queue_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE queue ADD CONSTRAINT vhost_id_exists FOREIGN KEY (vhost_id) REFERENCES vhost (id) ON DELETE SET NULL;
-
-ALTER TABLE queue_stats ADD CONSTRAINT queue_id_exists FOREIGN KEY (queue_id) REFERENCES queue (id) ON DELETE SET NULL;
-
-ALTER TABLE session ADD CONSTRAINT stats_id_exists FOREIGN KEY (stats_id) REFERENCES session_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE session ADD CONSTRAINT stats_prev_id_exists FOREIGN KEY (stats_prev_id) REFERENCES session_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE session ADD CONSTRAINT vhost_id_exists FOREIGN KEY (vhost_id) REFERENCES vhost (id) ON DELETE SET NULL;
-
-ALTER TABLE session ADD CONSTRAINT client_id_exists FOREIGN KEY (client_id) REFERENCES client (id) ON DELETE SET NULL;
-
-ALTER TABLE session_stats ADD CONSTRAINT session_id_exists FOREIGN KEY (session_id) REFERENCES session (id) ON DELETE SET NULL;
-
-ALTER TABLE system ADD CONSTRAINT stats_id_exists FOREIGN KEY (stats_id) REFERENCES system_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE system ADD CONSTRAINT stats_prev_id_exists FOREIGN KEY (stats_prev_id) REFERENCES system_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE system_stats ADD CONSTRAINT system_id_exists FOREIGN KEY (system_id) REFERENCES system (id) ON DELETE SET NULL;
-
-ALTER TABLE vhost ADD CONSTRAINT stats_id_exists FOREIGN KEY (stats_id) REFERENCES vhost_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE vhost ADD CONSTRAINT stats_prev_id_exists FOREIGN KEY (stats_prev_id) REFERENCES vhost_stats (id) ON DELETE SET NULL;
-
-ALTER TABLE vhost ADD CONSTRAINT broker_id_exists FOREIGN KEY (broker_id) REFERENCES broker (id) ON DELETE SET NULL;
-
-ALTER TABLE vhost_stats ADD CONSTRAINT vhost_id_exists FOREIGN KEY (vhost_id) REFERENCES vhost (id) ON DELETE SET NULL;
-
+These classes do not have connections set:
+ * Binding
+ * BindingStats
+ * Broker
+ * BrokerStats
+ * Client
+ * ClientStats
+ * Consumer
+ * ConsumerStats
+ * Destination
+ * DestinationStats
+ * Exchange
+ * ExchangeStats
+ * Producer
+ * ProducerStats
+ * Queue
+ * QueueStats
+ * Session
+ * SessionStats
+ * System
+ * SystemStats
+ * Vhost
+ * VhostStats
+You must indicate --connection=URI
More information about the rhmessaging-commits
mailing list