summaryrefslogtreecommitdiff
path: root/java/client/src
Commit message (Collapse)AuthorAgeFilesLines
* Update from trunk r1375509 through r1450773asyncstoreKim van der Riet2013-02-2851-964/+3101
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1451244 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3858: Updated code to include recent refactoring by Gordon (gsim) - see ↵Kim van der Riet2012-08-273-12/+29
| | | | | | QPID-4178. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1377715 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3858: Updated branch - merged from trunk r.1368650Kim van der Riet2012-08-0331-213/+489
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1368910 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3858: Updated branch - merged from trunk r.1333987Kim van der Riet2012-05-0425-308/+529
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1334037 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2660 : AMQMessageDelegate_0_10 uses Byte.valueOf() when converting ↵Robert Godfrey2012-02-202-0/+57
| | | | | | String properties to short, int, and long values git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1291260 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3836 Modified the address handling code to pass the noLocalRajith Muditha Attapattu2012-02-134-10/+19
| | | | | | argument to queue-declare method. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1243719 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3817: remove unnecessary cast to AMQQueue from the QueueBrowser ↵Robert Gemmell2012-02-132-3/+6
| | | | | | | | | creation path to allow their use with Address syntax 'destination.<address>' entries in JNDI properties files. Applied patch from Praveen Murugesan git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1243389 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3831: use AcquireMode=PRE_ACQUIRED when using server-side selectors and ↵Robert Gemmell2012-02-136-16/+12
| | | | | | consuming from Queues. Remove unused method parameter for selector filter. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1243384 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3440: add test to verify issue by ensuring that the reply-to ↵Robert Gemmell2012-02-132-14/+85
| | | | | | Destination cache results in use of the same Destination objects for subsequent messages. Implement equals() and hashCode() for the generated ReplyTo class to let it function properly as an index in the hashmap to resolve the issue. Update PropertyValueTest to remember the initial reply-to destination it sets and compare it with the value returned after sending/receiving the message, rather than constituting its own test destination for comparison. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1243380 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3819: ExhaustiveACLTests seen to timeoutKeith Wall2012-02-091-24/+1
| | | | | | | | | Backout changes to AMQStateManager made by QPID-3512 as these changes were causing the client to hang for 30 seconds after the Broker closed connection due to ACL violation. Refactored ConnectionCloseTest (now called BrokerClosesClientConnectionTest) to avoid the sporadic failure by verifying that the closed connection is reported correctly to the client. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1242338 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3807: Improve thread safety of JMS Session dispatcher.Keith Wall2012-02-071-21/+11
| | | | | | Make _dispatcherThread/_dispatcher volatile and remove their unused setters. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1241430 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Remove unnecessary getters added by recent commit 1236867Keith Wall2012-02-071-87/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1241429 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Move members back to top of class where they belongKeith Wall2012-02-071-181/+180
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1241428 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Remove redundant code from client and common trees.Keith Wall2012-02-063-134/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1241107 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3814: ensure the 0-10 client sends its version number during ↵Robert Gemmell2012-02-052-29/+16
| | | | | | ConnectionStart(Ok) process, align properties better across protocol versions, general tidy up of the property handling git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1240813 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3801 : [Java] Move JMS Selector code into commonRobert Godfrey2012-02-0219-2627/+222
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1239643 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3784: move the system property key into ClientPropertiesRobert Gemmell2012-02-022-7/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1239622 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3784: introduce system property to run a dispatcher thread as ↵Robert Gemmell2012-02-022-1/+77
| | | | | | | | damon/non-daemon thread. Changes dispatcher thread to be non daemon thread by default. 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/qpid@1239620 13f79535-47bb-0310-9956-ffa450edef68
* 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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@1211611 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status