Package org.codehaus.activemq.service

Examples of org.codehaus.activemq.service.Subscription


        if (log.isDebugEnabled()) {
            log.debug("Removing consumer: " + info);
        }
        if (info.getDestination() != null && info.getDestination().isQueue()) {
            synchronized (subscriptionMutex) {
                Subscription sub = (Subscription) subscriptionContainer.removeSubscription(info.getConsumerId());
                if (sub != null) {
                    sub.setActive(false);
                    sub.clear();//resets entries in the QueueMessageContainer
                    dispatcher.removeActiveSubscription(client, sub);
                    //need to do wildcards for this - but for now use exact matches
                    for (Iterator iter = messageContainers.values().iterator(); iter.hasNext();) {
                        QueueMessageContainer container = (QueueMessageContainer) iter.next();
                        //should change this for wild cards ...
                        if (container.getDestinationName().equals(sub.getDestination().getPhysicalName())) {
                            QueueList list = getSubscriptionList(container);
                            list.remove(sub);
                            if (list.isEmpty()) {
                                activeSubscriptions.remove(sub.getDestination().getPhysicalName());
                            }
                            list = getBrowserList(container);
                            list.remove(sub);
                            if (list.isEmpty()) {
                                browsers.remove(sub.getDestination().getPhysicalName());
                            }
                        }
                    }
                }
            }
View Full Code Here


      // Are we not intrested in handling that destination?
        if( !isManagerFor(ack.getDestination(), ack.isPersistent()) ) {
          return;
        }

        Subscription sub = subscriptionContainer.getSubscription(ack.getConsumerId());
        if (sub != null) {
            sub.messageConsumed(ack);
            if (ack.isMessageRead()) {
                updateAcknowledgeStats(client, sub);
            }
        }
    }
View Full Code Here

    public Subscription getSubscription(String consumerId) {
        return (Subscription) subscriptions.get(consumerId);
    }

    public Subscription removeSubscription(String consumerId) {
        Subscription subscription = (Subscription) subscriptions.remove(consumerId);
        if (subscription != null) {
            destinationIndex.remove(subscription.getDestination(), subscription);
        }
        return subscription;
    }
View Full Code Here

    public Iterator subscriptionIterator() {
        return subscriptions.values().iterator();
    }

    public Subscription makeSubscription(Dispatcher dispatcher,BrokerClient client, ConsumerInfo info, Filter filter) {
        Subscription subscription = createSubscription(dispatcher, client,info, filter);
        subscriptions.put(info.getConsumerId(), subscription);
        destinationIndex.put(subscription.getDestination(), subscription);
        return subscription;
    }
View Full Code Here

    }

    public void removeMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException {
        // we should not remove a durable topic subscription from the subscriptionContainer
        // unless via the deleteSubscription() method
        Subscription sub = (Subscription) activeSubscriptions.remove(info.getConsumerId());
        if (sub != null) {
            sub.setActive(false);
            dispatcher.removeActiveSubscription(client, sub);
        }
    }
View Full Code Here

     * @throws javax.jms.JMSException if the subscriber doesn't exist or is still active
     */
    public void deleteSubscription(String clientId, String subscriberName) throws JMSException {
        boolean subscriptionFound = false;
        for (Iterator i = subscriptionContainer.subscriptionIterator();i.hasNext();) {
            Subscription sub = (Subscription) i.next();
            if (sub.getClientId().equals(clientId) && sub.getSubscriberName().equals(subscriberName)) {
                //only delete if not active
                if (sub.isActive()) {
                    throw new JMSException("The Consummer " + subscriberName + " is still active");
                }
                else {
                    subscriptionContainer.removeSubscription(sub.getConsumerId());
                    sub.clear();
                    subscriptionFound = true;
                   
                    Set containers = destinationMap.get(sub.getDestination());
                    for (Iterator iter = containers.iterator();iter.hasNext();) {
                        TopicMessageContainer container = (TopicMessageContainer) iter.next();
                        if (container instanceof DurableTopicMessageContainer) {
                            ((DurableTopicMessageContainer) container).deleteSubscription(sub.getPersistentKey());
                        }
                    }
                   
                }
            }
View Full Code Here

     */
    private void doSendMessage(BrokerClient client, ActiveMQMessage message, MessageContainer container) throws JMSException {
        Set matchingSubscriptions = subscriptionContainer.getSubscriptions(message.getJMSActiveMQDestination());
        if (!matchingSubscriptions.isEmpty()) {
            for (Iterator i = matchingSubscriptions.iterator();i.hasNext();) {
                Subscription sub = (Subscription) i.next();
                if (sub.isTarget(message)) {
                    sub.addMessage(container, message);
                }
            }
            updateSendStats(client, message);
        }       
    }
View Full Code Here

     * @return
     */
    public Map getLocalDestinations() {
        Map localDestinations = new HashMap();
        for (Iterator iter = subscriptionContainer.subscriptionIterator(); iter.hasNext();) {
            Subscription sub = (Subscription) iter.next();
            if (sub.isLocalSubscription()) {
                final ActiveMQDestination dest = sub.getDestination();
                localDestinations.put(dest.getPhysicalName(), dest);
            }
        }
        return Collections.unmodifiableMap(localDestinations);
    }
View Full Code Here

     */
    public void acknowledgeMessage(BrokerClient client, final MessageAck ack) throws JMSException {
        if ( !ack.getDestination().isTopic() )
            return;
           
        Subscription sub = (Subscription) activeSubscriptions.get(ack.getConsumerId());
        if (sub == null)
            return;
       
        sub.messageConsumed(ack);
    }
View Full Code Here

    protected void doAddMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException {
        boolean shouldRecover = false;
        if (info.getConsumerName() != null && info.getClientId() != null) {
            for (Iterator iter = activeSubscriptions.values().iterator();iter.hasNext();) {
                Subscription subscription = (Subscription) iter.next();
                if (subscription.isSameDurableSubscription(info)) {
                    throw new DuplicateDurableSubscriptionException(info);
                }
            }
        }
        Subscription subscription = subscriptionContainer.getSubscription(info.getConsumerId());
        if (subscription != null && subscription.isDurableTopic()) {
            //check the subscription hasn't changed
            if (!subscription.getDestination().equals(subscription.getDestination())
                    || !subscription.getSelector().equals(info.getSelector())) {
                subscriptionContainer.removeSubscription(info.getConsumerId());
                subscription.clear();
                subscription = subscriptionContainer.makeSubscription(dispatcher, client,info, createFilter(info));
            }
        }
        else {
            subscription = subscriptionContainer.makeSubscription(dispatcher, client,info, createFilter(info));
            shouldRecover = true;
        }
        subscription.setActiveConsumer(client,info);
        activeSubscriptions.put(info.getConsumerId(), subscription);
        dispatcher.addActiveSubscription(client, subscription);
        if (subscription.isWildcard()) {
            synchronized (this) {
                if (!loadedMessageContainers) {
                    loadAllMessageContainers();
                    loadedMessageContainers = true;
                }
            }
        }
        else {
            // load the container
            getContainer(subscription.getDestination().getPhysicalName());
        }
        Set containers = destinationMap.get(subscription.getDestination());
        for (Iterator iter = containers.iterator();iter.hasNext();) {
            TopicMessageContainer container = (TopicMessageContainer) iter.next();
            if (container instanceof DurableTopicMessageContainer) {
                ((DurableTopicMessageContainer) container).storeSubscription(info, subscription);
            }
        }
        if (shouldRecover) {
            recoverSubscriptions(subscription);
        }
        // lets not make the subscription active until later
        // as we can't start dispatching until we've sent back the receipt
        // TODO we might wish to register a post-receipt action here
        // to perform the wakeup
        subscription.setActive(true);
        //dispatcher.wakeup(subscription);
    }
View Full Code Here

TOP

Related Classes of org.codehaus.activemq.service.Subscription

Copyright © 2018 www.massapicom. All rights reserved.
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.