org.apache.activemq.store.leveldb
Class ReplicatedLevelDBPersistenceAdapter

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.broker.LockableServiceSupport
          extended by org.apache.activemq.leveldb.replicated.ProxyLevelDBStore
              extended by org.apache.activemq.leveldb.replicated.ElectingLevelDBStore
                  extended by org.apache.activemq.store.leveldb.ReplicatedLevelDBPersistenceAdapter
All Implemented Interfaces:
BrokerServiceAware, Lockable, Service, PersistenceAdapter, PListStore, TransactionStore, scala.ScalaObject

public class ReplicatedLevelDBPersistenceAdapter
extends org.apache.activemq.leveldb.replicated.ElectingLevelDBStore
implements PersistenceAdapter

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


Field Summary
 
Fields inherited from class org.apache.activemq.broker.LockableServiceSupport
brokerService
 
Constructor Summary
ReplicatedLevelDBPersistenceAdapter()
           
 
Method Summary
 
Methods inherited from class org.apache.activemq.leveldb.replicated.ElectingLevelDBStore
address, asyncBufferSize_$eq, asyncBufferSize, bind_$eq, bind, brokerName_$eq, brokerName, clusterSizeQuorum, configure, container_$eq, container, create_master, create_slave, createDefaultLocker, debug, debug, debug, deleteAllMessages, directory_$eq, directory, doStart, doStop, error, error, error, failoverProducersAuditDepth_$eq, failoverProducersAuditDepth, flushDelay_$eq, flushDelay, getAsyncBufferSize, getBind, getContainer, getDirectory, getFailoverProducersAuditDepth, getFlushDelay, getHostname, getIndexBlockRestartInterval, getIndexBlockSize, getIndexCacheSize, getIndexCompression, getIndexFactory, getIndexMaxOpenFiles, getIndexWriteBufferSize, getLogCompression, getLogSize, getMaxFailoverProducersToTrack, getMonitorStats, getParanoidChecks, getReplicas, getSecurityToken, getSync, getVerifyChecksums, getWeight, getZkAddress, getZkPassword, getZkPath, getZkSessionTmeout, hostname_$eq, hostname, 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, isMaster, log, logCompression_$eq, logCompression, logSize_$eq, logSize, machine_hostname, master_$eq, master_started_latch, master_started, master_stopped, master, maxFailoverProducersToTrack_$eq, maxFailoverProducersToTrack, monitorStats_$eq, monitorStats, node_id, objectName, org$apache$activemq$leveldb$util$Log$_setter_$log_$eq, paranoidChecks_$eq, paranoidChecks, position_$eq, position, protected$brokerService, proxy_target, proxy_target, replicas_$eq, replicas, securityToken_$eq, securityToken, setAsyncBufferSize, setBind, setBrokerName, setContainer, setDirectory, setFailoverProducersAuditDepth, setFlushDelay, setHostname, setIndexBlockRestartInterval, setIndexBlockSize, setIndexCacheSize, setIndexCompression, setIndexFactory, setIndexMaxOpenFiles, setIndexWriteBufferSize, setLogCompression, setLogSize, setMaxFailoverProducersToTrack, setMonitorStats, setParanoidChecks, setReplicas, setSecurityToken, setSync, setUsageManager, setVerifyChecksums, setWeight, setZkAddress, setZkPassword, setZkPath, setZkSessionTmeout, size, slave_$eq, slave, start_master, start_slave, stop_master, stop_slave, stopped_latch, sync_$eq, sync, trace, trace, trace, usageManager_$eq, usageManager, verifyChecksums_$eq, verifyChecksums, warn, warn, warn, weight_$eq, weight, zk_client_$eq, zk_client, zk_group_$eq, zk_group, zkAddress_$eq, zkAddress, zkPassword_$eq, zkPassword, zkPath_$eq, zkPath, zkSessionTmeout_$eq, zkSessionTmeout
 
Methods inherited from class org.apache.activemq.leveldb.replicated.ProxyLevelDBStore
beginTransaction, checkpoint, commit, commitTransaction, createQueueMessageStore, createTopicMessageStore, createTransactionStore, getDestinations, getLastMessageBrokerSequenceId, getLastProducerSequenceId, getPList, prepare, recover, removePList, removeQueueMessageStore, removeTopicMessageStore, rollback, rollbackTransaction
 
Methods inherited from class org.apache.activemq.broker.LockableServiceSupport
getBrokerService, getLocker, getLockKeepAlivePeriod, getScheduledThreadPoolExecutor, isUseLock, 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, toString, wait, wait, wait
 
Methods inherited from interface org.apache.activemq.store.PersistenceAdapter
beginTransaction, checkpoint, commitTransaction, createQueueMessageStore, createTopicMessageStore, createTransactionStore, deleteAllMessages, getDestinations, getDirectory, getLastMessageBrokerSequenceId, getLastProducerSequenceId, removeQueueMessageStore, removeTopicMessageStore, rollbackTransaction, setBrokerName, setDirectory, setUsageManager, size
 
Methods inherited from interface org.apache.activemq.Service
start, stop
 
Methods inherited from interface org.apache.activemq.broker.BrokerServiceAware
setBrokerService
 

Constructor Detail

ReplicatedLevelDBPersistenceAdapter

public ReplicatedLevelDBPersistenceAdapter()


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.