Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » store » kahadaptor » [javadoc | source]
org.apache.activemq.store.kahadaptor
public class: KahaReferenceStoreAdapter [javadoc | source]
java.lang.Object
   org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter
      org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter

All Implemented Interfaces:
    ReferenceStoreAdapter, BrokerServiceAware, PersistenceAdapter

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Fields inherited from org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter:
wireFormat,  transactionStore,  topics,  queues,  messageStores
Constructor:
 public KahaReferenceStoreAdapter(AtomicLong size) 
Method from org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter Summary:
addInterestInRecordFile,   addSubscriberState,   clearMessages,   commitTransaction,   createQueueMessageStore,   createQueueReferenceStore,   createTopicMessageStore,   createTopicReferenceStore,   deleteAllMessages,   getIndexBinSize,   getIndexKeySize,   getIndexLoadFactor,   getIndexMaxBinSize,   getIndexPageSize,   getMapReferenceContainer,   getReferenceFileIdsInUse,   getStateStore,   isPersistentIndex,   isStoreValid,   recoverState,   recoverSubscription,   removeInterestInRecordFile,   removeReferenceStore,   removeSubscriberState,   retrievePreparedState,   savePreparedState,   setDirectory,   setIndexBinSize,   setIndexKeySize,   setIndexLoadFactor,   setIndexMaxBinSize,   setIndexPageSize,   setPersistentIndex,   start,   stop
Methods from org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter:
beginTransaction,   checkpoint,   commitTransaction,   createMessageMarshaller,   createQueueMessageStore,   createStore,   createTopicMessageStore,   createTransactionStore,   deleteAllMessages,   getBrokerName,   getDestinations,   getDirectory,   getLastMessageBrokerSequenceId,   getListContainer,   getMapContainer,   getMaxDataFileLength,   getStore,   getSubsMapContainer,   isPersistentIndex,   removeQueueMessageStore,   removeTopicMessageStore,   retrieveMessageStore,   rollbackTransaction,   setBrokerName,   setBrokerService,   setDirectory,   setMaxDataFileLength,   setPersistentIndex,   setUsageManager,   size,   start,   stop,   toString
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter Detail:
 synchronized  void addInterestInRecordFile(int recordNumber) 
 protected  void addSubscriberState(SubscriptionInfo info) throws IOException 
 public  void clearMessages() throws IOException 
 public  void commitTransaction(ConnectionContext context) throws IOException 
 public synchronized MessageStore createQueueMessageStore(ActiveMQQueue destination) throws IOException 
 public ReferenceStore createQueueReferenceStore(ActiveMQQueue destination) throws IOException 
 public synchronized TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws IOException 
 public TopicReferenceStore createTopicReferenceStore(ActiveMQTopic destination) throws IOException 
 public  void deleteAllMessages() throws IOException 
 public int getIndexBinSize() 
 public int getIndexKeySize() 
 public int getIndexLoadFactor() 
 public int getIndexMaxBinSize() 
 public int getIndexPageSize() 
 protected MapContainer<MessageId, ReferenceRecord> getMapReferenceContainer(Object id,
    String containerName) throws IOException 
 public synchronized Set<Integer> getReferenceFileIdsInUse() throws IOException 
 protected synchronized Store getStateStore() throws IOException 
 public boolean isPersistentIndex() 
 public boolean isStoreValid() 
 public  void recoverState() throws IOException 
 public  void recoverSubscription(SubscriptionInfo info) throws IOException 
 synchronized  void removeInterestInRecordFile(int recordNumber) 
 public  void removeReferenceStore(KahaReferenceStore referenceStore) 
 protected  void removeSubscriberState(SubscriptionInfo info) 
 public Map<TransactionId, AMQTx> retrievePreparedState() throws IOException 
 public  void savePreparedState(Map<TransactionId, AMQTx> map) throws IOException 
 public synchronized  void setDirectory(File directory) 
 public  void setIndexBinSize(int indexBinSize) 
 public  void setIndexKeySize(int indexKeySize) 
 public  void setIndexLoadFactor(int loadFactor) 
 public  void setIndexMaxBinSize(int maxBinSize) 
 public  void setIndexPageSize(int indexPageSize) 
 public  void setPersistentIndex(boolean persistentIndex) 
 public synchronized  void start() throws Exception 
 public synchronized  void stop() throws Exception