/[Apache-SVN]
ViewVC logotype

Revision 1784178

Jump to revision: Previous Next
Author: orudyy
Date: Thu Feb 23 17:11:04 2017 UTC (7 years, 3 months ago)
Changed paths: 52
Log Message: 
QPID-7618: [Java Broker] Introduce overflow policy for producer flow control and move existing producer flow control functionality into overflow policy handler

Changed paths

Path Details
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/logging/messages/QueueMessages.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/logging/messages/Queue_logmessages.properties modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/message/RoutingResult.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/model/OverflowPolicy.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/model/Queue.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/protocol/CapacityChecker.java deleted
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/LastValueQueueList.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/NoneOverflowPolicyHandler.java added
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/NoneOverflowPolicyHandlerFactory.java added
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/OverflowPolicyHandler.java
(Copied from qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/protocol/CapacityChecker.java, r1784177) 		added , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/OverflowPolicyHandlerFactory.java added
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/PriorityQueueList.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlOverflowPolicyHandler.java added
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlOverflowPolicyHandlerFactory.java added
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/QueueEntryList.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/RingOverflowPolicyHandler.java added
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/RingOverflowPolicyHandlerFactory.java added
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/SortedQueueEntryList.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/StandardQueueEntryList.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/store/VirtualHostStoreUpgraderAndRecoverer.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/AbstractQueueTestBase.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/LastValueQueueListTest.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/PriorityQueueListTest.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/ProducerFlowControlOverflowPolicyHandlerTest.java added
Directoryqpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/RingOverflowPolicyHandlerTest.java added
Directoryqpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/SortedQueueEntryListTest.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/StandardQueueEntryListTest.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/StandardQueueTest.java modified , text changed
Directoryqpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/store/VirtualHostStoreUpgraderAndRecovererTest.java added
Directoryqpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerSession.java modified , text changed
Directoryqpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java modified , text changed
Directoryqpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/NodeReceivingDestination.java modified , text changed
Directoryqpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java modified , text changed
Directoryqpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/StandardReceivingLinkEndpoint.java modified , text changed
Directoryqpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/type/transport/AmqpError.java modified , text changed
Directoryqpid/java/trunk/broker-plugins/management-http/src/main/java/resources/addQueue.html modified , text changed
Directoryqpid/java/trunk/broker-plugins/management-http/src/main/java/resources/editQueue.html modified , text changed
Directoryqpid/java/trunk/broker-plugins/management-http/src/main/java/resources/js/qpid/management/Queue.js modified , text changed
Directoryqpid/java/trunk/broker-plugins/management-http/src/main/java/resources/js/qpid/management/addQueue.js modified , text changed
Directoryqpid/java/trunk/broker-plugins/management-http/src/main/java/resources/js/qpid/management/editQueue.js modified , text changed
Directoryqpid/java/trunk/broker-plugins/management-http/src/main/java/resources/showQueue.html modified , text changed
Directoryqpid/java/trunk/systests/src/main/java/org/apache/qpid/systest/rest/Asserts.java modified , text changed
Directoryqpid/java/trunk/systests/src/test/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java modified , text changed
Directoryqpid/java/trunk/systests/src/test/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java modified , text changed
Directoryqpid/java/trunk/systests/src/test/java/org/apache/qpid/systest/rest/QueueRestTest.java modified , text changed
Directoryqpid/java/trunk/systests/src/test/java/org/apache/qpid/systest/rest/VirtualHostRestTest.java modified , text changed
Directoryqpid/java/trunk/systests/src/test/java/org/apache/qpid/systest/rest/acl/QueueRestACLTest.java modified , text changed
Directoryqpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java modified , text changed
Directoryqpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/queue/QueuePolicyTest.java modified , text changed
Directoryqpid/java/trunk/test-profiles/Java10Excludes modified , text changed
infrastructure at apache.org
 ViewVC Help
Powered by ViewVC 1.1.26