summaryrefslogtreecommitdiff
path: root/java/client/src
Commit message (Collapse)AuthorAgeFilesLines
...
* QPID-2744 : Add tests for correct exception when null object is set via ↵Martin Ritchie2010-07-221-1/+1
| | | | | | setObjectProperty in Field Table and via JMS Properties git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966680 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2738Rajith Muditha Attapattu2010-07-213-24/+10
| | | | | | | | You could now susbcribe to any queue using browse mode and use a regular MessageConsumer (even with a MessageListener) instead of having to use a Queue Browser. Ex. 'my-ring-queue; {mode: browse}' git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966284 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2733Rajith Muditha Attapattu2010-07-201-0/+2
| | | | | | | | As the initial step, all subscription queues are marked exclusive and auto-delete. When support for reliability is added, the reliability mode will be taken into account. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@965713 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2735Rajith Muditha Attapattu2010-07-171-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964998 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2736Rajith Muditha Attapattu2010-07-163-47/+100
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The session.createQueue and session.createTopic methods will behave as follows. session.createQueue =================== 1. If just a queue name is passed, 1.1 If the destination syntax is BURL, a queue by that name will be created and bound to the amq.direct exchange using the queue name as the binding key. If published using this destination, then the message will be sent to amq.direct with routing key set to the queue name. 1.2 If destination syntax is ADDR, a queue is created by that name. If published using this exchange then the message will be sent to the defualt exchange (nameless exchange) with routing key set to the queue name. 2. If an address string or binding url is passed, it will be passed accordingly. session.createTopic =================== 1. If just a topic name is passed, 1.1 If destination syntax is ADDR, a temp queue is created and bound to the amq.topic with the topic name as binding key. If published using this destination, then the message will be sent to amq.topic with the topic name set to routing key. The topic name will also be set as "qpid.subject" in the outgoing message. 1.2 Same as above except there will be no subject set. 2. If an address string or binding url is passed, it will be passed accordingly. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964984 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2723Rajith Muditha Attapattu2010-07-084-14/+53
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@961866 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2722Rajith Muditha Attapattu2010-07-081-5/+19
| | | | | | | The producer now checks for the presense of qpid.subject in the header and uses it as the routing-key if sending to an exchange. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@961862 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2694 Commit to trunk for Andrew Kennedy patch for session leak on closeMarnie McCormack2010-07-052-4/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@960667 13f79535-47bb-0310-9956-ffa450edef68
* Added null checks in fillInCommonNodeArgs() and when trying to parse ↵Rajith Muditha Attapattu2010-06-251-6/+12
| | | | | | | | | capacities in getLink() Also fixed an error when parsing the qpid queue policy type. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@958102 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2696Rajith Muditha Attapattu2010-06-253-23/+45
| | | | | | | | | Modified the PropertiesFileInitialContextFactory to allow the new addressing strings to be specified in the jndi properties file. Downgraded some "info" log messages in AMQDestination to "debug". Added a test cases to cover the issue reported in the JIRA. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@957942 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2599: restore log4j settings files which are not named log4j.xml or ↵Robert Gemmell2010-06-041-0/+33
| | | | | | log4j.properties and so need not be removed completely since they wont be automatically applied by log4j if found on the classpath like the others will git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@951419 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2633 : Move destinationConsumer count logic to before the consumer is ↵Martin Ritchie2010-06-031-8/+15
| | | | | | registered. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@951165 13f79535-47bb-0310-9956-ffa450edef68
* Add the ASF License to various classes currently missing itRobert Gemmell2010-06-021-0/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@950740 13f79535-47bb-0310-9956-ffa450edef68
* 1. Capacity can now be specified as " capacity : {source: 5, target 10}" in ↵Rajith Muditha Attapattu2010-05-285-28/+56
| | | | | | | | | | | addition to "capacity:10" where both source and target is set to 10. 2. If the exchange type if direct and no subject is set, then the routing_key is set to "" instead of throwing an exception. 3. Added a fix to infer the exchange type if specified in the x-declares section. 4. The link can now specify an optional 'name' parameter which will be used as the queue name if present. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@949083 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2629Rajith Muditha Attapattu2010-05-287-21/+1266
| | | | | | | | | Removed commons collections from the build deps. Added the ReferenceMap and supported classes under a subpackage in qpid. These classes were copied from the Commons Collections release tag 3_2. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@949076 13f79535-47bb-0310-9956-ffa450edef68
* Implemented the feature described in QPID-2515Rajith Muditha Attapattu2010-05-182-17/+55
| | | | | | | However a few issues needs to be ironed out - see the JIRA for these issues. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@945945 13f79535-47bb-0310-9956-ffa450edef68
* I am reverting a change made by martin on rev 942098 (QPID-2586) as the 0-10 ↵Rajith Muditha Attapattu2010-05-141-1/+1
| | | | | | | | | | code path relies on that for failover. Currently due to the above commit all failover related tests are failing. However we will try to address the issue mentioned in QPID-2586. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@944457 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2599Rajith Muditha Attapattu2010-05-112-69/+0
| | | | | | | Removing all log4j xml and property files from the code base, except for the ones in test-profile folder and broker/etc folder. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943339 13f79535-47bb-0310-9956-ffa450edef68
* Commiting a patch by Emmanuel Bourg attached to QPID-2594Rajith Muditha Attapattu2010-05-1116-47/+80
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943200 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2559Rajith Muditha Attapattu2010-05-081-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@942293 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2586 : Give Client 0-10 close semantics not detactMartin Ritchie2010-05-071-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@942098 13f79535-47bb-0310-9956-ffa450edef68
* The heartbeat wasn't being set properly and these mistakes went uncaught due ↵Rajith Muditha Attapattu2010-05-061-1/+1
| | | | | | | | | | | | to lack of proper test. I have added a test case to AMQConnectionTest called testHeartBeat. This test fails once in a while even when I have an external script to clean the broker instance. It seems once it's wedged with kill -STOP, it somestimes doesn't get cleaned up properly with kill -9. Despite the occasional failure, I think it's worth to have this test as a lot of our users rely on heartbeat functionality. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@941553 13f79535-47bb-0310-9956-ffa450edef68
* Reverting the change made in rev 939416 as it's the wrong solution.Rajith Muditha Attapattu2010-05-031-4/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@940672 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2559Rajith Muditha Attapattu2010-04-291-3/+5
| | | | | | | A test case will be checked in shortly. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@939416 13f79535-47bb-0310-9956-ffa450edef68
* Modified the toString() to include the options.Rajith Muditha Attapattu2010-04-291-0/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@939405 13f79535-47bb-0310-9956-ffa450edef68
* Fixed some obvious spelling mistakes and removed commented out code.Rajith Muditha Attapattu2010-04-281-13/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@938732 13f79535-47bb-0310-9956-ffa450edef68
* Removed unused imports.Rajith Muditha Attapattu2010-04-271-22/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@938728 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2496Rajith Muditha Attapattu2010-04-271-23/+25
| | | | | | | | | 1. Added comments to explain how the address is handled 2. Now the subscription queue is created only when the destination is used by a consumer. 3. Removed unnessacery logic in createSubscriptionQueue method git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@938727 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2522Rajith Muditha Attapattu2010-04-211-2/+1
| | | | | | | Commiting patch submitted by Emmanuel Bourg. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@936568 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2512Rajith Muditha Attapattu2010-04-161-1/+1
| | | | | | | | | Changed the default destination syntax to addressing. Added qpid.dest_syntax=BURL to the test profiles to ensure all existing tests work. At some point next week the existing binding URL based entries will be prefixed with "BURL:" and the above system property will be removed. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@934997 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2496Rajith Muditha Attapattu2010-04-151-1/+1
| | | | | | | Fixed a minor bug when processing link props. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@934582 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-2496Rajith Muditha Attapattu2010-04-155-229/+764
| | | | | | | | | | The changes include support the new addressing structure and most items on the list specified in the JIRA. The following is not included in the commit 1. Add subject as filter in JMS - for exchanges use it as binding key and for queues use it as a selector - this needs to be thought through. Besides JMS already provides a way to handle this. 2. Implementation of DELETE option. Further testing needs to be done to figure out the impact. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@934563 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2496Rajith Muditha Attapattu2010-04-153-2/+18
| | | | | | | This allows a user to pass in an address string when creating a queue or topic using the JMS 1.0 methods (session.createQueue(String s) and session.createTopic(String s) ) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@934559 13f79535-47bb-0310-9956-ffa450edef68
* Commiting the patch attached to QPID-2471Rajith Muditha Attapattu2010-04-145-11/+88
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@934236 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2346 : Addressed the problems with ↵Martin Ritchie2010-04-121-0/+6
| | | | | | | | AcknowledgeAfterFailoverOnMessageTest, The issues were the same as AckAfterFailoverTest. So used same prepBroker approach. Test also need timeout increased as broke restarts took to long for a message to be sent/received. Finally the last change was thatthe queue needed to be re-declared so that the final queue depth check would have a queue to query. Merged from 0.5.x-dev @ r907004 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@933281 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2493Rajith Muditha Attapattu2010-04-092-1/+22
| | | | | | | Added test cases as well. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@932467 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-2447Rajith Muditha Attapattu2010-03-222-0/+21
| | | | | | | | | | | | Added QpidClientX509KeyManager (a customer KeyManager) which will return the ssl_client_alias specified in the Connection URL. Note the alias here is actually the certificate name and not the alias used in the keytool. I also fixed a minor bug in SSLUtil to retrive the identitiy of the local certificate instead of the peer's certificate. Added a test for the above JIRA. Added AMQTestConnection_0_10 which allows the SecurityLayer to be exposed for testing purposes. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@926380 13f79535-47bb-0310-9956-ffa450edef68
* Added support for QPID-2444 QPID-2446Rajith Muditha Attapattu2010-03-192-38/+91
| | | | | | | | | | 1. You could specify ssl_verify_hostname as a Broker argument in the Connection URL to explicitly enable SSL hostname verification. 2. You could specify a per connection trust store and key store to allow each connection to use it's own client certificate. trust_store,trust_store_passowrd, key_store, key_store_password could be specified as Broker arguments in the Connection URL. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@925289 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2432Rajith Muditha Attapattu2010-03-051-35/+51
| | | | | | | | | | | Modified the XAResourceImpl to maintain the timeout value and set it to any XID in the start method if the time value > 0 Also the XID nulled after commit, rollback and forget, to prevent a timeout being set on an invalid xid. The setTimeout method will only set the timeout if xid is not null and if the timeout value is different from the previous value. Modified the test cases in FaulTest to adhere to the correct behaviour and also added a new test case to cover the issue mentioned in the JIRA. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@919666 13f79535-47bb-0310-9956-ffa450edef68
* BasicMessageProducer_0_10.java contains a fix for QPID-2428.Rajith Muditha Attapattu2010-03-043-4/+19
| | | | | | | | | I also changed the exception handling code to use initCause() instead of setLinkedException as the latter does not show the 'cause' properly. AMQSession_0_10.java was modified to include the 'name' in the error message thrown if the address does not resolve to an exchange or a queue. AddressHelper.java - added a null check. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@918842 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-2242Rajith Muditha Attapattu2010-02-181-47/+97
| | | | | | | I modified the code to keep a map consisting of exchange_type and exchange_name, so it can be properly used when needed. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@911251 13f79535-47bb-0310-9956-ffa450edef68
* added a null check for the exchange class - related to QPID-1831Rajith Muditha Attapattu2010-02-181-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@911249 13f79535-47bb-0310-9956-ffa450edef68
* I have added the license header to the files included in this commit.Rajith Muditha Attapattu2010-02-123-0/+63
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@909641 13f79535-47bb-0310-9956-ffa450edef68
* Fixed an error in retrieving the SSL parameterRajith Muditha Attapattu2010-02-111-1/+1
| | | | | | | Added a log message in IoTransport to denote successfull creation of SSL Sender and Receiver git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@909150 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2370 : Committing patch to improve broker logging. This will not ↵Martin Ritchie2010-02-051-15/+51
| | | | | | | | | | | | | | cleanly apply to trunk due to IO changes. QPID-1084 : Committed change to prevent flow control threads being created/sent if the channel/session is closed or the state has acutally changed in the mean time. Wrapped .debug statements as per review feedback Merged and adapted these changes from 0.5.x r905592,905596,905605 The AMQMinaProtocolSession Changes were moved to the AMQProtocolEngine git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@906890 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1831Rajith Muditha Attapattu2010-02-033-0/+366
| | | | | | | Contains helper classes for retrieving and holding information from a parsed address string git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@906145 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1831Rajith Muditha Attapattu2010-02-039-91/+632
| | | | | | | | 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
* QPID-2379 : Initial work on adding QMF and federation to the Java BrokerRobert Godfrey2010-01-312-54/+46
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@904934 13f79535-47bb-0310-9956-ffa450edef68
* Added a null check for connection as some test cases use mock sessions by ↵Rajith Muditha Attapattu2010-01-281-1/+1
| | | | | | passing null as the connection parameter git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@904126 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-2363Rajith Muditha Attapattu2010-01-283-3/+24
| | | | | | | 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
View Lorry Controller Status