Package org.codehaus.activemq.service

Examples of org.codehaus.activemq.service.Subscription.clear()

104
105
106
107
108
109
110
111
112
113
114
                if (sub.isActive()) {
                    throw new JMSException("The Consummer " + subscriberName + " is still active");
                }
                else {
                    subscriptionContainer.removeSubscription(sub.getConsumerId());
                    sub.clear();
                    subscriptionFound = true;
                }
            }
        }
        if (!subscriptionFound) {
View Full Code Here
223
224
225
226
227
228
229
230
231
232
233
        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));
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
        Subscription sub = (Subscription) activeSubscriptions.remove(info.getConsumerId());
        if (sub != null) {
            sub.setActive(false);
            dispatcher.removeActiveSubscription(client, sub);
            subscriptionContainer.removeSubscription(info.getConsumerId());
            sub.clear();
        }
    }


    /**
 
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
        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 ...
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
        Subscription sub = (Subscription) activeSubscriptions.remove(info.getConsumerId());
        if (sub != null) {
            sub.setActive(false);
            dispatcher.removeActiveSubscription(client, sub);
            subscriptionContainer.removeSubscription(info.getConsumerId());
            sub.clear();
        }
    }


    /**
 
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
        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 ...
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
                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();
View Full Code Here
253
254
255
256
257
258
259
260
261
262
263
        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));
View Full Code Here
173
174
175
176
177
178
179
180
181
182
183
        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 ...
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
        Subscription sub = (Subscription) activeSubscriptions.remove(info.getConsumerId());
        if (sub != null) {
            sub.setActive(false);
            dispatcher.removeActiveSubscription(client, sub);
            subscriptionContainer.removeSubscription(info.getConsumerId());
            sub.clear();
        }
    }


    /**
 
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.