Repository: activemq Updated Branches: refs/heads/master cf3d41952 -> 37da75e0e
https://issues.apache.org/jira/browse/AMQ-6375 Quick fix the build after broken by previous commit on this issue, no actual stats tracking implemented in LevelDB by this commit. Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/37da75e0 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/37da75e0 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/37da75e0 Branch: refs/heads/master Commit: 37da75e0e48800317d1a36d7d0b8adab0d2b06b7 Parents: cf3d419 Author: Timothy Bish <tabish...@gmail.com> Authored: Tue Jul 26 16:56:02 2016 -0400 Committer: Timothy Bish <tabish...@gmail.com> Committed: Tue Jul 26 16:56:02 2016 -0400 ---------------------------------------------------------------------- .../org/apache/activemq/leveldb/LevelDBStore.scala | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/37da75e0/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala ---------------------------------------------------------------------- diff --git a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala index 5865f35..cb28173 100644 --- a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala +++ b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala @@ -87,7 +87,7 @@ class LevelDBStoreTest(val store:LevelDBStore) extends LevelDBStoreTestMBean { import store._ var suspendForce = false; - + override def setSuspendForce(value: Boolean): Unit = this.synchronized { if( suspendForce!=value ) { suspendForce = value; @@ -129,7 +129,7 @@ class LevelDBStoreTest(val store:LevelDBStore) extends LevelDBStoreTestMBean { } var suspendDelete = false; - + override def setSuspendDelete(value: Boolean): Unit = this.synchronized { if( suspendDelete!=value ) { suspendDelete = value; @@ -147,8 +147,8 @@ class LevelDBStoreTest(val store:LevelDBStore) extends LevelDBStoreTestMBean { override def getDeleteCalls = this.synchronized { db.client.log.recordLogTestSupport.deleteCall.threads.get() - } - + } + } class LevelDBStoreView(val store:LevelDBStore) extends LevelDBStoreViewMBean { @@ -901,6 +901,12 @@ class LevelDBStore extends LockableServiceSupport with BrokerServiceAware with P super.asyncAddQueueMessage(context, message, false) } + var stats = new MessageStoreSubscriptionStatistics(false) + + def getMessageStoreSubStatistics: MessageStoreSubscriptionStatistics = { + stats; + } + def subscription_count = subscriptions.synchronized { subscriptions.size } @@ -1008,7 +1014,7 @@ class LevelDBStore extends LockableServiceSupport with BrokerServiceAware with P case None => 0 } } - + def getMessageSize(clientId: String, subscriptionName: String): Long = { check_running return 0
