| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
| |
and also clean up to simplify. qpid.stopall now just passes through to qpid.stop rather than go back & forth between scripts. Only retained it in case we have users currently dependent on it.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709199 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
by the broker on ApplicationRegistry shutdown
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707678 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
from rgodfrey.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707672 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
SASL configurations
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707658 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707657 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Added new Mock Objects to the broke to allow direct testing of the new class.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707344 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
BasicBytesFlowControl doesn't wait long enough to determine if the 3rd message is going to be delivered accidently. It also ack'd every message, which was not it's intent, so use acknowledgeThis() instead.
Refactor common code out of processQueue and flushSubscription into attemptDelivery.
Make sure sendLock is held when closing the consumer.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@705657 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
tool will function.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@705627 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
code was used, agree it was a poor approach. Will document a better one on QPID-1103
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@704945 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@704936 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@704928 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@704925 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703497 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
SimpleAMQQueue - dequeue messages if they are persistent, regardless of queue durability.
SimpleAMQQueueTest - make sure that all messages which are stored are removed properly.
TestableMemoryMessageStore - override enqueue/dequeue so it's possible to determine what is in the queue at any given point in time.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703485 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Subscription.
Added Test QueueBrowserUsesNoAckTest to validate the change.
Note that the Credit Manager Suspends the subscriber not the channel when credit is exhausted. JIRA to follow.
So to check if the subscription was suspended I needed to make a MockChannel and give it access to the subscriber map in the
Channel.
The test also needed to be able to interrogate the state of the Subscription which was not part of the Subscription interface, but was used by all subscriptions. So promoted to the interface and implemented the stubs in the various helper/test classes.
Added the ability to browse() via the InternalBrokerBaseCase and prevented a NPE when there were no messages returned via getDelivers.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703212 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703188 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703187 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703155 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@702745 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@702327 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@701330 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
modified delete to behave like rm. Added further tests for copy and delete. Encorporated review feedback from ASkinner.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@701329 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
modified before being given the the ApplicationRegistry
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@701328 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@701326 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
If msg-auth is configured as true in config.xml the user_id in message properties is verified against the id used at authentication.
If not an exception with error code 403 is thrown.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@699044 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@697131 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@697130 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@696692 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
for this.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@696691 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
AMQPriorityQueue: don't advance deleted subscriptions
AMQPriorityQueueTest: Add test class for priority queues
SimpleAMQQueueTest: Add more tests
PriorityTest: Check for more message orders
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@696686 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
less alarming, amended to info level log message with no stack trace
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@694282 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
and client package. Documenation will be added to the wiki such that performance tests could also be packaged.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@692461 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
automatically added to the queue registry.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@691669 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@691668 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
to allow retrieval of the referenceCount. Updated AMQQueue to only perform stop() actions once, such as releasing the RefCountExService. Updated instances where new virtualhosts were not added to the VHostRegistry. See supplemental JIRA for removing the need for this.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@691661 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Factory. Updated direct creations to use the factory.. where possible.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@691643 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
that queue thus shutting down the ThreadPool.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@691263 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@691262 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@688094 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
defaults centrally.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@687764 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@687749 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
client to lock in Mina seemingly missing the notify for the CloseFuture and hangs indefinately
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@687741 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
the filter, it's ok to remove it.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@687382 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
TopicExchange: take field arguments into account when determining if topic binding already exists when binding, but not for regular isBound().
DurableSubscriptionTest: add test case for QPID-1202
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@687010 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
on each test run
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@686722 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@686214 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@685874 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
validate that Flow Control is operating correctly
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@685104 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@684714 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@684710 13f79535-47bb-0310-9956-ffa450edef68
|