summaryrefslogtreecommitdiff
path: root/java/client/src
Commit message (Collapse)AuthorAgeFilesLines
...
* QPID-784 : Added ability to provide existing Socket to Qpid Client Libraries ↵Martin Ritchie2008-02-127-12/+596
| | | | | | | | | | | | | | | to use as for connection. AMQBrokerDetails.java, BrokerDetails.java And ConnectionURLTest.java augmented to allow new transport type 'socket' New ExistingSocketConnector, which utises a given Socket() rather than creating its own from a SocketChannel. This code was taken from the Mina library v1.0.0. Changes to AMQConnection.java, SocketTransportConnection.java were required to allow the new Socket object to be passed through to the ExistingSocketConnector. The TransportConnection.java was updated to return an ExistingSocketConnector when the 'socket' transport is used. AMQConnection.makeBrokerConnection was changed when the 'socket' transport is being used. This allows the set Socket to be passed down to the ExistingSocketConnector for the transport to be run over. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@620767 13f79535-47bb-0310-9956-ffa450edef68
* QPID-588: change instances of trace() and isTraceEnabled to debug equivalent ↵Aidan Skinner2008-02-083-17/+17
| | | | | | to support older versions of log4j git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@619868 13f79535-47bb-0310-9956-ffa450edef68
* Merged revisions 608477,609961,610475,610479,610806,611146 via svnmerge from Aidan Skinner2008-01-282-1/+69
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | https://svn.apache.org/repos/asf/incubator/qpid/branches/M2 ........ r608477 | rgodfrey | 2008-01-03 13:23:04 +0000 (Thu, 03 Jan 2008) | 1 line QPID-499 : Added per-virtual host timed tasks to inspect queues (with no consumers) for expired messages ........ r609961 | ritchiem | 2008-01-08 12:59:01 +0000 (Tue, 08 Jan 2008) | 2 lines QPID-499 : Patch to update the queue size statistics when the Active TTL process runs Removed old single commented out code line from AMQSession. ........ r610475 | ritchiem | 2008-01-09 17:32:43 +0000 (Wed, 09 Jan 2008) | 1 line Qpid-723 Added exec to qpid.start ........ r610479 | ritchiem | 2008-01-09 17:39:54 +0000 (Wed, 09 Jan 2008) | 1 line Qpid-690 : Provide configurable delay between re-connecion attempts. ........ r610806 | ritchiem | 2008-01-10 14:41:37 +0000 (Thu, 10 Jan 2008) | 1 line QPID-690 : Relaxed the timings on failover as Thread.sleep is accurate to 10ms so may finish the sleep 10ms early. Resulting in erratic failures as 9.9s < 10s. ........ r611146 | ritchiem | 2008-01-11 11:33:31 +0000 (Fri, 11 Jan 2008) | 1 line Patch by Aidan Skinner to make third constructor public. This is done so that the BDBMessageStore tests can still run with the addition of the VirtualHost reaper thread. ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@615943 13f79535-47bb-0310-9956-ffa450edef68
* Merged revisions ↵Aidan Skinner2008-01-249-195/+151
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 598285,598619,598721,598834-598835,599375,599531,599533,599572,599805,602134,604151,604928,605536,605542,606015-606016 via svnmerge from https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1.1 ........ r598285 | ritchiem | 2007-11-26 14:16:01 +0000 (Mon, 26 Nov 2007) | 3 lines QPID-92, QPID-564 : Upgraded Mina to 1.0.1 still not good enough but all future versions currently have a bug with the CumulativeProtocolDecoder. It compact()s the buffer which breaks slices. Added MultiThread Support which is some of the feature set of QPID-564 ........ r598619 | ritchiem | 2007-11-27 12:51:14 +0000 (Tue, 27 Nov 2007) | 1 line Renamed POMs to M2.1.1 Removed erroneous equals() in SpecificMethodFrameListenerTest ........ r598721 | ritchiem | 2007-11-27 18:09:33 +0000 (Tue, 27 Nov 2007) | 1 line QPID-621 : Patch Supplied by Aidan Skinner. Msg Ack after msg consumer is closed. ........ r598834 | ritchiem | 2007-11-28 00:45:32 +0000 (Wed, 28 Nov 2007) | 14 lines QPID-679 : Patch provided by Aidan Skinner and additional from odd problems during test runs. AMQChannel - Catch and log AMQException occuring when requeue()-ing. Previously exceptions wouldn't be caught at all. The requeue() is called during closure so there is nothing we can do protocol wise on error other than log the issue and continue with any other shutdown that is needed. AMQMinaProtocolSession & AMQPFastProtocolHandler . Additions to catch and log AMQExceptions. Changes to AMQMinaProtocolSession were done to ignore all input on a closing session other than the close-ok. Previously only Protocol frames were ignored this resulted in Content*Body-s still being processed. Additional checks were made for the MessageStoreClosedException to log and continue. As said else were we need to seperate protocol exceptoions(AMQException) from internal code exception handling. Further All AMQExceptions occuring in the frameReceived method are now caught and logged. Allowing them to propogate higher will only result in thread death. AMQPFastProtocolHandler Caught AMQExceptions occuring whilst closing the session. Again allowing these to continue will result in thread death. There is not a lot that can be done other than log the problem as the session is already closed by this point. Prevented the stacktrace associated with a session exception being printed in the exceptionCaught method when the problem was an IO Exception. This doesn't add anything useful and only adds to the log file sizes. ApplicationRegistry - Added removeAll option which ensures that all ARs are correctly purged so that we can attempt to clean up between Unit Tests. MemoryMessageStore - This was causing us real problems during the failover testing. Similar checks should probably be made to any other Message Store Impl. The issue was that when shutting down the broker the MS.close() method is called this sets all the storage to null. However, there may still be message processing going on as the close() does not attempt to stop connection processing. Hence we now check to see if the Store is close throwing a MSClosedException if required. This prevents NPEs that have been seen during Unit failover testing. In fact the close() is called as a request to shutdown the ApplicationRegistry, but this only occurs from tests and broker shutdown, no attempt to unbind or prevent further connections during this period is yet done. CLIENT CHANGES AMQConnection - Added method to check if failover is in progress. AMQClient - Upgraded acknowledge() exception to JMSException for errors due to failover. Also , added call to update consumers as a result of failover. BasicMessageConsumer - Changes to acquireReceiving to take in to consideration blocking for failover to occur. wrt receiveNoWait.. which previously blocked for failover to complete... not exactly noWait. acknowledge will now TransportConnection - Update to ensure all inVM brokers are correctly killed. FailoverTest - QPID-679 - Finder of all the above problems. ........ r598835 | ritchiem | 2007-11-28 01:01:05 +0000 (Wed, 28 Nov 2007) | 1 line CommitRollbackTest - this one just was never right.. now we have something better. ........ r599375 | ritchiem | 2007-11-29 10:58:08 +0000 (Thu, 29 Nov 2007) | 1 line Update to broker to address fanout python failure. ........ r599531 | ritchiem | 2007-11-29 17:56:12 +0000 (Thu, 29 Nov 2007) | 1 line QPID-92 QPID-564 Forgot to upgrade mina to 1.0.1 ........ r599533 | ritchiem | 2007-11-29 18:25:21 +0000 (Thu, 29 Nov 2007) | 1 line QPID-564 QPID-92 Tidied up a few points and fixed infinite loop in Read IO Thread ........ r599572 | ritchiem | 2007-11-29 20:56:22 +0000 (Thu, 29 Nov 2007) | 2 lines Mina Fix: Vm Pipe Starts Connection session before acceptor session. This results in protocol frames arriving before the protocol decoder has been configured on the InVM Broker. Verification of this could be done by adding a client side filter that delays the first message by a few seconds. ........ r599805 | ritchiem | 2007-11-30 12:47:08 +0000 (Fri, 30 Nov 2007) | 1 line Added new simple Request/Repsonse code as my last commit here seems to have missed the actual code. ........ r602134 | rupertlssmith | 2007-12-07 16:00:14 +0000 (Fri, 07 Dec 2007) | 1 line Added JDNI config for two broker, failover setup for failover tests. Also passed into FT tests config. ........ r604151 | ritchiem | 2007-12-14 10:40:37 +0000 (Fri, 14 Dec 2007) | 2 lines QPID-707 : Added new test to check message count on broker as messages are consumed to ensure that an ack is sent at 5000 mgs. Added acks on message consumer closure. Augmented VMTestCase to have helper methods for accessing broker statistics. ........ r604928 | rupertlssmith | 2007-12-17 17:00:10 +0000 (Mon, 17 Dec 2007) | 1 line DUPS_OK mode set to be same as AUTO_ACK, fixed broken dups ok test. ........ r605536 | rupertlssmith | 2007-12-19 13:40:05 +0000 (Wed, 19 Dec 2007) | 1 line Messages were being sent mandatory by default, set to false. ........ r605542 | rupertlssmith | 2007-12-19 13:53:44 +0000 (Wed, 19 Dec 2007) | 1 line Changed test configs to use colons instead of commas. ........ r606015 | rgodfrey | 2007-12-20 20:08:01 +0000 (Thu, 20 Dec 2007) | 2 lines QPID-714 : (Patch from Aidan Skinner) Issue with competing, transactional/client-ack consumers Ack each individual message on commit, not use multiple acks ........ r606016 | rgodfrey | 2007-12-20 20:12:25 +0000 (Thu, 20 Dec 2007) | 2 lines QPID-714 : (Patch from Aidan Skinner) Issue with competing, transactional/client-ack consumers Ack each individual message on commit, not use multiple acks ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@614906 13f79535-47bb-0310-9956-ffa450edef68
* Qpid-755, Corrected license header.Rupert Smith2008-01-231-20/+39
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@614482 13f79535-47bb-0310-9956-ffa450edef68
* Qpid-755, Added session per connection variant to test, to check that ↵Rupert Smith2008-01-231-1/+100
| | | | | | durable subscription can be picked up by a fresh connection. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@614481 13f79535-47bb-0310-9956-ffa450edef68
* Qpid-755, Test reordered to actually test subscription durability.Rupert Smith2008-01-221-40/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@614243 13f79535-47bb-0310-9956-ffa450edef68
* QPID-690 : Missing Test and code update.Martin Ritchie2007-11-262-17/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@598360 13f79535-47bb-0310-9956-ffa450edef68
* Last commit accidentally caught my failover change that wasn't complete.Martin Ritchie2007-11-261-3/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@598337 13f79535-47bb-0310-9956-ffa450edef68
* QPID-92, QPID-564 : Upgraded Mina to 1.0.1 still not good enough but all ↵Martin Ritchie2007-11-266-65/+123
| | | | | | future versions currently have a bug with the CumulativeProtocolDecoder. It compact()s the buffer which breaks slices. Added MultiThread Support which is some of the feature set of QPID-564 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@598324 13f79535-47bb-0310-9956-ffa450edef68
* QPID-567 : Add mutliversion support to Qpid/Java, fixed client support when ↵Robert Godfrey2007-11-267-82/+184
| | | | | | | | | | server returns Protocol header. Added QueueUnbind Added ability to select protocol version in ConnectionURL or with -Dorg.apache.qpid.amqp_version git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@598105 13f79535-47bb-0310-9956-ffa450edef68
* QPID-567 : Add mutliversion support to Qpid/Java.Robert Godfrey2007-11-2433-584/+1304
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@597918 13f79535-47bb-0310-9956-ffa450edef68
* QPID-160 Addition of JMSXUserID to all messages through the java broker.Martin Ritchie2007-11-073-25/+45
| | | | | | | | As this will cause the headers to be re-encoded it can be disabled in the config.xml. Default is enabled as the sample config.xml should have all features enabled so that testing can observe the interactions. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@592729 13f79535-47bb-0310-9956-ffa450edef68
* QPID-662 Transactional state not correctly reported after fail over. We now ↵Martin Ritchie2007-11-066-156/+301
| | | | | | | | record if we have sent any messages from here we can check if we have failed over and so have lost messages from the transaction making it invalid. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@592374 13f79535-47bb-0310-9956-ffa450edef68
* QPID-663 Messages fail to be received after fail over. This is due to the ↵Martin Ritchie2007-11-061-10/+8
| | | | | | old protocol session being reinstated after fail over. The new protocol session needs to be set in the StateManager as this maintains its own reference which is not being updated hence messages are being lost. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@592373 13f79535-47bb-0310-9956-ffa450edef68
* Additional Test for ConnectionURLTest, ensuring retries are correctly parsed.Martin Ritchie2007-11-051-6/+43
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@591960 13f79535-47bb-0310-9956-ffa450edef68
* QPID-654 : added a shutdownNow() call if the _taskPool hasn't terminiated by ↵Martin Ritchie2007-10-191-1/+11
| | | | | | the time we have finished closing. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@586374 13f79535-47bb-0310-9956-ffa450edef68
* QPID-653 : Updated timeoutsRobert Godfrey2007-10-195-25/+25
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@586344 13f79535-47bb-0310-9956-ffa450edef68
* QPID-637 : Patch provided by Aidan Skinner to ensure correct behaviour of ↵Martin Ritchie2007-10-182-127/+110
| | | | | | session closure. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@585912 13f79535-47bb-0310-9956-ffa450edef68
* QPID-637 Patch submitted by Aidan Skinner to address receive not waiting for ↵Martin Ritchie2007-10-111-10/+31
| | | | | | full timeout. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583882 13f79535-47bb-0310-9956-ffa450edef68
* QPID-635 Added a unit test and implemented the equals() method on ↵Martin Ritchie2007-10-113-0/+102
| | | | | | BlockingMethodFrameListener and SpecificMethodFrameListener. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583775 13f79535-47bb-0310-9956-ffa450edef68
* QPID-631 : Patch provided by Aidan Skinner to address the errors in the ↵Martin Ritchie2007-10-101-4/+4
| | | | | | MessageRequeueTest. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583546 13f79535-47bb-0310-9956-ffa450edef68
* QPID-627 : Update provided by Aidan Skinner to correctly close resources ↵Martin Ritchie2007-10-101-0/+2
| | | | | | used by Large Message Test. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583418 13f79535-47bb-0310-9956-ffa450edef68
* Qpid-627 Patch provided by Aidan Skinner to address hangs in ↵Martin Ritchie2007-10-091-8/+11
| | | | | | DurableSubscriptionTest. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583154 13f79535-47bb-0310-9956-ffa450edef68
* Qpid-626 : Patch provided by Aidan Skinner to address AMQSession Deadlocks.Martin Ritchie2007-10-091-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583147 13f79535-47bb-0310-9956-ffa450edef68
* QPID-625 : Fix commit rollback test to prevent failures caused by incorrect ↵Robert Godfrey2007-10-091-3/+10
| | | | | | assertions in the test git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583105 13f79535-47bb-0310-9956-ffa450edef68
* Update to provide a UUID.randomUUID() when getLocalHost() throws an ↵Martin Ritchie2007-10-091-7/+14
| | | | | | | | UnknownHostException. Update to formatting git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583086 13f79535-47bb-0310-9956-ffa450edef68
* QPID-551 : Patch provided by Aidan Skinner to address problems in info ↵Martin Ritchie2007-10-052-9/+11
| | | | | | logging when stacktraces are short. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@582266 13f79535-47bb-0310-9956-ffa450edef68
* QPID-624 : Forgot to commit updates to test along with ↵Martin Ritchie2007-10-051-30/+47
| | | | | | BlockingMethodFrameListener git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@582202 13f79535-47bb-0310-9956-ffa450edef68
* QPID-624: Update to ensure all errors are correctly processed in ↵Martin Ritchie2007-10-051-23/+61
| | | | | | BlockingMethodFrameListener.java git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@582201 13f79535-47bb-0310-9956-ffa450edef68
* QPID-614 : Applied supplementary patch from Aidan Skinner.Martin Ritchie2007-10-031-20/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@581627 13f79535-47bb-0310-9956-ffa450edef68
* QPID-584 : Fixed issue where ALL errors are presented to client as a ↵Martin Ritchie2007-10-031-1/+1
| | | | | | connection closing error. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@581621 13f79535-47bb-0310-9956-ffa450edef68
* QPID-617 : Transactional consume does not ack messages.Martin Ritchie2007-10-031-15/+19
| | | | | | Problem is that we were not classing msgs as consumed until onMessage completed in the transactional case. This patch corrects that. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@581540 13f79535-47bb-0310-9956-ffa450edef68
* QPID-615, Added patched version of MINAs VM Pipe cleanup thread. Will ↵Rupert Smith2007-10-021-0/+125
| | | | | | replace once bug fix is in newer version of MINA. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@581293 13f79535-47bb-0310-9956-ffa450edef68
* QPID-614 : Applied patch supplied by Aidan SkinnerRobert Godfrey2007-10-021-28/+51
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@581189 13f79535-47bb-0310-9956-ffa450edef68
* QPID-611 QPID-620. DurableSubscriptionTest was failing due to a race ↵Martin Ritchie2007-10-011-14/+29
| | | | | | condition when using NO_ACK. This is due to the Queue Total Size being updated after the send, but after the send and NO_ACK the msg data is purged and so there is no size to retrieve. Changed all references to msg.dequeue to queue.dequeue where appropriate so we can use that single point in the future for updating the Queue Total Size. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@580993 13f79535-47bb-0310-9956-ffa450edef68
* QPID-595 CommitRollbackTest Patch provided by Aidan Skinner to address ↵Martin Ritchie2007-10-011-4/+3
| | | | | | intermittent test failure. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@580992 13f79535-47bb-0310-9956-ffa450edef68
* QPID-597 : TopicSessionTest Failure, Patch supplied by Aidan Skinner.Martin Ritchie2007-09-281-8/+15
| | | | | | ResetMessageListenerTest.java was changing the prefetch method via a system property that propogated to all tests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@580258 13f79535-47bb-0310-9956-ffa450edef68
* QPID-596 : ConnectionStartTest was broken. I've fixed it but here is the ↵Martin Ritchie2007-09-271-19/+34
| | | | | | | | | | | | | | | | | | | | | | | problem for those like me that like to know why: Previously: The setUp method created a producer connection and then sent a message - This will result in that message being bounced as there is no consumer. The first test should fail but the test was wrong, which caused it to pass. There was an assert that was expecting the receive a message yet the test was recieve() == null !!!! The second test worked because the broker was not killed between tests This left the queue created so on the second run the message was delivered causing the test to succeed. Now: Fixed the InVM broker setup/teardown so the client is created first and the broker removed at the end of the test. Also updated the asserts to be more explicit rather than having the == null or !=null put that as assertNull/NotNull. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@580022 13f79535-47bb-0310-9956-ffa450edef68
* Update for three tests that don't remove their VMBrokerMartin Ritchie2007-09-263-0/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@579709 13f79535-47bb-0310-9956-ffa450edef68
* Updated TransportConnection to synchronize around the creation/destruction ↵Martin Ritchie2007-09-262-65/+80
| | | | | | | | | | of VM Brokers. I had observed a ConcurrentModificationException in the KillAllVMBrokers(). This isn't good this suggests that the tests are overlapping. This fix won't address that problem but will stop any CModifications occuring. If there is test setup/teardown overlapping we should now see tests failing because the VM broker isn't there. Potentially addresses VM issues in QPID-596 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@579577 13f79535-47bb-0310-9956-ffa450edef68
* QPID-612 : Use same scheme for every creation of temporary queue namesRobert Godfrey2007-09-243-128/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@578845 13f79535-47bb-0310-9956-ffa450edef68
* Merged revisions ↵Rupert Smith2007-09-244-64/+92
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 575663-575687,575689-576860,576862-577192,577194-577315,577317-577659,577661-578047,578049-578060,578062-578604 via svnmerge from https://svn.apache.org/repos/asf/incubator/qpid/branches/M2 ........ r575663 | rgodfrey | 2007-09-14 13:43:13 +0100 (Fri, 14 Sep 2007) | 1 line QPID-600 : Deadlock on connection.close ........ r577931 | rgreig | 2007-09-20 22:26:37 +0100 (Thu, 20 Sep 2007) | 1 line Adding timeouts to two wait() calls to prevent hanging ........ r578258 | rgreig | 2007-09-21 21:31:18 +0100 (Fri, 21 Sep 2007) | 1 line QPID-607: dispatcher threads now poll so that the can die when the connection is closed. ........ r578475 | rgreig | 2007-09-22 20:01:59 +0100 (Sat, 22 Sep 2007) | 1 line QPID-608 Fix the test by adding in creation of the VM broker ........ r578509 | rgreig | 2007-09-22 23:05:30 +0100 (Sat, 22 Sep 2007) | 1 line QPID-609 : dispatcher thread was being restarted by the code that closed the consumer due to the receipt of a basic.cancel frame. Move the dispatcher shutdown to the end of the consumer close process. Also rename the dispatcher _closed field since it clashes with a field in the container class. ........ r578604 | rgreig | 2007-09-23 22:29:33 +0100 (Sun, 23 Sep 2007) | 4 lines QPID-589: avoid the deadlock between the session close and the BasicCancelOkHandler by not sending a BasicCancel when the session is being closed. ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@578745 13f79535-47bb-0310-9956-ffa450edef68
* Attempt to fix hanging builds due to client testsRobert Greig2007-09-201-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@577941 13f79535-47bb-0310-9956-ffa450edef68
* Merged revision 572751 from the trunk, this fixes QPID-573.Rafael H. Schloming2007-09-142-28/+37
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@575788 13f79535-47bb-0310-9956-ffa450edef68
* QPID-572 Applied test patch supplied by Aidan Skinner along with change to ↵Martin Ritchie2007-09-121-0/+152
| | | | | | ConcurrentSelectorDeliveryManager that resolves the ordering problem. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@574902 13f79535-47bb-0310-9956-ffa450edef68
* QPID-590 : Provide test case and resolution to prevent deadlock occurring on ↵Martin Ritchie2007-09-112-277/+279
| | | | | | the client when two threads work on the AMQSession object. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@574555 13f79535-47bb-0310-9956-ffa450edef68
* QPID-584 : Client exceptions are now presented via any set Exception Listener Martin Ritchie2007-09-103-1/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@574266 13f79535-47bb-0310-9956-ffa450edef68
* QPID-585 : Created a new StateManager for each subsequent ↵Martin Ritchie2007-09-102-1/+10
| | | | | | makeBrokerConnection call during the initial connection. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@574237 13f79535-47bb-0310-9956-ffa450edef68
* QPID-547 : Stop session closure while in message dispatchRobert Godfrey2007-08-101-1/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@564593 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status