summaryrefslogtreecommitdiff
path: root/java/client
Commit message (Collapse)AuthorAgeFilesLines
...
* Remove out of date/redundant scripts and README.txt fileRobert Gemmell2010-11-223-144/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1037877 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2943: add the example src+jar to the client release archiveRobert Gemmell2010-11-141-0/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1035028 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2943: remove references from the README.txt file to examples that no ↵Robert Gemmell2010-11-141-260/+4
| | | | | | longer exist git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1035027 13f79535-47bb-0310-9956-ffa450edef68
* Increment version numbers from 0.7 to 0.8(docs) and 0.9(code)Robert Gemmell2010-11-071-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1032374 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2928 QPID-2737 The isExclusive method in BasicMessageConsumer_0_10.java ↵Rajith Muditha Attapattu2010-11-045-5/+87
| | | | | | takes the dest syntax into consideration when determining the exclusivity for a subscription. For destinations created using the addressing syntax, Queue subscriptions are non exclusive by default but are allowed to change it. Topic subscriptions are exclusive and is not allowed to change the value. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1031321 13f79535-47bb-0310-9956-ffa450edef68
* add ASF licence to various files in the java treeRobert Gemmell2010-10-311-4/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1029523 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2835 Implement CON Operational Logging on 0-10Andrew Donald Kennedy2010-10-031-1/+13
| | | | | | Committed patch from SorinS <ssuciu@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003984 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2857: Fix issue identified by running FindBugs across the codebase. ↵Robert Gemmell2010-09-301-19/+22
| | | | | | Release lock before sleeping. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1002993 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2857: close the input stream used when loading properties files for ↵Robert Gemmell2010-09-291-1/+10
| | | | | | JNDI lookups git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1002675 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2879: The 0-10 Java Client is sending null arguments on messageSubscribeAndrew Donald Kennedy2010-09-231-1/+2
| | | | | | | | | Converts the argument Map to a FieldTable and add as an argument to messageSubscribe Patch from <sorins@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1000407 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2882Rajith Muditha Attapattu2010-09-221-5/+13
| | | | | | | Modified the address helper class to check for the durable property in the node props for the target node and link props for the subscription queue. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999718 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2881Rajith Muditha Attapattu2010-09-222-6/+8
| | | | | | | | | | | | | | | | | | | | | | When a topic based destination is used in creating a consumer, the code looks to see if the address is already resolved. If it is then it could mean two things. 1. A consumer is being recreated after failover. 2. This destination was used previously to create a consumer or a producer. In this case we assume it was used for a consumer. For case #1, we need to preserve the queue name. The reason being if it was either a durable subscription or if it was a named queue (name property specified in link) then we need to maintain the same name. For case #2 we need to ensure that each consumer gets it's own queue,hence we clone the destination object and the queue name is set to null so name is auto-generated. I have removed the incorrect logic (in BasicMessageConsumer_0_10) of looking at the durable property as one factor in deciding if it's case #1. A durable subscription does use a named queue, therefore it is not nessacery to look at the durable property in order to identify it as case #1. I have made modifications to createDurableTopic method in AMQTopic to set the queue name in the link properties. The above changes enable a user to create more than one consumer (each with it's own unique queue) when using the same destination created off an addressing string that has durable set to true. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999704 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2786Rajith Muditha Attapattu2010-09-214-11/+52
| | | | | | | | Added logic to the AMQTopic class to handle the creation of the durable subscription topics using an addressing string. Modified the subscription queue creation to handle durable subscriptions. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999196 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2857 : Address issues found by running FindBugs against the Java codebaseRobert Godfrey2010-09-171-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998162 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2857 : Address issues found by running FindBugs against the Java codebaseRobert Godfrey2010-09-1218-49/+72
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@996393 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2418: updates to fix test failures when using the 0-10 client test ↵Robert Gemmell2010-09-054-12/+39
| | | | | | | | | | | profiles. Use a transacted session when querying for queue counts following consumption, as the 0-10 client batches auto-acks asynchronously. Always send the selector filter argument even if empty, to allow querying the brokers via 0-10 to detect whether the selector is being added/removed/modified at subscribe time. Enable the Java broker to perform argument matching during the 0-10 isBound check. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992856 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2418: Unsubscribe existing open durable subscriptions when changing ↵Robert Gemmell2010-09-054-220/+241
| | | | | | | | | subscription. Remove duplication in implementations. Applied patch from Andrew Kennedy <andrew.international@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992855 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2844Rajith Muditha Attapattu2010-09-021-2/+11
| | | | | | | If an entry within the x-bindings doesn't contain an exchange, the address name is used as the exchange if address resolves to an exchange else amq.topic is used. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992061 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2845Rajith Muditha Attapattu2010-09-022-92/+18
| | | | | | | | Added code to recognize an arguments map within the x-bindings section. Removed validation of the arguments specified in the above map. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992059 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2809Rajith Muditha Attapattu2010-08-201-1/+1
| | | | | | | Forgot to checkin this with my intial commit. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@987549 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2809Rajith Muditha Attapattu2010-08-203-52/+150
| | | | | | | This is also a workaround for QPID-2808 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@987505 13f79535-47bb-0310-9956-ffa450edef68
* Added -c count parameter - exits after reading c messages.Jonathan Robie2010-08-191-0/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@987303 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2657: Correct handling of sync on 0-10 client session for exceptionsAndrew Donald Kennedy2010-08-133-61/+95
| | | | | | | | | | AMQSession_0_10 is modified to contain a pair of get/set methods for the current exception, using the set method to post the exception to the listener. The sync method will now throw an exception if one has occurred and all other methods that used to call sync()/getCurrentException() can just call sync(0 and get the expected behaviour. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@985262 13f79535-47bb-0310-9956-ffa450edef68
* Tidy up various badly named testsAndrew Donald Kennedy2010-08-133-41/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@985259 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2799: Convert address with underscores for temp queue nameAndrew Donald Kennedy2010-08-131-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@985202 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2786Rajith Muditha Attapattu2010-08-051-17/+31
| | | | | | | | Removed the checking for dest style and instead added support for providing the address name and subject is the exchange name and routing key is null. Otherwise we would have to modify the hashcode, equals methods etc to take the dest style into account. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@982652 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2786Rajith Muditha Attapattu2010-08-041-1/+13
| | | | | | | | | | | This fix is only for creating a durable subscription without a selector. When creating a durable subscription with a selector a different code path is used. The patch in QPID-2418 attempts to fix the code duplication among other things. Once that patch is applied I may have to readjust the code. I will be adding a test case to DurableSubscriptionTest.java once the code is sorted out. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@982381 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2744: Property name check in wrong placeAndrew Donald Kennedy2010-08-031-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@981896 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2744: Unify 0-10 and 0-8 error messages for invalid object types in ↵Andrew Donald Kennedy2010-08-012-9/+7
| | | | | | properties git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@981231 13f79535-47bb-0310-9956-ffa450edef68
* Removed an import (related to a work-in-progress) that got accidently ↵Rajith Muditha Attapattu2010-07-291-106/+115
| | | | | | included in the AddressHelper.java git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@980287 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2774Rajith Muditha Attapattu2010-07-281-2/+3
| | | | | | | | If the exchange type is not specified, then it is set to null when parsing the string. If the exchange needs to be created, it's set to 'topic' if the exchange type is null. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@980259 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2738Rajith Muditha Attapattu2010-07-281-3/+19
| | | | | | | | | | The pre-aquire flag is now computed differently for each dest syntax type. For BURL the exchange type is also queried if the Destination is not an instance of AMQTopic. For ADDR, if the browse mode is set, then pre-acquire is set to false irrespective of the node type. We still continue to use pre-acquire=false if selectors are present. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@980232 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2766Rajith Muditha Attapattu2010-07-281-1/+5
| | | | | | | My initial checkin was not entirely correct as it does violate the JMS spec for property type conversion, since it will now first convert all property types (except Double) to a String and then on to a Double. Only Floats, Doubles, and Strings are allowed to be read back as a Double value, everything else should throw a MessageFormatException. Thx Robbie for pointing this out. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@980143 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2766Rajith Muditha Attapattu2010-07-281-1/+1
| | | | | | | Instead of doing Double.valueOf(Float.valueOf(value)) , I changed it to use Double.valueOf(value). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979933 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2675: Remove obsolete QpidExceptionAndrew Donald Kennedy2010-07-2615-142/+60
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979294 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2760: Only client 0-10 session sync should throw any exceptionsAndrew Donald Kennedy2010-07-261-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979290 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2697: Print AMQConnectionURL optionsAndrew Donald Kennedy2010-07-262-5/+25
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979212 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2744: Make 0-10 code path throw a MessageFormatException on null ↵Andrew Donald Kennedy2010-07-261-1/+5
| | | | | | setObjectProperty git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979201 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2752Rajith Muditha Attapattu2010-07-222-16/+12
| | | | | | | | | Added a test case to create and LVQ from the JMS client using the addressing syntax. Fixed a few bugs in QpidQueueOptions.java. Modified the MapAccessor to allow any value to be retrieved as a String. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966763 13f79535-47bb-0310-9956-ffa450edef68
* Sicne we have removed the old examples, this verify file is not needed any more.Rajith Muditha Attapattu2010-07-221-64/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966755 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-226-72/+81
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966722 13f79535-47bb-0310-9956-ffa450edef68
* Cleanup M2.x merge codeMartin Ritchie2010-07-221-11/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966681 13f79535-47bb-0310-9956-ffa450edef68
* 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
View Lorry Controller Status