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

AMQ-5005. Fix for scala plugin

This commit is contained in:
Hadrian Zbarcea 2014-01-30 15:43:19 -05:00
parent 69e6ad8cf3
commit d36e3c0e95
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBClient.scala
View File

@ -836,7 +836,7 @@ class LevelDBClient(store: LevelDBStore) {
private def logRefIncrement(pos: Long) {
for( key <- logRefKey(pos) ) {
logRefs.getOrElseUpdate(key, new LongCounter()).incrementAndGet()
logRefs.getOrElseUpdate(key, new LongCounter(0)).incrementAndGet()
}
}

3
activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/groups/ClusteredSingleton.scala
View File

@ -163,7 +163,8 @@ class ClusteredSingletonWatcher[T <: NodeState](val stateClass:Class[T]) extends
def masters = this.synchronized {
_members.mapValues(_.head._2).toArray.map(_._2).toArray(new ClassManifest[T] {
def erasure = stateClass
def runtimeClass = stateClass
override def erasure = stateClass
})
}