activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobImpl.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobListener.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobLocation.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobScheduler.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobSchedulerFacade.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobSchedulerImpl.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobSchedulerStore.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/SchedulerBroker.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/SharedFileLocker.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MultiKahaDBTransactionStore.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/TempKahaDBStore.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/TempMessageDatabase.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/
|
added
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/index/
|
added
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/index/BTreeIndex.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/BTreeIndex.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/index/BTreeNode.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/BTreeNode.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/index/BTreeVisitor.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/BTreeVisitor.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/index/HashBin.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/HashBin.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/index/HashIndex.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/HashIndex.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/index/Index.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/Index.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/index/ListIndex.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/ListIndex.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/index/ListNode.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/ListNode.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/
|
added
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/CallerBufferingDataFileAppender.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/CallerBufferingDataFileAppender.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/DataFile.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/DataFile.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/DataFileAccessor.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/DataFileAccessor.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/DataFileAccessorPool.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/DataFileAccessorPool.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/DataFileAppender.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/DataFileAppender.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/FileAppender.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/FileAppender.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/Journal.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Location.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/Location.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/ReadOnlyDataFile.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/ReadOnlyDataFile.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/ReadOnlyJournal.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/ReadOnlyJournal.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/ReplicationTarget.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/ReplicationTarget.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/journal/package.html
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/package.html, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/package.html
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/package.html, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/page/
|
added
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/page/Page.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/page/Page.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/page/PageFile.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/page/PageFile.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/page/Transaction.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/page/Transaction.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/
|
added
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/BytesMarshaller.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/BytesMarshaller.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/CommandLineSupport.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/CommandLineSupport.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/DataByteArrayInputStream.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/DataByteArrayInputStream.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/DataByteArrayOutputStream.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/DataByteArrayOutputStream.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/DiskBenchmark.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/DiskBenchmark.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/IntegerMarshaller.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/IntegerMarshaller.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/LinkedNode.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/LinkedNode.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/LinkedNodeList.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/LinkedNodeList.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/LocationMarshaller.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/LocationMarshaller.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/LongMarshaller.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/LongMarshaller.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/Marshaller.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/Marshaller.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/ObjectMarshaller.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/ObjectMarshaller.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/Scheduler.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/Scheduler.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/SchedulerTimerTask.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/SchedulerTimerTask.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/Sequence.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/Sequence.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/SequenceSet.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/SequenceSet.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/StringMarshaller.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/StringMarshaller.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/disk/util/VariableMarshaller.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/VariableMarshaller.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/plist/PList.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/plist/PListEntry.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/plist/PListStore.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/ByteSequence.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/IOHelper.java
|
modified
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/LFUCache.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/LFUCache.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/LockFile.java
(Copied from activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/LockFile.java, r1406368)
|
added
, text changed
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/BTreeIndex.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/BTreeNode.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/BTreeVisitor.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/HashBin.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/HashIndex.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/Index.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/ListIndex.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/index/ListNode.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/CallerBufferingDataFileAppender.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/DataFile.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/DataFileAccessor.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/DataFileAccessorPool.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/DataFileAppender.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/FileAppender.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/Journal.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/Location.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/ReadOnlyDataFile.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/ReadOnlyJournal.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/ReplicationTarget.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/journal/package.html
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/package.html
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/page/Page.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/page/PageFile.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/page/Transaction.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/ByteArrayInputStream.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/ByteArrayOutputStream.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/ByteSequence.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/BytesMarshaller.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/CommandLineSupport.java
|
deleted
|
activemq/trunk/activemq-core/src/main/java/org/apache/kahadb/util/DataByteArrayInputStream.java
|
deleted
|
[...] |