summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src
Commit message (Collapse)AuthorAgeFilesLines
* QPID-1390 : Added test to validate that new SASL providers are unregistered ↵Martin Ritchie2008-10-241-0/+120
| | | | | | by the broker on ApplicationRegistry shutdown git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707678 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1315: Fix style issue, iterator control usage as per review comments ↵Aidan Skinner2008-10-242-11/+15
| | | | | | from rgodfrey. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707672 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1394 : Registration of JCAProvider is incorrect in client and broker ↵Martin Ritchie2008-10-242-7/+11
| | | | | | SASL configurations git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707658 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1390 : Allow Authentication Manager to correctly closeMartin Ritchie2008-10-243-2/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707657 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1385 : Extracted annonymous class from AMQChannel.resend(boolean), ↵Martin Ritchie2008-10-238-62/+827
| | | | | | 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
* QPID-1315:Aidan Skinner2008-10-172-157/+114
| | | | | | | | | | 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
* QPID-1101 : Reverted change, for some reason I can't seem to find where this ↵Martin Ritchie2008-10-151-6/+1
| | | | | | 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
* QPID-1314: move metadata store up a few lines as per review comment.Aidan Skinner2008-10-151-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@704936 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1356: move commit even higher, before the auth check.Aidan Skinner2008-10-151-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@704928 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1356: Write message to disk before delivering it to queues.Aidan Skinner2008-10-151-3/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@704925 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1314: add missing MockQueueEntry class, oopsAidan Skinner2008-10-101-0/+177
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703497 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1314: Make sure all messags that are enqueued are dequeued.Aidan Skinner2008-10-103-2/+58
| | | | | | | | 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
* QPID-1331 : Modified the BrowserSubscription to be consistent with the NoAck ↵Martin Ritchie2008-10-098-10/+181
| | | | | | | | | | | | | | | | 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
* revert the commit.Lahiru Gunathilake2008-10-091-97/+130
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703155 13f79535-47bb-0310-9956-ffa450edef68
* resolving jira 1329.Lahiru Gunathilake2008-10-081-130/+97
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@702745 13f79535-47bb-0310-9956-ffa450edef68
* testing commiting added a word to a comment.Lahiru Gunathilake2008-10-071-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@702327 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1269 : Modified to actually test the type of queue that is returnedMartin Ritchie2008-10-031-16/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@701330 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1268 : Added additional deleteDirectory method that behaves like rmdir, ↵Martin Ritchie2008-10-031-0/+3
| | | | | | 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
* QPID-1101 : Merge of changes from M2 to allow Configuration to be loaded and ↵Martin Ritchie2008-10-031-1/+5
| | | | | | 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
* QPID-1266 : Updates based on reviewMartin Ritchie2008-10-032-16/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@701326 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for the problem identified in QPID-943.Rajith Muditha Attapattu2008-09-253-19/+65
| | | | | | | | | 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
* QPID-1286: Change test and variable names as per review.Aidan Skinner2008-09-191-13/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@697131 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1286: Change test and variable names as per review.Aidan Skinner2008-09-192-82/+78
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@697130 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1286: add missing classAidan Skinner2008-09-181-0/+192
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@696692 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1287: Allow boolean <priority> element in virtual host file. Add test ↵Aidan Skinner2008-09-182-2/+115
| | | | | | for this. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@696691 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1286: make sure priority queues don't mess with deleted subscriptionsAidan Skinner2008-09-183-28/+304
| | | | | | | | | 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
* QPID-1190 Changed logging for protocol negotiation on client connect to be ↵Marnie McCormack2008-09-111-1/+1
| | | | | | 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
* QPID-1269 : Added test to ensure queue creation via the Factory is ↵Martin Ritchie2008-09-031-0/+91
| | | | | | automatically added to the queue registry. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@691669 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1266 : Actually added the test.Martin Ritchie2008-09-031-0/+63
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@691668 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1266 : Provided test for new stop() method. Updated RefCountExService ↵Martin Ritchie2008-09-035-7/+26
| | | | | | 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
* QPID-1269 : Added queue registration as part of the creation via the ↵Martin Ritchie2008-09-032-2/+9
| | | | | | 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
* QPID-1266 - Provide a stop() method on AMQQueue to stop all processing on ↵Martin Ritchie2008-09-023-2/+18
| | | | | | 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
* QPID-579 : Make broker stop on startup errorsMartin Ritchie2008-09-021-4/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@691262 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1258 add ASL to java files that were missing itAidan Skinner2008-08-225-0/+105
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@688094 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1167: reset queue notification lists when creating queues. Pull out ↵Aidan Skinner2008-08-217-25/+73
| | | | | | defaults centrally. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@687764 13f79535-47bb-0310-9956-ffa450edef68
* Sorry went crazy with git and didn't meant to commit this changeMartin Ritchie2008-08-211-4/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@687749 13f79535-47bb-0310-9956-ffa450edef68
* Stopped the broker closing the ProtocolSessions as this was causing the ↵Martin Ritchie2008-08-211-4/+5
| | | | | | 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
* QPID-1202: TopicExchance.removeFilteredQueue: if there are no instances of ↵Aidan Skinner2008-08-201-8/+11
| | | | | | 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
* QPID-1202: Rebind durable subscriptions if the arguments have changedAidan Skinner2008-08-191-8/+25
| | | | | | | | 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
* QPID-1226 : Last few changes to correctly shutdown all ApplicationRegistries ↵Martin Ritchie2008-08-185-3/+41
| | | | | | on each test run git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@686722 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1136 : Fixed Flow Control problem due to this change and added test to ↵Martin Ritchie2008-08-125-17/+7
| | | | | | 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
* QPID-1193 : Actually removed the calls that pass in the ugly nullMartin Ritchie2008-08-112-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@684714 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1193 : re-added createQueue(AMQQueue queue) method, after code review call.Martin Ritchie2008-08-113-0/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@684710 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1218: cleaned up the interface to IoTransport a bit; added IoAcceptor; ↵Rafael H. Schloming2008-08-091-2/+2
| | | | | | fixed Session tracking of sync point; default JAVA inside qpid-run git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@684182 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1218 Optionally use IoTransport, it's hot, but doesn't pass all the ↵Aidan Skinner2008-08-081-0/+11
| | | | | | tests yet. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@684016 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1136 : Provided a fix for the leak in UnacknowledgedMessage when ↵Martin Ritchie2008-08-088-84/+144
| | | | | | acking. Added a new InternalBrokerBaseCase for performing testing on the broker without using the client libraries. This allows for testing closer to AMQP. Merged from M2.1.x git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@683949 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1224: add methods to get the list of message ids from a queue, with ↵Aidan Skinner2008-08-083-0/+204
| | | | | | optional offset. Test class for this. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@683932 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1213: Patch from rgodfrey to refactor AbstractJMSMessage and ↵Rafael H. Schloming2008-08-072-7/+1
| | | | | | descendants to move AMQP version specific code into delegates and remove unnecessary conversion between 0-8 and 0-10 objects git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@683683 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1195 , QPID-1193 Initial changes to allow bind and queue arguments to ↵Martin Ritchie2008-08-0715-65/+770
| | | | | | be stored and recovered from the MessageStore. Created a test to validate that the stored values can be recovered. DerbyStore hasn't fully been implemented. Surrounding work has been done and tested with BDBMessageStore. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@683632 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1218: fix stupid used-only-by-tests method breakage that I have exposedAidan Skinner2008-08-071-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@683597 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status