Examples of org.apache.activemq.store.TopicMessageStore.recoverSubscription()

Class org.apache.activemq.store.TopicMessageStore

Examples of org.apache.activemq.store.TopicMessageStore.recoverSubscription()

org.apache.activemq.store.TopicMessageStore.recoverSubscription()
For the new subscription find the last acknowledged message ID and then find any new messages since then and dispatch them to the subscription.
e.g. if we dispatched some messages to a new durable topic subscriber, then went down before acknowledging any messages, we need to know the correct point from which to recover from. @param clientId @param subscriptionName @param listener @param subscription @throws Exception


                    destRecord.setBindingData(new UTF8Buffer(json));
                    manager.store_queue(destRecord);


                    final long seqKeyCounter[] = new long[]{0};
                    topic.recoverSubscription(sub.getClientId(), sub.getSubscriptionName(), new MessageRecoveryListener() {
                        @Override
                        public boolean hasSpace() {
                            return true;
                        }

View Full Code Here


                    destRecord.setBindingData(new UTF8Buffer(json));
                    manager.store_queue(destRecord);


                    final long seqKeyCounter[] = new long[]{0};
                    topic.recoverSubscription(sub.getClientId(), sub.getSubscriptionName(), new MessageRecoveryListener() {
                        @Override
                        public boolean hasSpace() {
                            return true;
                        }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.