kaha implementation of message persistence for the broker
AMQTxMarshaller | Marshall an AMQTx | code | html |
AtomicIntegerMarshaller | Marshall an AtomicInteger | code | html |
ConsumerMessageRef | Holds information for location of message | code | html |
ConsumerMessageRefMarshaller | Marshall a TopicSubAck | code | html |
IntegerMarshaller | Marshall an Integer | code | html |
KahaMessageStore | An implementation of org.apache.activemq.store.MessageStore which uses a JPS Container | code | html |
KahaPersistenceAdapter | code | html | |
KahaReferenceStore | code | html | |
KahaReferenceStoreAdapter | Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. | code | html |
KahaTopicMessageStore | code | html | |
KahaTopicReferenceStore | Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. | code | html |
KahaTransaction | Stores a messages/acknowledgements for a transaction | code | html |
KahaTransactionStore | Provides a TransactionStore implementation that can create transaction aware MessageStore objects from non transaction aware MessageStore objects. | code | html |
ReferenceRecord | Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. | code | html |
ReferenceRecordMarshaller | Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. | code | html |
StoreEntryMarshaller | Marshall a TopicSubAck | code | html |
TopicSubAck | Holds information for location of message | code | html |
TopicSubAckMarshaller | Marshall a TopicSubAck | code | html |
TopicSubContainer | Holds information for the subscriber | code | html |
TransactionMarshaller | Marshall a Transaction | code | html |
TxCommand | Base class for messages/acknowledgements for a transaction | code | html |