summaryrefslogtreecommitdiff
path: root/java/client/src
Commit message (Collapse)AuthorAgeFilesLines
* Fixed various compilation errorsRajith Muditha Attapattu2008-01-168-49/+92
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612593 13f79535-47bb-0310-9956-ffa450edef68
* Please refer JIRA's 739,740 and 741 for more information about the issues.Rajith Muditha Attapattu2008-01-169-84/+72
| | | | | | | | | | | | | | | | | | | | AMQDestination Renamed the destinationName to routingKey as it is incorrectly used. Also modified it to recognize fannout exchange AMQQueue Modified to return the proper routing key to support situations where the queue name and the routing key is different. BasicMessageProducer_0_10.java Added a temp hack to interoperate with python. The bug is in python and it needs to be fixed. Basically python relies on the content length to pass the content frames properly. So I added a line to calculate the content length and sets it in the message properties. The rest was modified to reflect the change done in AMQDestination. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612581 13f79535-47bb-0310-9956-ffa450edef68
* see QPID-739Arnaud Simon2008-01-161-1/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612471 13f79535-47bb-0310-9956-ffa450edef68
* Added MESSAGE_FLOW_MAX_BYTES that is used by new examples. This value may ↵Arnaud Simon2008-01-161-0/+1
| | | | | | need to be changed as it has only be added to repair the build. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612396 13f79535-47bb-0310-9956-ffa450edef68
* see Qpid-721Arnaud Simon2008-01-041-7/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@608875 13f79535-47bb-0310-9956-ffa450edef68
* estSend2ThenCloseAfter1andTryAgain from CommitRollbackTest randomlyArnaud Simon2008-01-041-8/+8
| | | | | | | | fails because a message is not marked as redelivered (see line 468). I have removed this assertion check as 0.10 uses different semantics (i.e. 0.10 does not expect the message to be marked as redelivered). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@608868 13f79535-47bb-0310-9956-ffa450edef68
* cashed headers: see QPID-720Arnaud Simon2008-01-046-15/+80
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@608840 13f79535-47bb-0310-9956-ffa450edef68
* added "..qpidity" package (see Qpid-719)Arnaud Simon2008-01-041-0/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@608823 13f79535-47bb-0310-9956-ffa450edef68
* Qpid-710: changed start so connection is started before messages are deliveredArnaud Simon2007-12-171-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@604939 13f79535-47bb-0310-9956-ffa450edef68
* Qpid-709: nolocal test was failing because the inVM connections were not ↵Arnaud Simon2007-12-172-1/+16
| | | | | | created with a new connection ID. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@604926 13f79535-47bb-0310-9956-ffa450edef68
* Qpid-708: changed setCleintID to throw the expected exceptionArnaud Simon2007-12-171-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@604799 13f79535-47bb-0310-9956-ffa450edef68
* changed for accepting messages without headearsArnaud Simon2007-12-071-3/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@602116 13f79535-47bb-0310-9956-ffa450edef68
* Added a very basic plain nio transport. You could flip between the ↵Rajith Muditha Attapattu2007-11-303-5/+21
| | | | | | | | | transports using -Dtransport="nio". By default it's the MINA transport. You can also turn on batching for the nio transport by using -Dbatch="true". This option has no effect on MINA. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599856 13f79535-47bb-0310-9956-ffa450edef68
* added flushArnaud Simon2007-11-291-0/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599452 13f79535-47bb-0310-9956-ffa450edef68
* Setting the message to null to mark for garbage collectionRajith Muditha Attapattu2007-11-292-4/+7
| | | | | | | | noAck still has to clear our internal command ids. increased the default max prefetch to 1000 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599255 13f79535-47bb-0310-9956-ffa450edef68
* Enabled the broker module again, and Commented out the offending class that ↵Rajith Muditha Attapattu2007-11-291-5/+5
| | | | | | had compilation errors due missing classes from the new mina version git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599216 13f79535-47bb-0310-9956-ffa450edef68
* Added the JVM switch -DnoAck to disable the sending the semantic ackRajith Muditha Attapattu2007-11-271-1/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@598719 13f79535-47bb-0310-9956-ffa450edef68
* added a jvm switch called -DnoAck to disable the semantic ack, the current ↵Rajith Muditha Attapattu2007-11-271-2/+1
| | | | | | solution used a Qpid specific NO_ACK method in the extended session. However if people are using a pure JMS API then they have no way of taking use of this feature, therefore I added this jvm switch git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@598717 13f79535-47bb-0310-9956-ffa450edef68
* optimized message creationArnaud Simon2007-11-223-71/+108
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@597478 13f79535-47bb-0310-9956-ffa450edef68
* Removed exception thrown by setClientIDArnaud Simon2007-11-201-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@596660 13f79535-47bb-0310-9956-ffa450edef68
* Changed to use local methods instead of super onesArnaud Simon2007-11-131-10/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594500 13f79535-47bb-0310-9956-ffa450edef68
* Added a new set of performance tests which is more focused on getting the ↵Rajith Muditha Attapattu2007-11-121-4/+3
| | | | | | | | | | | throughput. The producers and consumers can be run from separate machines. There is no pass/fail, it merely records message count, memory etc at periodic intervals and prints a summary at the the end of the test. Since there are periodic entries, you could identify the rough time time it crashed and memory consumption etc. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594239 13f79535-47bb-0310-9956-ffa450edef68
* Uncommented the lines that caused me a compilation error (due to an out of ↵Rajith Muditha Attapattu2007-11-122-5/+5
| | | | | | data spec file) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594208 13f79535-47bb-0310-9956-ffa450edef68
* Chnaged the sync logic in the client session to ignore message headersRajith Muditha Attapattu2007-11-123-53/+85
| | | | | | | Fixed a compilation error in XAResourceImpl git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594204 13f79535-47bb-0310-9956-ffa450edef68
* Fixed a compilation error in XAResourceImplRajith Muditha Attapattu2007-11-122-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594203 13f79535-47bb-0310-9956-ffa450edef68
* added property for setting max message size before a syncArnaud Simon2007-11-092-4/+41
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593519 13f79535-47bb-0310-9956-ffa450edef68
* removed remote exchange class querying when standard exchanges are usedArnaud Simon2007-11-091-52/+81
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593486 13f79535-47bb-0310-9956-ffa450edef68
* cahnged for testing if the receiving thread is set before stopping itArnaud Simon2007-11-081-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593179 13f79535-47bb-0310-9956-ffa450edef68
* added several cr and xa testsArnaud Simon2007-11-081-0/+167
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593103 13f79535-47bb-0310-9956-ffa450edef68
* added several cr and xa testsArnaud Simon2007-11-082-0/+1839
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593101 13f79535-47bb-0310-9956-ffa450edef68
* added several cr and xa testsArnaud Simon2007-11-081-132/+39
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593099 13f79535-47bb-0310-9956-ffa450edef68
* added several cr and xa testsArnaud Simon2007-11-081-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593098 13f79535-47bb-0310-9956-ffa450edef68
* added several cr and xa testsArnaud Simon2007-11-081-2/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593097 13f79535-47bb-0310-9956-ffa450edef68
* Add support for array type to c++ (and python, decode only for now)Gordon Sim2007-11-062-4/+4
| | | | | | | | Change the type of the in-doubt field in dtx-coordination.recover to an array (to bring in line with amqp spec) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592494 13f79535-47bb-0310-9956-ffa450edef68
* Close connection on tear down (ensures no consumers are left active)Gordon Sim2007-11-061-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592330 13f79535-47bb-0310-9956-ffa450edef68
* changed to only run dtx tests when the broker version is not 0_8Arnaud Simon2007-11-051-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@591959 13f79535-47bb-0310-9956-ffa450edef68
* changed to only run dtx tests when the broker version is not 0_8Arnaud Simon2007-11-051-455/+471
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@591957 13f79535-47bb-0310-9956-ffa450edef68
* added dtx queue testsArnaud Simon2007-11-053-2/+730
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@591954 13f79535-47bb-0310-9956-ffa450edef68
* Changed for creating a dtx sessionArnaud Simon2007-11-051-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@591952 13f79535-47bb-0310-9956-ffa450edef68
* Changed for not acquiring messages if this is a browserArnaud Simon2007-10-291-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@589777 13f79535-47bb-0310-9956-ffa450edef68
* Changed queue browsing behavior: added timeout for receiveing next message ↵Arnaud Simon2007-10-262-2/+2
| | | | | | and set acquire mode to false git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@588678 13f79535-47bb-0310-9956-ffa450edef68
* Changed the way temporary queues are created so that we can porduce before ↵Arnaud Simon2007-10-263-7/+33
| | | | | | creating a consumer git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@588642 13f79535-47bb-0310-9956-ffa450edef68
* Changed to handle sync receive when connection is startedArnaud Simon2007-10-243-1/+45
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@587889 13f79535-47bb-0310-9956-ffa450edef68
* Updated to be 0_10 specificArnaud Simon2007-10-241-84/+198
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@587860 13f79535-47bb-0310-9956-ffa450edef68
* Removed JMS_QPID_DESTTYPE, note that this property is not used by 0_10 but ↵Arnaud Simon2007-10-241-2/+2
| | | | | | JMS provider properties must be removed from the delivered headers. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@587827 13f79535-47bb-0310-9956-ffa450edef68
* Added exception handlingArnaud Simon2007-10-241-1/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@587809 13f79535-47bb-0310-9956-ffa450edef68
* cahnged for using different destinationsArnaud Simon2007-10-247-7/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@587808 13f79535-47bb-0310-9956-ffa450edef68
* cahnged for setting the consumer before the producerArnaud Simon2007-10-231-7/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@587552 13f79535-47bb-0310-9956-ffa450edef68
* Added timeout for avoiding lockingArnaud Simon2007-10-191-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@586521 13f79535-47bb-0310-9956-ffa450edef68
* Updated for setting delivery mode of foreign messageArnaud Simon2007-10-191-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@586518 13f79535-47bb-0310-9956-ffa450edef68