summaryrefslogtreecommitdiff
path: root/qpid/java/client
Commit message (Collapse)AuthorAgeFilesLines
* QPID-3177Rajith Muditha Attapattu2011-04-041-0/+2
| | | | | | | Porting the fix made in trunk at rev 1087890 into the 0.10 release branch. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.10@1088643 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: add missing ASF licenceRobert Gemmell2011-03-291-0/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.10@1086770 13f79535-47bb-0310-9956-ffa450edef68
* Porting rev 1079408 from Qpid trunk to 0.10 branch.Rajith Muditha Attapattu2011-03-091-1/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.10@1080013 13f79535-47bb-0310-9956-ffa450edef68
* Porting rev 1079402 from Qpid trunk to 0.10 branch.Rajith Muditha Attapattu2011-03-091-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.10@1080009 13f79535-47bb-0310-9956-ffa450edef68
* Porting rev 1078971 from Qpid trunk to 0.10 branch.Rajith Muditha Attapattu2011-03-092-4/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.10@1080006 13f79535-47bb-0310-9956-ffa450edef68
* Porting rev 1078961 from Qpid trunk to the 0.10 release branch.Rajith Muditha Attapattu2011-03-092-2/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.10@1080001 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Update branch versions to 0.10Andrew Stitcher2011-03-041-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.10@1078121 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2732Rajith Muditha Attapattu2011-03-033-2/+46
| | | | | | | | Only UNRELIABLE and AT_LEAST_ONCE is supported. Currently the reliability mode is used only for determining the accept-mode. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076800 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3109Rajith Muditha Attapattu2011-03-035-11/+67
| | | | | | | | | The isQueueExist method is modified to handle the exception when a queue has been deleted. Both the Message producer and consumer now delete the queue if the delete option is selected and will not check if the queue is empty or if there are any subscribers on it. Also added test cases. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076670 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3108: Allow QueueSender queue to be unidentified and still use gettersAndrew Stitcher2011-03-031-44/+43
| | | | | | | - Change error checks so that don't throw an incorrect exception in getters when the queue is null. This should only happen when sending. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076642 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2930Rajith Muditha Attapattu2011-03-031-1/+15
| | | | | | | | | | | The getPropertyNames method will filter out any property names whose values are not allowed as per the JMS spec. I could have used the ALLOWED map to check if a value is a valid type. But unfortunately that map contains byte[] as a valid type, which is not correct as per the JMS spec. I did not want to modify that map or the behaviour of the setObjectProperty or getObjectProperty methods as there might be applications out there that is depending on it. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076532 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3106Rajith Muditha Attapattu2011-03-032-36/+57
| | | | | | | Instead of checking if it's an instance of AMQQueue, the code the now checks if it's an instance of AMQDestination and javax.jms.Queue to cover the AMQAnyDestination case. The same check is done for topics. Added test cases for QueueReceivers, TopicSubscribers and DurableTopicSubscribers using the new addressing scheme. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076516 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3099Rajith Muditha Attapattu2011-03-012-0/+46
| | | | | | | | | | Added logic to look for the 'host' in the authority field if getHost returns null. Looking at the code that follows, you could definitely make more improvements. However since we are close to the 0.10 release I'd leave things as it is for the time being. I have also added test cases to cover the issues highlighted by the respective JIRA. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076011 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3098Rajith Muditha Attapattu2011-03-011-1/+2
| | | | | | | | This commit allows a MapMessage to accept an UUID object in it's setObject method. Added test cases for directly setting UUID objects or inside Maps and Lists that gets set into the MapMessage body. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075961 13f79535-47bb-0310-9956-ffa450edef68
* 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@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@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@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@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@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@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@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@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@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@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@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@1038773 13f79535-47bb-0310-9956-ffa450edef68
* Correct typosRobert Gemmell2010-11-221-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1037923 13f79535-47bb-0310-9956-ffa450edef68
* add README.txt file for Java client, include in the distributed binary ↵Robert Gemmell2010-11-222-1/+58
| | | | | | convenience archive git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1037881 13f79535-47bb-0310-9956-ffa450edef68
* Remove file from the old maven build systemRobert Gemmell2010-11-221-35/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1037878 13f79535-47bb-0310-9956-ffa450edef68
* 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@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@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@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@1032374 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1031321 ↵Rajith Muditha Attapattu2010-11-045-5/+87
| | | | 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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@987505 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status