summaryrefslogtreecommitdiff
path: root/java/client/src
Commit message (Collapse)AuthorAgeFilesLines
...
* QPID-2979: Added SASL client plugin for ANONYMOUS; added call to register ↵Gordon Sim2011-03-014-0/+111
| | | | | | available plugins for 0-10 codepath. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1075871 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3008: Fix failover behaviour in 0-10 for QueueBrowserAutoAckTestAndrew Donald Kennedy2011-02-172-12/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1071631 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3047: Fix QueueDepthWithSelectorTest on 0-10Andrew Donald Kennedy2011-02-171-0/+1
| | | | | | Refactor test and fix 0-10 client session to flush acks git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1071620 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3016: Store soft references to ReplyTo destinationsAndrew Donald Kennedy2011-02-171-14/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1071462 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-048-165/+206
| | | | | | 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
* QPID-1670: Implement an UncaughtExceptionHandler to log exceptions causing ↵Robert Gemmell2011-02-042-19/+57
| | | | | | | | | the permature termination of Qpid client threads. Applied patch from Keith Wall <keith.wall@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1067108 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3022: enable the logging tests and fix issues causing failures due to ↵Robert Gemmell2011-01-271-0/+14
| | | | | | minor differences between 0-10 and 0-9 behaviour git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1064086 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3019Rajith Muditha Attapattu2011-01-256-14/+47
| | | | | | | | | The createMessageProducer method now throws a JMSException. The MessageProducer constructors now throw an AMQException allowing any exceptions caught during destination validation to be propogated back to the createMessageProducer method. Fixed the exception handling for the 0-10 code path where all exceptions are chained properly. This allows the user to get all the relavent information by examing the stack trace. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1063123 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3011Rajith Muditha Attapattu2011-01-202-8/+26
| | | | | | | | | | Commiting a fix as per the solution outlined in the above JIRA. A null check is added in the generateDestination method in AbstractAMQMessageDelegate.java where an ExchangeInfo object is created with just the exchange name to allow the destination to be created. The correct information will be querried when a consumer or producer is created with that destination. If a replyTo address is available then the exchange info for that is querried and updated within the updateExchangeTypeMapping method in AMQMessageDelegate_0_10.java git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1061577 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2994Rajith Muditha Attapattu2011-01-111-0/+1
| | | | | | | When the session is marked transactional, message transfers are not replayed. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1057460 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2959Rajith Muditha Attapattu2010-11-241-2/+4
| | | | | | | | If the exchange or routing key is null, it's now being set to empty string. If set to empty string the message will be sent to the nameless exchange. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1038773 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-1212-38/+61
| | | | 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
* 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
* 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
View Lorry Controller Status