Package org.codehaus.activemq.service

Examples of org.codehaus.activemq.service.QueueList

121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
                    //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
218
219
220
221
222
223
224
225
226
227
228
229
    public void poll() throws JMSException {
        synchronized (subscriptionMutex) {
            for (Iterator iter = activeSubscriptions.keySet().iterator(); iter.hasNext();) {
                QueueMessageContainer container = (QueueMessageContainer) iter.next();

                QueueList browserList = (QueueList) browsers.get(container);
                doPeek(container, browserList);
                QueueList list = (QueueList) activeSubscriptions.get(container);
                doPoll(container, list);
            }
        }
    }
View Full Code Here
362
363
364
365
366
367
368
369
370
371
372
    private void updateActiveSubscriptions(QueueMessageContainer container, Subscription sub) throws JMSException {
        //need to do wildcards for this - but for now use exact matches
        //should change this for wild cards ...
        if (container.getDestinationName().equals(sub.getDestination().getPhysicalName())) {
            container.reset();//reset container - flushing all filter out messages to new consumer
            QueueList list = getSubscriptionList(container);
            if (!list.contains(sub)) {
                list.add(sub);
            }
        }
    }
View Full Code Here
370
371
372
373
374
375
376
377
378
379
380
            }
        }
    }

    private QueueList getSubscriptionList(QueueMessageContainer container) {
        QueueList list = (QueueList) activeSubscriptions.get(container);
        if (list == null) {
            list = new DefaultQueueList();
            activeSubscriptions.put(container, list);
        }
        return list;
View Full Code Here
383
384
385
386
387
388
389
390
391
392
393
    private void updateBrowsers(QueueMessageContainer container, Subscription sub) throws JMSException {
        //need to do wildcards for this - but for now use exact matches
        //should change this for wild cards ...
        if (container.getDestinationName().equals(sub.getDestination().getPhysicalName())) {
            container.reset();//reset container - flushing all filter out messages to new consumer
            QueueList list = getBrowserList(container);
            if (!list.contains(sub)) {
                list.add(sub);
            }
        }
    }
View Full Code Here
391
392
393
394
395
396
397
398
399
400
401
            }
        }
    }

    private QueueList getBrowserList(QueueMessageContainer container) {
        QueueList list = (QueueList) browsers.get(container);
        if (list == null) {
            list = new DefaultQueueList();
            browsers.put(container, list);
        }
        return list;
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
                    //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
267
268
269
270
271
272
273
274
275
276
277
278
    public void poll() throws JMSException {
        synchronized (subscriptionMutex) {
            for (Iterator iter = activeSubscriptions.keySet().iterator(); iter.hasNext();) {
                QueueMessageContainer container = (QueueMessageContainer) iter.next();

                QueueList browserList = (QueueList) browsers.get(container);
                doPeek(container, browserList);
                QueueList list = (QueueList) activeSubscriptions.get(container);
                doPoll(container, list);
            }
        }
    }
View Full Code Here
411
412
413
414
415
416
417
418
419
420
421
    private void updateActiveSubscriptions(QueueMessageContainer container, Subscription sub) throws JMSException {
        //need to do wildcards for this - but for now use exact matches
        //should change this for wild cards ...
        if (container.getDestinationName().equals(sub.getDestination().getPhysicalName())) {
            container.reset();//reset container - flushing all filter out messages to new consumer
            QueueList list = getSubscriptionList(container);
            if (!list.contains(sub)) {
                list.add(sub);
            }
        }
    }
View Full Code Here
419
420
421
422
423
424
425
426
427
428
429
            }
        }
    }

    private QueueList getSubscriptionList(QueueMessageContainer container) {
        QueueList list = (QueueList) activeSubscriptions.get(container);
        if (list == null) {
            list = new DefaultQueueList();
            activeSubscriptions.put(container, list);
        }
        return list;
View Full Code Here
TOP

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

  • org.codehaus.activemq.service.impl.DurableQueueMessageContainerManager
  • org.codehaus.activemq.service.impl.QueueMessageContainerManager
    • 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.