Package org.apache.qpid.server.subscription

Examples of org.apache.qpid.server.subscription.Subscription

837
838
839
840
841
842
843
844
845
846
847
848
849
850
    {
        Iterator<Subscription> subscriberIter = _subscriptionList.iterator();
        // iterate over all the subscribers, and if they are in advance of this queue entry then move them backwards
        while (subscriberIter.hasNext())
        {
            Subscription sub = subscriberIter.next();

            // we don't make browsers send the same stuff twice
            if (sub.seesRequeues() && (!sub.acquires() && sub == subscription))
            {
                updateSubRequeueEntry(sub, entry);
            }
        }
View Full Code Here
1415
1416
1417
1418
1419
1420
1421
1422
1423
1424
1425
1426
1427
1428
            Iterator<Subscription> subscriptionIter = _subscriptionList.iterator();

            while (subscriptionIter.hasNext())
            {
                Subscription s = subscriptionIter.next();
                if (s != null)
                {
                    s.queueDeleted(this);
                }
            }

            _virtualHost.getQueueRegistry().unregisterQueue(_name);
            getConfigStore().removeConfiguredObject(this);
View Full Code Here
1780
1781
1782
1783
1784
1785
1786
1787
1788
1789
1790
1791
    protected void advanceAllSubscriptions() throws AMQException
    {
        Iterator<Subscription> subscriberIter = _subscriptionList.iterator();
        while (subscriberIter.hasNext())
        {
            Subscription sub = subscriberIter.next();
            if(sub.acquires())
            {
                getNextAvailableEntry(sub);
            }
            else
            {
View Full Code Here
1868
1869
1870
1871
1872
1873
1874
1875
1876
1877
1878
1879
1880
1881
1882
1883
1884
1885
1886
1887
1888
1889
1890
1891
1892
1893
1894
1895
1896
1897
1898
1899
1900
1901
1902
1903
1904
1905
1906
1907
1908
1909
1910
            Iterator<Subscription> subscriptionIter = _subscriptionList.iterator();
            //iterate over the subscribers and try to advance their pointer
            while (subscriptionIter.hasNext())
            {
                Subscription sub = subscriptionIter.next();
                sub.getSendLock();
                try
                {

                    done = attemptDelivery(sub);

                    if (done)
                    {
                        if (extraLoops == 0)
                        {
                            deliveryIncomplete = false;
                            if (sub.isAutoClose())
                            {
                                unregisterSubscription(sub);

                                sub.confirmAutoClose();
                            }
                        }
                        else
                        {
                            extraLoops--;
                        }
                    }
                    else
                    {
                        iterations--;
                        extraLoops = 1;
                    }
                }
                finally
                {
                    sub.releaseSendLock();
                }
            }
            _asynchronousRunner.set(null);
        }
View Full Code Here
434
435
436
437
438
439
440
441
442
443
444
        if (_tag2SubscriptionMap.containsKey(tag))
        {
            throw new AMQException("Consumer already exists with same tag: " + tag);
        }
       
         Subscription subscription =
                SubscriptionFactoryImpl.INSTANCE.createSubscription(_channelId, _session, tag, acks, filters, noLocal, _creditManager);


        // So to keep things straight we put before the call and catch all exceptions from the register and tidy up.
        // We add before we register as the Async Delivery process may AutoClose the subscriber
View Full Code Here
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
     * @throws AMQException
     */
    public boolean unsubscribeConsumer(AMQShortString consumerTag) throws AMQException
    {

        Subscription sub = _tag2SubscriptionMap.remove(consumerTag);
        if (sub != null)
        {
            try
            {
                sub.getSendLock();
                sub.getQueue().unregisterSubscription(sub);
            }
            finally
            {
                sub.releaseSendLock();
            }
            return true;
        }
        else
        {
View Full Code Here
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
            if (_logger.isInfoEnabled())
            {
                _logger.info("Unsubscribing consumer '" + me.getKey() + "' on channel " + toString());
            }

            Subscription sub = me.getValue();

            try
            {
                sub.getSendLock();
                sub.getQueue().unregisterSubscription(sub);
            }
            finally
            {
                sub.releaseSendLock();
            }

        }

        _tag2SubscriptionMap.clear();
View Full Code Here
743
744
745
746
747
748
749
750
751
752
753
            // Without any details from the client about what has been processed we have to mark
            // all messages in the unacked map as redelivered.
            message.setRedelivered();

            Subscription sub = message.getDeliveredSubscription();

            if (sub != null)
            {

                if(!queue.resend(message,sub))
View Full Code Here
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
        postRollbackTask.run();

        for(QueueEntry entry : _resendList)
        {
            Subscription sub = entry.getDeliveredSubscription();
            if(sub == null || sub.isClosed())
            {
                entry.release();
            }
            else
            {
                sub.getQueue().resend(entry, sub);
            }
        }
        _resendList.clear();

        if(requiresSuspend)
        {
            _suspended.set(false);
            for(Subscription sub : _tag2SubscriptionMap.values())
            {
                sub.getQueue().deliverAsync(sub);
            }

        }

View Full Code Here
1071
1072
1073
1074
1075
1076
1077
1078
1079
1080
1081
1082
1083
1084
            SubscriptionList.SubscriptionNodeIterator subscriptionIter = _subscriptionList.iterator();

            while (subscriptionIter.advance())
            {
                Subscription s = subscriptionIter.getNode().getSubscription();
                if (s != null)
                {
                    s.queueDeleted(this);
                }
            }

            _bindings.deregister();
            _virtualHost.getQueueRegistry().unregisterQueue(_name);
View Full Code Here
TOP

Related Classes of org.apache.qpid.server.subscription.Subscription

  • org.apache.qpid.server.AMQChannel
  • org.apache.qpid.server.ExtractResendAndRequeue
  • org.apache.qpid.server.ExtractResendAndRequeueTest
  • org.apache.qpid.server.handler.BasicGetMethodHandler
  • org.apache.qpid.server.management.plugin.servlet.rest.MessageServlet
  • org.apache.qpid.server.protocol.v0_8.AMQChannel
  • org.apache.qpid.server.protocol.v0_8.ExtractResendAndRequeue
  • org.apache.qpid.server.protocol.v0_8.ExtractResendAndRequeueTest
  • org.apache.qpid.server.protocol.v0_8.handler.BasicGetMethodHandler
  • org.apache.qpid.server.protocol.v0_8.SubscriptionFactoryImplTest
    • 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.