List of recoverSubscription() Examples

Examples of recoverSubscription()

org.activemq.service.TopicMessageContainer.recoverSubscription()
A durable subscription has started so recovery any messages that are required. This method should find the last acknowledged message for the given subscription and then iterate through any further messages and those that match the subscription should be dispatched to this subscription so that they can be dispatched in the future @param subscription
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
org.codehaus.activemq.service.TopicMessageContainer.recoverSubscription()
A durable subscription has started so recovery any messages that are required. This method should find the last acknowledged message for the given subscription and then iterate through any further messages and those that match the subscription should be dispatched to this subscription so that they can be dispatched in the future @param subscription

Examples of org.activemq.service.TopicMessageContainer.recoverSubscription()

        
        getContainer(subscription.getDestination().getPhysicalName());
        Set containers = destinationMap.get(subscription.getDestination());
        for (Iterator iter = containers.iterator();iter.hasNext();) {
            TopicMessageContainer container = (TopicMessageContainer) iter.next();
            container.recoverSubscription(subscription);
        }
    }


    /**
     * Called when recovering a wildcard subscription where we need to load all the durable message containers (for

View Full Code Here

Examples of org.activemq.service.TopicMessageContainer.recoverSubscription()

        
        getContainer(subscription.getDestination().getPhysicalName());
        Set containers = destinationMap.get(subscription.getDestination());
        for (Iterator iter = containers.iterator();iter.hasNext();) {
            TopicMessageContainer container = (TopicMessageContainer) iter.next();
            container.recoverSubscription(subscription);
        }
    }


    /**
     * Called when recovering a wildcard subscription where we need to load all the durable message containers (for

View Full Code Here

Examples of org.activemq.service.TopicMessageContainer.recoverSubscription()

        
        getContainer(subscription.getDestination().getPhysicalName());
        Set containers = destinationMap.get(subscription.getDestination());
        for (Iterator iter = containers.iterator();iter.hasNext();) {
            TopicMessageContainer container = (TopicMessageContainer) iter.next();
            container.recoverSubscription(subscription);
        }
    }


    /**
     * Called when recovering a wildcard subscription where we need to load all the durable message containers (for

View Full Code Here

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


                    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

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


                    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

Examples of org.codehaus.activemq.service.TopicMessageContainer.recoverSubscription()

            getContainer(subscription.getDestination().getPhysicalName());
        }
        Set containers = destinationMap.get(subscription.getDestination());
        for (Iterator iter = containers.iterator();iter.hasNext();) {
            TopicMessageContainer container = (TopicMessageContainer) iter.next();
            container.recoverSubscription(subscription);
        }
    }


    /**
     * Called when recovering a wildcard subscription where we need to load all the durable message containers (for

View Full Code Here

Examples of org.codehaus.activemq.service.TopicMessageContainer.recoverSubscription()

            getContainer(subscription.getDestination().getPhysicalName());
        }
        Set containers = destinationMap.get(subscription.getDestination());
        for (Iterator iter = containers.iterator();iter.hasNext();) {
            TopicMessageContainer container = (TopicMessageContainer) iter.next();
            container.recoverSubscription(subscription);
        }
    }


    /**
     * Called when recovering a wildcard subscription where we need to load all the durable message containers (for

View Full Code Here

Examples of org.codehaus.activemq.service.TopicMessageContainer.recoverSubscription()

            // load the container
            getContainer(subscription.getDestination().getPhysicalName());
        }
        for (Iterator iter = messageContainers.values().iterator(); iter.hasNext();) {
            TopicMessageContainer container = (TopicMessageContainer) iter.next();
            container.recoverSubscription(subscription);
        }
    }




    /**

View Full Code Here

Examples of org.codehaus.activemq.service.TopicMessageContainer.recoverSubscription()

        
        getContainer(subscription.getDestination().getPhysicalName());
        Set containers = destinationMap.get(subscription.getDestination());
        for (Iterator iter = containers.iterator();iter.hasNext();) {
            TopicMessageContainer container = (TopicMessageContainer) iter.next();
            container.recoverSubscription(subscription);
        }
    }


    /**
     * Called when recovering a wildcard subscription where we need to load all the durable message containers (for

View Full Code Here

Examples of org.codehaus.activemq.service.TopicMessageContainer.recoverSubscription()

            getContainer(subscription.getDestination().getPhysicalName());
        }
        Set containers = destinationMap.get(subscription.getDestination());
        for (Iterator iter = containers.iterator();iter.hasNext();) {
            TopicMessageContainer container = (TopicMessageContainer) iter.next();
            container.recoverSubscription(subscription);
        }
    }


    /**
     * Called when recovering a wildcard subscription where we need to load all the durable message containers (for

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.