summaryrefslogtreecommitdiff
path: root/java/client/src
Commit message (Collapse)AuthorAgeFilesLines
...
* NO-JIRA: delete unused folder with old testsRobert Gemmell2011-08-1844-6009/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1159198 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3377 Applying patch from Pavel MoravecRajith Muditha Attapattu2011-08-021-5/+6
| | | | | | | QPID-3381 Changed the code to use QpidMessageProperties.QPID_SUBJECT instead of the string literal. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1153298 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3381 Provided the ability to retrieve the routing key from a JMS ↵Rajith Muditha Attapattu2011-08-021-2/+7
| | | | | | message using getStringProperty(). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1153274 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3381 Added the class QpidMessageProperties as a place holder for Qpid ↵Rajith Muditha Attapattu2011-08-021-0/+34
| | | | | | specific properties, rather than using string literals all over the code. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1153272 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3263 Applying patch from Weston Price with the following modifications.Rajith Muditha Attapattu2011-08-023-8/+51
| | | | | | | | 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-3358 Added a controller to coordinate tests run on several jvm's on the ↵Rajith Muditha Attapattu2011-07-201-1/+1
| | | | | | | | | | | | | | | | | same host or multiple host machines. 1. The controller registers participants and waits until the desired numbers of producers and consumers join the test. 2. It then coordinates warmup runs between the participants and starts the actual test run. 3. Once the test is done it collects stats and computes averages,max,minetc.. and prints them out. The collector is designed run by itself, but can be run inline with a producer for simplicity. Infact by default the producer will run a controller unless -Dext_controller=true is specified. This is done to ensure that the simple test cases like the per-report script can be run without additional configuration. The code would need a bit of cleanup later on. The current form was done quite quickly as a POC for an urgent task. I will be reviewing the code and making improvements over the comming days. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1148935 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3345: restore/add ability to use sys props to select the ↵Robert Gemmell2011-07-141-2/+2
| | | | | | | | NetworkTransport used to make/accept connections Applied patch by Keith Wall <keith.wall@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1146594 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3269Rajith Muditha Attapattu2011-07-086-26/+84
| | | | | | | | | | | 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-0715-490/+10
| | | | | | | | 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-3342: transition TCP based Mina transport for 0-8/0-9/0-9-1 protocols ↵Robert Gemmell2011-07-0710-833/+71
| | | | | | | | over to new IO interface model Applied patch by Keith Wall and myself git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1143867 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3341: remove unused/dead transport code and accompanying implementation ↵Robert Gemmell2011-07-073-39/+4
| | | | | | | | classes Applied patch by Keith Wall and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1143865 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3331: Update trunk versions to 0.13 for the next releaseJustin Ross2011-06-301-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1141643 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3302 You can now get and set the app-id in AMQP 0-10 message properties ↵Rajith Muditha Attapattu2011-06-281-1/+13
| | | | | | using "x-amqp-0-10.app-id". git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1140412 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3270 A new enumeration is created off a static list for eachRajith Muditha Attapattu2011-06-221-14/+15
| | | | | | invocation of asEnumeration(). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1138296 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3270 The protocol version is now read from the Connection objectRajith Muditha Attapattu2011-06-221-4/+5
| | | | | | passed into when creating the ConnectionMetaData. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1138295 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3273 The JMS delivery mode is now used evaluated as a string instead of ↵Rajith Muditha Attapattu2011-06-201-5/+8
| | | | | | | | | | an integer. Added a test case to cover the JIRA. There was an existing test case (testUsingOnMessage) that had delivery mode in it's selector, but for some reason it was commented out. I decided to add a new one as I was not sure why the delivery mode was taken out of the selector in that test case. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1137804 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2158: add length validation into AMQShortString, remove dead code from ↵Robert Gemmell2011-06-071-107/+5
| | | | | | | | AMQDestinations, truncate exception messages with length over 255 before sending them over the wire in AMQChannelException and AMQConnectionException. Applied patch by Oleksandr Rudyy <orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1133037 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3277: AMQCallbackHandler improvements. Refactor AMQCallbackHandler to ↵Robert Gemmell2011-05-269-71/+230
| | | | | | | | 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-3254Rajith Muditha Attapattu2011-05-161-2/+2
| | | | | | | | | The default for routing key should be based on the context. i.e for sending it should be "" and for receiving it should be "#". However we currently don't have a way of handling this properly. Therefore defaulting it to "". git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1103884 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3220: Specifying connection url option failover='singlebroker' causes ↵Robert Gemmell2011-05-163-6/+343
| | | | | | | | | the wrong failover policy to be used. Wrote new unit test case and resolved the defect. Applied patch from Keith Wall <keith.wall@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1103857 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3254Rajith Muditha Attapattu2011-05-111-0/+5
| | | | | | | | Added a check to ensure that durable subscriptions are only created for Topics. Added code to mark a destination durable. If the addressing string explicitly specified durable==false, it will be overriden. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1102102 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3254Rajith Muditha Attapattu2011-05-113-15/+46
| | | | | | | | | Added logic to resolve the address to ensure corner cases such addresses without subjects are handled properly. The address resolotuion code will determine the defaults for subject (and routing key) by querying the name specified in the address. I also added null checks for getRoutingKey() method and getTopicName() method in both AMQTopic and AMQAnyDestination classes. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1102002 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3207Rajith Muditha Attapattu2011-05-111-1/+1
| | | | | | | | Rolling back the change until we fix the deadlock issue identified in QPID-3216 Also investigate the other test failure to see if there are any other issues besides the deadlock problem. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1101861 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3245Rajith Muditha Attapattu2011-05-041-0/+5
| | | | | | | The ack fusher task is now cancelled when the session is closed due to an error received from the broker. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1099634 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3233Rajith Muditha Attapattu2011-05-034-8/+66
| | | | | | | | If the underlying AMQP session gets closed, the JMS session is now notified along with details that caused the session closure. The JMS Session will throw an exception (with an error code and details) when a user accesses the closed session. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1099288 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3214Rajith Muditha Attapattu2011-05-031-3/+1
| | | | | | | | | Committing the suggested fix by Gordon Sim. All though the currentException may change by the time we call connection.exceptionReceived() it's not really a big issue. Chance of getting two successive sessions exceptions is rare if not none at all. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1099060 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3207Rajith Muditha Attapattu2011-04-141-1/+1
| | | | | | | Changed the value of sendClose to "true" as we need to send message-cancel if the session has not encountered any errors. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1092510 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3194Rajith Muditha Attapattu2011-04-081-1/+1
| | | | | | | Changed the keyword from "alt-exchange" to "alternate-exchange". git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1090422 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3194Rajith Muditha Attapattu2011-04-081-1/+1
| | | | | | | Added logic to use the alternate exchange when issuing the queue-declare. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1090421 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3182Rajith Muditha Attapattu2011-04-062-3/+6
| | | | | | | A queue-bind is now issue when creating a queue under node props or for the subscription queue under link props. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1089552 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3177: Add missing call to connection resumeAndrew Donald Kennedy2011-04-011-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1087890 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3167: add a unit test of SimpleAMQQueue#processQueue to check delivery ↵Robert Gemmell2011-03-302-2/+2
| | | | | | when subscriptions with unique selectors are in use git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1087000 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/trunk/qpid@1086769 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3156: Use MapAccessor to retrieve Boolean propertiesAndrew Donald Kennedy2011-03-241-15/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1085187 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3156Rajith Muditha Attapattu2011-03-231-1/+8
| | | | | | | | The address parser treats 'true' as a string while it treats 'True' as a boolean. Therefore I modified the AddressHelper class to expect both forms. The MapAccessor class used for the rest of code already handles this case. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1084462 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2959Rajith Muditha Attapattu2011-03-172-6/+14
| | | | | | | | | Added a temp hack to get the testReplyToWithNamelessExchange passing with the java.0.10 test profile. In doing so I realized that "qpid.declare_exchanges" has no affect on the producer side. Therefore I added a check in BasicMessageProducer_0_10.java to check this flag before issuing an exchange_declare. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1082715 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3143Rajith Muditha Attapattu2011-03-141-1/+0
| | | | | | | | | | | Removed the line which sets the create option to 'always'. Please note that the default create option is set to 'never'. Therefore if just a queue name is specified the client will throw an exception if that queue is not present in the broker. However this check will only be performed when a producer or consumer is created using that destination. Also modified the existing test case to verify the default and the explicit create case. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1081460 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2732Rajith Muditha Attapattu2011-03-081-1/+6
| | | | | | | | The reliability mode is now used on the producer side to determine replay. Any messages transfers sent to a destination marked unreliable will not be added to the replay buffer. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1079408 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3127: Set accept mode to NONE for NO_ACKNOWLEDGEAndrew Donald Kennedy2011-03-081-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1079402 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3109: Change close throws clause to match parent classAndrew Donald Kennedy2011-03-081-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1079059 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2732Rajith Muditha Attapattu2011-03-072-4/+19
| | | | | | | | Set the default reliability modes for Topics and Queues. The code now throws an exception if at-least-once is specified for Topics as we don't support it properly atm. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1078971 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3109Rajith Muditha Attapattu2011-03-072-3/+5
| | | | | | | | Added a null check for the destination in both MessageConsumer and MessageProducer close methods. According to the JMS spec the MessageProducer can be created with a null destination and still be used properly by specifying a destination on the send. Therefore this null check especially important on the message producer side. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1078961 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Update trunk versions to 0.11Andrew Stitcher2011-03-041-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1078098 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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@1075961 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status