summaryrefslogtreecommitdiff
path: root/qpid/java/client/src
Commit message (Collapse)AuthorAgeFilesLines
* Merge from trunk tag to-cmake-25mar09 (r758432)Stephen D. Huston2009-03-2527-416/+588
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/cmake@758465 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1665: changed acknowledgeMessage so to ack messages even if maxprefetch ↵Arnaud Simon2009-02-161-2/+2
| | | | | | is greater than 1 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@744917 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1623: Allow null as a valid destination for JMSReplyToAidan Skinner2009-02-113-2/+40
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@743367 13f79535-47bb-0310-9956-ffa450edef68
* Missed the modifications to FailoverRoundRobinServers.java during the commit ↵Rajith Muditha Attapattu2009-02-091-1/+1
| | | | | | | | | for QPID-1649 Missed the modifications to ServerDelegate during the cleanup done in rev 742269 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@742278 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1645Rajith Muditha Attapattu2009-02-091-0/+1
| | | | | | | | | Added support to specify the sasl_mechs as a space separated list in the connection URL. By default it will use PLAIN. You could provide a list of mechs to support or force to use one GASSAPI or CRAM-MD5 by specifying only that in the connection URL. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@742267 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1649Rajith Muditha Attapattu2009-02-095-4/+194
| | | | | | | There is some code in AMQConnectionDelegate_0_10.java related to QPID-1645 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@742260 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1644Rajith Muditha Attapattu2009-02-092-5/+8
| | | | | | | If the exchange name starts with "amq." then the passive flag will be set to true in the exchangeDeclare command git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@742255 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1654Rajith Muditha Attapattu2009-02-092-11/+65
| | | | | | | This contains the first step towards supporting a queue bound to any exchange type. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@742250 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for the problem highlighted in QPID-1374Rajith Muditha Attapattu2009-02-063-23/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@741754 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1609.Rajith Muditha Attapattu2009-01-236-41/+84
| | | | | | | | Currently we only check idle state on the incomming side. In the future we plan to add code to send a heartbeat when we reach the idle state on the outgoing side. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@737125 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1608Rajith Muditha Attapattu2009-01-211-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@736447 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1605: added an assertion to catch acknowledgments of message-ids ↵Rafael H. Schloming2009-01-217-45/+122
| | | | | | outside the range permitted on a session; added code to pause failover until messages from old sessions have been cleared out of the dispatcher queue git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@736316 13f79535-47bb-0310-9956-ffa450edef68
* This is related QPID-1479Rajith Muditha Attapattu2009-01-132-3/+25
| | | | | | | This commit contains the modifications for using the thread abstraction within MINA. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@734214 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1479Rajith Muditha Attapattu2009-01-131-18/+37
| | | | | | | This commit contains the core classes for adding the thread abstraction patch git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@734205 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1487: Make AMQDestination generate URLs with a destination set to the ↵Aidan Skinner2008-11-262-1/+43
| | | | | | routing key. Add a test for this. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@720919 13f79535-47bb-0310-9956-ffa450edef68
* Appologies for the sudden checkin without notice, close to the release cycle.Rajith Muditha Attapattu2008-11-211-37/+18
| | | | | | | Reverting the changes back. Will attach a patch and commit after the release. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@719657 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1479.Rajith Muditha Attapattu2008-11-211-18/+37
| | | | | | | | | | | | | | | For starters I have changed the IoSender.java IoReceiver.java and AMQSession.java#Dispatcher to use the Thread factory to create the threads they require. The ThreadFactory has two implimentations, the default being the java.lang.Threads. The other is the RealtimeThreadFactory which uses reflection to create threads with a specific priority. -Dqpid.thread_factory=<thread_factory_class> will decide which thread factory should be loaded. -Dqpid.rt_thread_priority=<int> specifies the gloabl real time thread priority and defaults to 20. You could also set individual thread priorities by adding the nessacery config+code changes. I have also changed the Testkit and QpidBench to use the Thread factory so you could use them for testing/benchmarking work on RT JVMs. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@719628 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1454 : Synchronize round the setting and usage of _failoverLatch, with ↵Martin Ritchie2008-11-181-3/+12
| | | | | | a new lock. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@718554 13f79535-47bb-0310-9956-ffa450edef68
* updated version numbers and release notes for M4Rafael H. Schloming2008-11-151-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@714267 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1430: *ahem* better fix for NPE on connection closeRafael H. Schloming2008-11-061-1/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711939 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1434 : Changed rethrow() name based on feedback from RobMartin Ritchie2008-11-061-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711848 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1431 : Prevent listeners being added to _frameListeners when an ↵Martin Ritchie2008-11-064-13/+739
| | | | | | exception state has occured due to connection closure. This adds additional synchronisation to the error handling condition. It also removes the need for a CopyOnWriteArrayList that was perhaps the wrong data structure for this list. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711822 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1326Rajith Muditha Attapattu2008-11-051-0/+4
| | | | | | | | If a transport is specified and if "//" is missing from the URL, an error will be thrown. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711740 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1430: fixed an NPE on connection closeRafael H. Schloming2008-11-041-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711377 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1420: swapped out the size limited ArrayBlockingQueue with a ↵Rafael H. Schloming2008-10-301-3/+4
| | | | | | LinkedBlockingQueue, this eliminates the need to coordinate the size of the synchronousQueue with the max prefetch, and hopefully prevents the deadlock described in the JIRA git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709244 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1339:Rafael H. Schloming2008-10-277-55/+127
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - Modified QpidTestCase to start/stop multiple brokers for failover testing. - Modified QpidTestCase to substitute port variables into broker start/stop commands. - Modified test profiles to use the new port variables. - Modified QpidTestCase to permit multiple exclude files. - Modified test profiles to make use of a common exclude list: ExcludeList - Added ConnectionTest.testResumeEmptyReplayBuffer. - Made default exception handling for Connection and Session log the exception. - Added SenderExcetion to specifically signal problems with transmitting connection data. - Modified Session to catch and deal with connection send failures for sessions with positive expiry. - Modified FailoverBaseCase to work for non VM brokers. - Made FailoverTest fail if failover times out. - Modified JMS implementation to make use of the recently added low level session resume. - Unexcluded failover tests from 0-10 test profiles. - Excluded MultipleJCAProviderRegistrationTest due to its testing strategy resulting in spurious failure when running as part of the larger test suite. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708093 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1394 : Registration of JCAProvider is incorrect in client and broker ↵Martin Ritchie2008-10-243-5/+19
| | | | | | SASL configurations git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707658 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1398: use bnd tool to produce osgi bundles with 'ant bundle'Aidan Skinner2008-10-241-0/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707654 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1296.Rajith Muditha Attapattu2008-10-231-1/+1
| | | | | | | I missed these two files in the previous commit. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707458 13f79535-47bb-0310-9956-ffa450edef68
* This is for QPID-1296Rajith Muditha Attapattu2008-10-231-1/+3
| | | | | | | | | | | | | added a boolean to the connect method to indicate whether an SSL connection should be created. currently there seems to be two issues. 1. The shutdownInput method used in IoReceiver is not supported by the SSLSocket implementation. 2. I haven't able to get client side authentication working. For item 1 we may need to use nio classes to get around the issue. For item 2 I am yet to figure out the correct config options to get client side auth working. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707453 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1319. Removed the unnessacery argument in the constructor.Rajith Muditha Attapattu2008-10-231-6/+1
| | | | | | | Now the code is changed back to what it was before the changes described in QPId-1319 was applied. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707452 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1319Rajith Muditha Attapattu2008-10-232-28/+2
| | | | | | | | Agree with Aidan that SSL should only be a broker level option. I have removed the code that copied the top level ssl value to the broker options. I will also correct the examples on the qpid wiki page git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707443 13f79535-47bb-0310-9956-ffa450edef68
* Clean up of code that is no longer being used.Rajith Muditha Attapattu2008-10-226-629/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707226 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1384: updated AMQDestination + added test for 0.10 code pathArnaud Simon2008-10-221-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@706894 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1374: Added handling of null message propertiesArnaud Simon2008-10-202-4/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@706166 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1373: Remove message for unack'd map when acking individual messages. ↵Aidan Skinner2008-10-171-0/+1
| | | | | | Add test. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@705658 13f79535-47bb-0310-9956-ffa450edef68
* s/setPrefecthLimits/setPrefetchLimitsAidan Skinner2008-10-171-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@705654 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1352: log the original exception so we don't lose the stack traceRafael H. Schloming2008-10-131-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@704187 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1289: Make 0-8/0-9 client honour the max_preftech system property.Aidan Skinner2008-10-104-16/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703383 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1339: refactor of low level client API to permit connections to exist ↵Rafael H. Schloming2008-10-0920-1506/+180
| | | | | | in a disconnected state as well as to provide a central point from which to track session state git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703208 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1335: moved Qman into java/management/clientArnaud Simon2008-10-0986-9653/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703177 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1327 - Added severity field to events, cleaned up routing key usageTed Ross2008-10-081-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@702977 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1327 - Event support for ManagementTed Ross2008-10-073-6/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@702651 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1319.Rajith Muditha Attapattu2008-10-073-8/+54
| | | | | | | | | | If SSL is specified as an option in the ConnectionURL then it will be copied to the broker level options. If SSL is also specified in the broker URL then it will override the value given at the top level. I also added a simple test case for this use case. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@702488 13f79535-47bb-0310-9956-ffa450edef68
* This is in response to Rafis comments on QPID-943.Rajith Muditha Attapattu2008-10-011-1/+5
| | | | | | | The userid is now converted into bytes using the UTF-8 encoding and the result is cached. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@700886 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1284: Qman unit testsArnaud Simon2008-09-2919-0/+2386
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@700134 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1284: Qman on behalf AndreaArnaud Simon2008-09-2967-0/+7263
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@700077 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for the java client for QPID-943.Rajith Muditha Attapattu2008-09-253-0/+10
| | | | | | | The 0-8 and 0-9 clients adds the user_id of the connection to the message properties before sending the message git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@699045 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1208: fixed ConnectionURLTest to match the new behavior of ↵Rafael H. Schloming2008-08-291-1/+2
| | | | | | AMQConnectionURL.toString() git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@690337 13f79535-47bb-0310-9956-ffa450edef68
* Add ASL to everywhere, to everything.Aidan Skinner2008-08-281-1/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@689937 13f79535-47bb-0310-9956-ffa450edef68