summaryrefslogtreecommitdiff
path: root/qpid/java/client/src
Commit message (Collapse)AuthorAgeFilesLines
* QPID-3790: Add a method AMQSession.getQueueDepth(AMQDestionation, boolean) ↵Robert Gemmell2012-02-014-14/+59
| | | | | | | | to sync session (if specified) before sending QueueQuery command Applied patch from Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com>. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1239166 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3789 : [Java Broker] Remove duplication between two password file ↵Robert Godfrey2012-02-013-3/+0
| | | | | | database implementations git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1239112 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3789 : [Java] Remove duplication of BytesDataOutput inner class, and ↵Robert Godfrey2012-01-315-419/+199
| | | | | | shared code in SessionAdapt[eo]rs git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1238868 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3604 Moved the draining of consumer queues further down to be doneRajith Muditha Attapattu2012-01-311-8/+6
| | | | | | | after we drain the dispatch queue. Since the message flow is now stopped we can drain the queues without grabbing the message-delivery-lock. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1238688 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3789 : [Java] Remove dead code and empty directoriesRobert Godfrey2012-01-303-601/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1237577 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3739: Java properties qpid.ssl.keyStoreCertType and ↵Keith Wall2012-01-291-2/+2
| | | | | | | | | | | | | | | qpid.ssl.trustStoreCertType have misleading names and would be better called qpid.ssl.[Key|Trust]ManagerFactory.algorithm * Introduced two properties qpid.ssl.KeyManagerFactory.algorithm and qpid.ssl.TrustManagerFactory.algorithm to allow a client user to override the algorithm name used when Qpid client constructs a KeyManager or TrustManager. * Continued to support qpid.ssl.keyStoreCertType and qpid.ssl.trustStoreCertType (now marked as deprecated) * Introduced a new Java Broker configuration key connector/ssl/keyManagerFactoryAlgorithm * Continued to support broker configuration key connector/ssl/certType (now marked as deprecated and will issue warning if used). * Changed the default from hardcoded 'SunX509' to the value(s) returned by KeyManagerFactory#getDefaultAlgorithm() and TrustManagerFactory#getDefaultAlgorithm(). This allows the Java Broker and Client to be used out of the box on non-Sun JDKs without having to set qpid.ssl.KeyManagerFactory.algorithm or qpid.ssl.TrustManagerFactory.algorithm. * Updated client docbook documentation. Tested both Java Broker and Client on IBM JDK and ensured all 0-10 and 0-9-1 profiles pass (including SSLTest which was failing prior to this change). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1237504 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3789 : [Java] fix regression caused by destination cache miss (by ↵Robert Godfrey2012-01-292-1/+7
| | | | | | further screwing with equality on AMQDestination) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1237331 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3789 : [Java] code tidyupsRobert Godfrey2012-01-2949-1614/+177
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1237273 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Encapsulate fields, use private members and accesors (keep ↵Robert Godfrey2012-01-2754-591/+927
| | | | | | checkstyle happy) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1236867 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Ensure all control flow statements use braces (keeping CheckStyle ↵Robert Godfrey2012-01-274-40/+139
| | | | | | happy) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1236647 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA : [Java] Tidy up import statements across the codebase, remove ↵Robert Godfrey2012-01-27149-957/+807
| | | | | | unused/redundant imports (keep Checkstyle happy) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1236638 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3786 Setting queueName, exchange and routingKey from informationRajith Muditha Attapattu2012-01-261-1/+15
| | | | | | given in the incomming message. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1236355 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3265 This is not a fix for this issue, but rather a minor step towards it.Rajith Muditha Attapattu2012-01-261-4/+4
| | | | | | | | It's incorrect to add the binding for the temp queue to the bindings object as if the destination is used with another consumer it will interfere. Therefore the qeueu bind is sent explictly. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1236198 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3604 Added sync() after sending message stop for each subscriber.Rajith Muditha Attapattu2012-01-241-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1235553 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3604 Once message stop is issued for each subscriber, the clientRajith Muditha Attapattu2012-01-242-1/+93
| | | | | | | | | | now drains the internal queues of each subscriber. It also drains the dispatch queue. These messages are then released without marking them as redelivered. Messages that were given to the application but were not acked are also released, but are marked as redelivered. All messages received upto that point are marked as completed. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1235550 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3688 Added a default constructor and allowed the destination string to ↵Rajith Muditha Attapattu2012-01-184-1/+34
| | | | | | be set and retrivied via a setter & getter. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1232992 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3763 Committing a patch by Weston Price.Rajith Muditha Attapattu2012-01-171-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1232605 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3604 Reverting the changes as it releases messages everytime theRajith Muditha Attapattu2012-01-112-38/+8
| | | | | | channel is suspended. This results in several test failures. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1230088 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3604 The code now drains individual consumer queues as well as theRajith Muditha Attapattu2012-01-112-6/+38
| | | | | | | | | dispatch queue (via syncDipatchQueue method) and releases both unacked and prefetched messages, while only the former being marked redelivered. Also all of these transfers are being marked as completed to ensure credits don't dry up. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229857 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3279, committing a patch by Weston Price.Rajith Muditha Attapattu2012-01-101-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229754 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1644 : Fix 0-8 Java Client to only declare amq.* exchanges passively ↵Robert Godfrey2012-01-081-9/+12
| | | | | | when creating a producer git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1228843 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3715: Fix the receiving of an empty ObjectMessage (without a body)Keith Wall2012-01-071-39/+13
| | | | | | Applied patch from Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1228583 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3716: restore throwing of IllegalStateException upon invoking ↵Robert Gemmell2012-01-063-4/+21
| | | | | | | | Session#getTransacted() on a closed session Applied patch from Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1228109 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3720 : [Java Broker] Implement Message GroupingRobert Godfrey2012-01-033-9/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1226930 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3714 : [Java] Performance ImprovementsRobert Godfrey2011-12-2814-121/+408
| | | | | | | | | | | | | | | | | | | | | | | | | | | | Persistence: Store message in same transaction as enqueue if possible Memory: Remove unnecessary (un)boxing Reduce unnecessary copying of message data Cache short strings Cache queues for a given routing key on an Exchange (0-9) Use a fixed size buffer for preparing frames to write out Other: Reduce calls to System.currentTimeMillis (0-10) Special case immutable RangeSets, in particular RangeSets of a single range/point (0-10) Special case delivery properties and message properties in headers (0-9) send commit-ok as soon as data committed to store Cache publishing access control queries (0-9) Optimised long and int typed values for FieldTables (0-9) Retain FieldTable encoded form (0-9) Cache queue and topic destinations git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1225178 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3659 The previous if statement for processing boolean props looks a bit ↵Rajith Muditha Attapattu2011-12-211-8/+12
| | | | | | convoluted. Changed it to a more simple and easily readable statement. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1221557 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3044: Implement JCA Adapter for Java JMS clientAndrew Stitcher2011-12-183-5/+43
| | | | | | - Large contributions from Weston Price & Kevin Conner git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1220336 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3691: failover should sync once before reporting failover successKeith Wall2011-12-161-0/+1
| | | | | | Applied patch from Andrew MacBean <andymacbean@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1215113 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3625 Comitting a patch from Weston Price.Rajith Muditha Attapattu2011-12-125-15/+73
| | | | | | (cherry picked from commit e7b630fd35055c9b80e3799c6939c7f3687b0c02) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1213290 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3625 Reversing the change we made as AUTO_ACK seems correct.Rajith Muditha Attapattu2011-12-091-1/+1
| | | | | | | | For the specific changes required for the JCA case we will be exploring other alternatives. (cherry picked from commit 3223886060101a3f471ad7f33fa07647d5ba2752) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1212554 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3625 Commiting the patch by Weston Price.Rajith Muditha Attapattu2011-12-081-3/+3
| | | | | | (cherry picked from commit fe3d0c1184bb124973e2cd7e451a67ac4a52a692) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1211959 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3659 Added a method in AMQBrokerDetails to handle booleanRajith Muditha Attapattu2011-12-071-7/+21
| | | | | | | | | properties which defaults to "True". I also added a log message to printout the TCP_NODELAY value returned by the sockets getTcpNoDelay() method as a way of figuring out the exact settings. (cherry picked from commit d2377ceb08af030e95ccc3d578df2d59ca3933c1) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1211611 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3662: Only display connection options once in toString of URLAndrew Donald Kennedy2011-12-062-10/+28
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1211061 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3661: Add Dynamic-Import-Package wildcard entry to client .bnd fileAndrew Donald Kennedy2011-12-061-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1211060 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3654: ANONYMOUS SASL mechanism does not work on Java clientAndrew Stitcher2011-11-301-2/+3
| | | | | | | | | Added a CallbackHandler for the ANONYMOUS mechanism (even though it should never be called) - This is necessary because the client uses the map of callback handlers to construct the list of available mechanisms. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1208733 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3642: Fix for redelivery regression found by python testsKeith Wall2011-11-301-4/+0
| | | | | | Applied patch from Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1208435 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3642, QPID-3640: Add Dead Letter Queue functionality for 0-10 path. ↵Keith Wall2011-11-282-10/+39
| | | | | | | | Also, it fixes issue with setting of redelivered flag for pre-fetched messages as DLQ functionality relies on this flag being set correctly. Applied patch from Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1207031 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3642,QPID-3643: Add Dead Letter Queue functionality for 0-8/0-9/0-9-1 ↵Keith Wall2011-11-2813-52/+453
| | | | | | | | paths, fixes isBound methods on FanoutExchange Applied patch from Keith Wall <keith.wall@gmail.com>, Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1207029 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3582: Client reporting "Unable to load custom SASL providers" during ↵Keith Wall2011-11-221-6/+0
| | | | | | connection git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1205197 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2703: 0-10 Transaction rollback/recover does not restore consumer creditKeith Wall2011-11-173-30/+17
| | | | | | | Defect in Java client. 0-10 requires that commands are completed, but the Java client was failing to complete those commands corresponding to messages that were being rolled-back/recovered. Work by Robbie Gemmell and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1203139 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3610: set TCP_NODELAY to true by default, add new system property for ↵Robert Gemmell2011-11-111-10/+21
| | | | | | changing default, add unit tests for system properties + connection url options. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1200803 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3539: NoLocal should occur at the connection level and not the session ↵Keith Wall2011-11-101-1/+2
| | | | | | | | level (0-10). Also fixed typing issue that prevented Java Broker understanding the no-local queue argument when encoded as String (as sent by Python tests). Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1200335 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3519: refactor consumer argument handlingKeith Wall2011-11-097-52/+45
| | | | | | Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1199664 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3518: Introduce client side ability to detect server side support.Keith Wall2011-11-099-35/+88
| | | | | | Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1199662 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3536: 0-10 overrides JMS AcceptMode with a defaulted (not explicitly ↵Keith Wall2011-11-073-23/+3
| | | | | | | | set) Link Reliability of UNRELIABLE Applied patch from Andrew MacBean <andymacbean@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1198701 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2848: refactored message consumer: pre-aquire, capacity decisions are ↵Keith Wall2011-11-0710-162/+259
| | | | | | | | moved into consumer, renamed field noConsume into browseOnly, cleaned up selector filter code. Applied patch from Andrew MacBean <andymacbean@gmail.com>, Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1198642 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3583: Update trunk version from 0.13 to 0.15Justin Ross2011-11-031-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1197304 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3562: move sending completions if necessary into postDeliver() so that ↵Robert Gemmell2011-10-302-11/+28
| | | | | | prefetch=1 has the expected impact for asynchronous transacted consumers git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1195213 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3532: make the 0-10 client hold the failover mutex during the failover. ↵Robert Gemmell2011-10-215-25/+58
| | | | | | | | Alter the Address resolution code to allow resolving addresses after failover. Add some more failover tests (inc ADDR based ones). Make the failover process notify any waiters in the session to abort and let failover proceed. Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1187279 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3542: ensure session complete sent for filtered out messagesKeith Wall2011-10-182-9/+41
| | | | | | Applied patch from Andrew MacBean <andymacbean@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1185580 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status