summaryrefslogtreecommitdiff
path: root/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
Commit message (Collapse)AuthorAgeFilesLines
* merged from trunkQPID-6125-ProtocolRefactoringRobert Godfrey2014-10-171-47/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6125-ProtocolRefactoring@1632579 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6088 : [Java Client] AMQP 0-8/8/9-1 prefetch should auto expand when ↵Robert Godfrey2014-09-081-36/+0
| | | | | | receive is called in a situation where the prefetch buffer is full git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1623422 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6037 : [Java Client] Enhance experimental support for ADDR addressing ↵Robert Godfrey2014-08-241-2/+3
| | | | | | to the 0-8/9/9-1 client git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1620147 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6000 : [Java Broker] [Java Client] add the ability to configure ↵Robert Godfrey2014-08-161-41/+77
| | | | | | automatic message compression git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1618375 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5980: continued javadoc fixupsRobert Gemmell2014-08-081-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1616808 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5088 : [Java Broker] Isolate use of AMQShortString and FieldTable to ↵Robert Godfrey2013-08-211-4/+4
| | | | | | 0-8/9/9-1 protocol specific plugins git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1516058 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5050: Move invocation of ExceptionListener to after the failoverMutex ↵Keith Wall2013-08-161-32/+44
| | | | | | | | | | | | | is released avoiding deadlock possibility Previously, the ExceptionListener was invoked whilst the failoverMutex was held, between the two potential state changes (connection state change and session state change). This commit reorders the statements so that the ExceptionListner is fired after the failoverMutex is released. It also means that the ExceptionListener is fired *after* both connection/session have undergone any state changes. The exceptionListener member is also made thread safe. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1514664 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4943: Introduce a feature for 0-8/0-9/0-9-1 protocols to close a ↵Alex Rudyy2013-06-211-3/+12
| | | | | | connection on receiving a mandatory unroutable message in a transacted session git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1495511 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4714 Moved _delegate.closeConnection method inside a finally blockRajith Muditha Attapattu2013-04-251-3/+12
| | | | | | | to ensure the TCP connection is closed in case an exception is thrown from any of the methods above. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1475810 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4312 : [Java Client] add option for verification of queue existence ↵Robert Godfrey2013-02-041-1/+21
| | | | | | during creation of a MessageProducer git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1442128 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2796 : Added Java system test for heartbeatingRobert Godfrey2012-11-261-0/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1413539 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3906 Switched the default to legacy stream message format.Rajith Muditha Attapattu2012-09-281-1/+2
| | | | | | | Allows the lists to contain elements of different types. Added a set of unit tests in place of the system tests. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1391566 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3906 List Message support for JMS.Rajith Muditha Attapattu2012-09-281-0/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1391565 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4289: Fix 0-8/0-9/0-9-1 failover issuesRobert Gemmell2012-09-101-1/+1
| | | | | | Applied patch from Philip Harvey <phil@philharveyonline.com> and Oleksandr Rudyy <orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1382799 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4038: log the Connection number and its local and remote addresses ↵Robert Gemmell2012-06-041-0/+10
| | | | | | after each [re]connection git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1346169 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4033: update the Dispatcher thread name to include a connection id to ↵Robert Gemmell2012-05-311-5/+15
| | | | | | ease identifying work for individual sessions on different connections during log analysis git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1344632 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3912: Client failover fails to reconnect if a previous attempted ↵Keith Wall2012-03-281-0/+1
| | | | | | | | reconnection has failed 'late' in the connection start process. Applied patch from Andrew MacBean <andymacbean@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1306208 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3885 Applying a patch by Kevin Conner.Rajith Muditha Attapattu2012-03-081-5/+14
| | | | | | | | | For the most part it reduces noise by downgrading most log messages from info to debug. It also adds a if(logger.isDebugEnabled()) to save on any unnecessary (and potentially expensive) string concatenations. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1298555 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2020 : [Java Client] create[Durable]ConnectionConsumer should throw ↵Robert Godfrey2012-02-271-4/+5
| | | | | | JMSException, not return null (until such time as QPID-3693 is completed) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1294370 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3789 : [Java] code tidyupsRobert Godfrey2012-01-291-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1237273 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Encapsulate fields, use private members and accesors (keep ↵Robert Godfrey2012-01-271-14/+33
| | | | | | checkstyle happy) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1236867 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA : [Java] Tidy up import statements across the codebase, remove ↵Robert Godfrey2012-01-271-33/+33
| | | | | | unused/redundant imports (keep Checkstyle happy) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1236638 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3642,QPID-3643: Add Dead Letter Queue functionality for 0-8/0-9/0-9-1 ↵Keith Wall2011-11-281-1/+5
| | | | | | | | paths, fixes isBound methods on FanoutExchange Applied patch from Keith Wall <keith.wall@gmail.com>, Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1207029 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3518: Introduce client side ability to detect server side support.Keith Wall2011-11-091-0/+13
| | | | | | Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1199662 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3532: make the 0-10 client hold the failover mutex during the failover. ↵Robert Gemmell2011-10-211-0/+10
| | | | | | | | Alter the Address resolution code to allow resolving addresses after failover. Add some more failover tests (inc ADDR based ones). Make the failover process notify any waiters in the session to abort and let failover proceed. Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1187279 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3428: make the Java broker validate 0-10 Session names, enabling it to ↵Robert Gemmell2011-09-131-2/+5
| | | | | | | | | satisfy the clients new ClientID verification feature. Misc updates to the clients verification process. Applied patch from Andrew MacBean git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1169982 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2901: fixes racing conditions on broker side when TopicDeletePolicy is ↵Robert Gemmell2011-09-071-1/+1
| | | | | | | | closing the consumer Session but the broker is trying to deliver next message to the Subscription of this closing Session. Applied patch from Oleksandr Rudyy <orudyy@gmail.com>. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1166246 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3434: Refactored 0-8..0-9-1 code paths to use same SSL configuration ↵Robert Gemmell2011-08-181-56/+6
| | | | | | | | mechanisms as 0-10. Apply work by myself and Keith Wall git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1159255 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3263 Applying patch from Weston Price with the following modifications.Rajith Muditha Attapattu2011-08-021-1/+12
| | | | | | | | 1. The test case now extends QpidBrokerTestCase instead of TestCase to ensure that it can run under the automated ant builds. 2. Added an additional case to testIsSameRMMultiCF to ensure that isSameRM() returns false for two XAResources created from two different brokers. 3. Excluded this test from the Java test profiles. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1153164 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3269Rajith Muditha Attapattu2011-07-081-17/+33
| | | | | | | | | | | In order to verify the uniqueness of the client ID, a dummy session is created using client ID as it's name. This prevents any other connection from using same client ID as the session creation will fail. However this verification is switched off by default in order to preserve backwards compatibility. You need to use -Dqpid.verify_client_id=true switch verification on. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1144531 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3343: refactor test profiles to allow testing within the same JVM for ↵Robert Gemmell2011-07-071-1/+1
| | | | | | | | all protocols, remove vm:// transport support and associated forked Mina classes Applied patch by Keith Wall and myself git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1143874 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3277: AMQCallbackHandler improvements. Refactor AMQCallbackHandler to ↵Robert Gemmell2011-05-261-32/+24
| | | | | | | | accept ConnectionURL in place of AMQProtocolSession (improved information hiding, ease ability to write good unit tests). Remove unused protected constructor from AMQConnection and MockAMQConnection. Applied patch from Keith Wall <keith.wall@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1127939 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3050Rajith Muditha Attapattu2011-02-121-1/+1
| | | | | | | Modified the code to use the correct system property name. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1069998 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3029: actually set and negotiate the supported max num channels per ↵Robert Gemmell2011-02-041-157/+13
| | | | | | connection during connection handshake. Enable/make the 0-10 client use channel numbers 0 to N-1 in line with the spec, rather than 1-N. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1067210 13f79535-47bb-0310-9956-ffa450edef68
* Added a log message to print out the negotiated AMQP version.Rajith Muditha Attapattu2010-07-221-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966752 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2657: Make Exceptions propagate to client for 0-10Andrew Donald Kennedy2010-07-221-26/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966722 13f79535-47bb-0310-9956-ffa450edef68
* Commiting a patch by Emmanuel Bourg attached to QPID-2594Rajith Muditha Attapattu2010-05-111-3/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943200 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1831Rajith Muditha Attapattu2010-02-031-1/+1
| | | | | | | | I added the patch attached to the above JIRA with modifications. The modifications include integration with the address parser added by Rafi, and several refactoring and bug fixes to the original patch. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@906142 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-2363Rajith Muditha Attapattu2010-01-281-1/+21
| | | | | | | I added use_legacy_map_msg_format as a connection paramter to force the client to use the old map message format. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903940 13f79535-47bb-0310-9956-ffa450edef68
* The commit contains fixes for QPID-2351, QPID-2350 and some ground work for ↵Rajith Muditha Attapattu2010-01-211-2/+2
| | | | | | | | | | | | | | QPID-2352 - Modified Connection.java to add more than one ConnectionListener. This was done to facilitate the SASL encryption patch - QPID-2352. - Changed the access modifier for getSaslClient method to "public" to allow the SaslClient to be retrieved by the SASL encryption code -QPID-2352. - Introduced ConnectionSettings object to hold all the configuration options. Previous constructor methods remains unchanged. - Modified the ClientDelegate to handle heartbeat and idelTimeout value properly. - Added support to specify config options via the connection URL - QPID-2351 - Added support to handle the heartbeat/idle_timeout options properly in the 0-10 code - QPID-2350. However once QPID-2343 is completed, the code will be further simplified. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901506 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2349 : Fixed Protocol Version negotiation. The Negotiated protocol ↵Martin Ritchie2010-01-201-2/+11
| | | | | | | | | version was not given to the ProtocolSession. Once this is done the correct delegate is enabled on connection. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901341 13f79535-47bb-0310-9956-ffa450edef68
* This is a first step towards QPID-2343Rajith Muditha Attapattu2010-01-181-1/+1
| | | | | | | | The common module also contains code for the client, and therefore contains configuration required for the client to be accessible from within the common module. Therefore the ClientProperties.java is best be placed inside the common module. The goal is to have a place holder for all configuration properties. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@900595 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2174Rajith Muditha Attapattu2010-01-121-5/+5
| | | | | | | | I couldn't find any straight forward way to grab the proper ID from the SASL client. Therefore I had to use the java GSSAPI classes to create a security context to grab the ID. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@898505 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2273 : Fix Protocol NegotiationRobert Godfrey2009-12-181-9/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@892301 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2192: remove extraneous printStackTrace()sAidan Skinner2009-12-021-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@886031 13f79535-47bb-0310-9956-ffa450edef68
* Added AMQP 0-9-1 supportRobert Godfrey2009-10-261-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@829944 13f79535-47bb-0310-9956-ffa450edef68
* Merged from java-broker-0-10 branchRobert Godfrey2009-10-251-13/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@829675 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1440 : Code review changes from QPID-1289. All actioned except adding ↵Martin Ritchie2009-10-081-1/+1
| | | | | | new createConsumer() method. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@823149 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1956Rajith Muditha Attapattu2009-09-221-5/+5
| | | | | | | I had missed this bit when I committed last night. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@817867 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1859Rajith Muditha Attapattu2009-05-141-1/+1
| | | | | | | | | For FailoverSingleServer the default for retries is set to 0 and the current_retries start from 0 instead of -1. For FailoverRoundRobinServers the current_broker_index now starts from 0 instead of -1. The AMQConnection now uses the getCurrentBrokerDetails() instead of the getNextBrokerDetails() to get the initial broker to connect. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@774899 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status