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

fix up imports - resolve warn re permanently hidden defs 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1428409 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2013-01-03 15:41:43 +00:00
parent 69d8258308
commit 6335b7e331
1 changed files with 1 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/DBManager.scala
View File

@ -21,26 +21,18 @@ import org.fusesource.hawtdispatch._
import org.fusesource.hawtdispatch.BaseRetained import org.fusesource.hawtdispatch.BaseRetained
import java.util.concurrent._ import java.util.concurrent._
import atomic._ import atomic._
import org.fusesource.hawtbuf.{DataByteArrayOutputStream, DataByteArrayInputStream, ByteArrayOutputStream, Buffer} import org.fusesource.hawtbuf.Buffer
import org.apache.activemq.store.MessageRecoveryListener import org.apache.activemq.store.MessageRecoveryListener
import java.lang.ref.WeakReference import java.lang.ref.WeakReference
import scala.Option._ import scala.Option._
import org.fusesource.hawtbuf.Buffer._ import org.fusesource.hawtbuf.Buffer._
import org.apache.activemq.command._ import org.apache.activemq.command._
import org.apache.activemq.leveldb.record.{SubscriptionRecord, CollectionRecord} import org.apache.activemq.leveldb.record.{SubscriptionRecord, CollectionRecord}
import util.TimeMetric
import java.util.HashMap import java.util.HashMap
import collection.mutable.{HashSet, ListBuffer} import collection.mutable.{HashSet, ListBuffer}
import org.apache.activemq.util.ByteSequence import org.apache.activemq.util.ByteSequence
import org.apache.activemq.leveldb.QueueEntryRecord
import util.TimeMetric import util.TimeMetric
import org.apache.activemq.leveldb.SubAckRecord
import scala.Some import scala.Some
import org.apache.activemq.leveldb.UowManagerConstants.QueueEntryKey
import org.apache.activemq.leveldb.CountDownFuture
import org.apache.activemq.leveldb.XaAckRecord
import org.apache.activemq.leveldb.MessageRecord
import org.apache.activemq.leveldb.DurableSubscription
case class MessageRecord(id:MessageId, data:Buffer, syncNeeded:Boolean) { case class MessageRecord(id:MessageId, data:Buffer, syncNeeded:Boolean) {
var locator:(Long, Int) = _ var locator:(Long, Int) = _