org.apache.activemq.store.leveldb
Class LevelDBPersistenceAdapter

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.broker.LockableServiceSupport
          extended by org.apache.activemq.leveldb.LevelDBStore
              extended by org.apache.activemq.store.leveldb.LevelDBPersistenceAdapter
All Implemented Interfaces:
BrokerServiceAware, Lockable, Service, PersistenceAdapter, PListStore, TransactionStore

public class LevelDBPersistenceAdapter
extends org.apache.activemq.leveldb.LevelDBStore

An implementation of PersistenceAdapter designed for use with LevelDB - Embedded Lightweight Non-Relational Database


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.activemq.leveldb.LevelDBStore
org.apache.activemq.leveldb.LevelDBStore.LevelDBMessageStore, org.apache.activemq.leveldb.LevelDBStore.LevelDBMessageStore$, org.apache.activemq.leveldb.LevelDBStore.LevelDBPList, org.apache.activemq.leveldb.LevelDBStore.LevelDBTopicMessageStore, org.apache.activemq.leveldb.LevelDBStore.LimitingRecoveryListener, org.apache.activemq.leveldb.LevelDBStore.LimitingRecoveryListener$, org.apache.activemq.leveldb.LevelDBStore.Transaction, org.apache.activemq.leveldb.LevelDBStore.Transaction$, org.apache.activemq.leveldb.LevelDBStore.TransactionAction
 
Field Summary
 
Fields inherited from class org.apache.activemq.broker.LockableServiceSupport
brokerService
 
Constructor Summary
LevelDBPersistenceAdapter()
           
 
Method Summary
 
Methods inherited from class org.apache.activemq.leveldb.LevelDBStore
$enable_assertions, asyncBufferSize_$eq, asyncBufferSize, beginTransaction, broker_service, checkpoint, commit, commitTransaction, createClient, createDefaultLocker, createMessageStore, createPList, createQueueMessageStore, createQueueMessageStore, createSubscription, createTopicMessageStore, createTopicMessageStore, createTransactionStore, db, debug, debug, debug, DEFAULT_DIRECTORY, deleteAllMessages, directory_$eq, directory, doingRecover_$eq, doingRecover, DONE, doStart, doStop, error, error, error, flushDelay_$eq, flushDelay, getAsyncBufferSize, getDestinations, getDirectory, getFlushDelay, getIndexBlockRestartInterval, getIndexBlockSize, getIndexCacheSize, getIndexCompression, getIndexFactory, getIndexMaxOpenFiles, getIndexWriteBufferSize, getLastMessageBrokerSequenceId, getLastProducerSequenceId, getLogAppendPosition, getLogCompression, getLogDirectory, getLogSize, getMonitorStats, getParanoidChecks, getPList, getSync, getTopicGCPositions, getVerifyChecksums, indexBlockRestartInterval_$eq, indexBlockRestartInterval, indexBlockSize_$eq, indexBlockSize, indexCacheSize_$eq, indexCacheSize, indexCompression_$eq, indexCompression, indexFactory_$eq, indexFactory, indexMaxOpenFiles_$eq, indexMaxOpenFiles, indexWriteBufferSize_$eq, indexWriteBufferSize, info, info, info, init, LevelDBMessageStore, LimitingRecoveryListener, log, logCompression_$eq, logCompression, logDirectory_$eq, logDirectory, logSize_$eq, logSize, monitorStats_$eq, monitorStats, objectName, org$apache$activemq$leveldb$util$Log$_setter_$log_$eq, paranoidChecks_$eq, paranoidChecks, plists, prepare, purgeOnStatup_$eq, purgeOnStatup, queues, recover, removePList, removeQueueMessageStore, removeTopicMessageStore, retry, rollback, rollbackTransaction, setAsyncBufferSize, setBrokerName, setDirectory, setFlushDelay, setIndexBlockRestartInterval, setIndexBlockSize, setIndexCacheSize, setIndexCompression, setIndexFactory, setIndexMaxOpenFiles, setIndexWriteBufferSize, setLogCompression, setLogDirectory, setLogSize, setMonitorStats, setParanoidChecks, setSync, setUsageManager, setVerifyChecksums, size, snappyCompressLogs_$eq, snappyCompressLogs, sync_$eq, sync, toIOException, topics, topicsById, toString, trace, trace, trace, Transaction, transaction, transactions, verifyChecksums_$eq, verifyChecksums, waitOn, warn, warn, warn, wireFormat, withUow
 
Methods inherited from class org.apache.activemq.broker.LockableServiceSupport
getLocker, getScheduledThreadPoolExecutor, keepLockAlive, postStop, preStart, setBrokerService, setLocker, setLockKeepAlivePeriod, setUseLock, stopBroker
 
Methods inherited from class org.apache.activemq.util.ServiceSupport
addServiceListener, dispose, isStarted, isStopped, isStopping, removeServiceListener, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.activemq.Service
start, stop
 

Constructor Detail

LevelDBPersistenceAdapter

public LevelDBPersistenceAdapter()


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.