Examples of disposition()

Examples of org.apache.qpid.proton.engine.Delivery.disposition()

721
722
723
724
725
726
727
728
729
730
731
            Link link = delivery.getLink();
            if (delivery.isUpdated())
            {
                if (link instanceof Sender)
                {
                    delivery.disposition(delivery.getRemoteState());
                }
                StoreEntry e = (StoreEntry) delivery.getContext();
                if (e != null) e.updated();
            }
View Full Code Here

Examples of org.apache.qpid.proton.engine.Delivery.disposition()

537
538
539
540
541
542
543
544
545
546
547
        Delivery delivery = connection.getWorkHead();
        while (delivery != null)
        {
            if (delivery.getLink() instanceof Sender && delivery.isUpdated())
            {
                delivery.disposition(delivery.getRemoteState());
            }
            //TODO: delivery.clear(); What's the equivalent in java?
            delivery = delivery.getWorkNext();
        }
        _outgoing.slide();
View Full Code Here

Examples of org.apache.qpid.proton.engine.Delivery.disposition()

138
139
140
141
142
143
144
145
146
147
148
                    throw new RuntimeException("Inconsistent state, empty delivery queue but lwm=" + _lwm + " and hwm=" + _hwm);
                }
                Delivery d = _deliveries.get(0);
                if (d.getLocalState() == null)
                {
                    d.disposition(ACCEPTED);
                }

                d.settle();
                _deliveries.remove(0);
                _lwm++;
View Full Code Here

Examples of org.apache.qpid.proton.engine.Delivery.disposition()

243
244
245
246
247
248
249
250
251
252
253
        Delivery clientDelivery = _client.connection.getWorkHead();
        assertEquals(_client.delivery, clientDelivery);
        assertTrue(clientDelivery.isUpdated());
        assertEquals(_client.sender, clientDelivery.getLink());
        clientDelivery.disposition(clientDelivery.getRemoteState());
        assertEquals(Accepted.getInstance(), _client.delivery.getLocalState());

        clientDelivery.settle();
        assertNull("Now we've settled, the delivery should no longer be in the work list", _client.connection.getWorkHead());
View Full Code Here

Examples of org.apache.qpid.proton.engine.Delivery.disposition()

444
445
446
447
448
449
450
451
452
453
454
            Delivery delivery = connection.getWorkHead();
            while (delivery != null)
            {
                if (delivery.getLink() instanceof Sender && delivery.isUpdated())
                {
                    delivery.disposition(delivery.getRemoteState());
                }
                //TODO: delivery.clear(); What's the equivalent in java?
                delivery = delivery.getWorkNext();
            }
            _outgoing.slide();
View Full Code Here

Examples of org.apache.qpid.proton.engine.Delivery.disposition()

138
139
140
141
142
143
144
145
146
147
148
                    throw new RuntimeException("Inconsistent state, empty delivery queue but lwm=" + _lwm + " and hwm=" + _hwm);
                }
                Delivery d = _deliveries.get(0);
                if (d.getLocalState() == null)
                {
                    d.disposition(ACCEPTED);
                }

                d.settle();
                _deliveries.remove(0);
                _lwm++;
View Full Code Here

Examples of org.apache.qpid.proton.engine.Delivery.disposition()

769
770
771
772
773
774
775
776
777
778
779
            Link link = delivery.getLink();
            if (delivery.isUpdated())
            {
                if (link instanceof Sender)
                {
                    delivery.disposition(delivery.getRemoteState());
                }
                StoreEntry e = (StoreEntry) delivery.getContext();
                if (e != null) e.updated();
            }
View Full Code Here

Examples of org.apache.qpid.proton.engine.Delivery.disposition()

140
141
142
143
144
145
146
147
148
149
150
                {
                    _tracked.remove( old.getId() );
                    Delivery d = old.getDelivery();
                    if (d != null) {
                        if (d.getLocalState() == null)
                            d.disposition(ACCEPTED);
                        d.settle();
                    }
                }
                _lwm++;
            }
View Full Code Here

Examples of org.apache.qpid.proton.engine.Delivery.disposition()

166
167
168
169
170
171
172
173
174
175
176
                {
                    if (d.getLocalState() == null)
                    {
                        if (match)
                        {
                            d.disposition(d.getRemoteState());
                        }
                        else
                        {
                            switch (status)
                            {
View Full Code Here

Examples of org.apache.qpid.proton.engine.Delivery.disposition()

173
174
175
176
177
178
179
180
181
182
183
                        else
                        {
                            switch (status)
                            {
                            case ACCEPTED:
                                d.disposition(ACCEPTED);
                                break;
                            case REJECTED:
                                d.disposition(REJECTED);
                                break;
                            default:
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.