Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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.
This commit is contained in:
Timothy Bish 2016-07-26 16:56:02 -04:00
parent cf3d419528
commit 37da75e0e4
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala
View File

@ -87,7 +87,7 @@ class LevelDBStoreTest(val store:LevelDBStore) extends LevelDBStoreTestMBean {
import store._ import store._
var suspendForce = false; var suspendForce = false;
override def setSuspendForce(value: Boolean): Unit = this.synchronized { override def setSuspendForce(value: Boolean): Unit = this.synchronized {
if( suspendForce!=value ) { if( suspendForce!=value ) {
suspendForce = value; suspendForce = value;
@ -129,7 +129,7 @@ class LevelDBStoreTest(val store:LevelDBStore) extends LevelDBStoreTestMBean {
} }
var suspendDelete = false; var suspendDelete = false;
override def setSuspendDelete(value: Boolean): Unit = this.synchronized { override def setSuspendDelete(value: Boolean): Unit = this.synchronized {
if( suspendDelete!=value ) { if( suspendDelete!=value ) {
suspendDelete = value; suspendDelete = value;
@ -147,8 +147,8 @@ class LevelDBStoreTest(val store:LevelDBStore) extends LevelDBStoreTestMBean {
override def getDeleteCalls = this.synchronized { override def getDeleteCalls = this.synchronized {
db.client.log.recordLogTestSupport.deleteCall.threads.get() db.client.log.recordLogTestSupport.deleteCall.threads.get()
} }
} }
class LevelDBStoreView(val store:LevelDBStore) extends LevelDBStoreViewMBean { class LevelDBStoreView(val store:LevelDBStore) extends LevelDBStoreViewMBean {
@ -901,6 +901,12 @@ class LevelDBStore extends LockableServiceSupport with BrokerServiceAware with P
super.asyncAddQueueMessage(context, message, false) super.asyncAddQueueMessage(context, message, false)
} }
var stats = new MessageStoreSubscriptionStatistics(false)
def getMessageStoreSubStatistics: MessageStoreSubscriptionStatistics = {
stats;
}
def subscription_count = subscriptions.synchronized { def subscription_count = subscriptions.synchronized {
subscriptions.size subscriptions.size
} }
@ -1008,7 +1014,7 @@ class LevelDBStore extends LockableServiceSupport with BrokerServiceAware with P
case None => 0 case None => 0
} }
} }
def getMessageSize(clientId: String, subscriptionName: String): Long = { def getMessageSize(clientId: String, subscriptionName: String): Long = {
check_running check_running
return 0 return 0