summaryrefslogtreecommitdiff
path: root/qpid/java/client/src
Commit message (Collapse)AuthorAgeFilesLines
* 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
* QPID-3546: update the highestDeliveryTag marker during failover to prevent ↵Robert Gemmell2011-10-132-5/+39
| | | | | | | | | | the stale value being used to set the rollback mark on the first rollback after failover. This commit only fixes the 0-10 client path, as fixing this on the 0-8/9/9-1 path currently would cause undesirable interaction with the issue in QPID 3521. Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1182793 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3542: Java client does not ack non-matching messages when using client ↵Keith Wall2011-10-112-67/+45
| | | | | | | | side selectors (CPP Broker) Applied patch from Andrew MacBean <andymacbean@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1181861 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3534: ignore transport exceptions raised whilst closing the network ↵Robert Gemmell2011-10-111-1/+10
| | | | | | | | connection after sending the close-ok reply, as these can prevent failover occurring and are actually related to the broker (incorrectly) having already closed the socket Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1181735 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3534, QPID-3535: make 0-8/0-9/0-9-1 client path simply close the ↵Robert Gemmell2011-10-101-1/+1
| | | | | | | | | underlying NetworkConnection instead of sending an erroneous ConnectionClose body after replying to the ConnectionClose from the broker or receving an unsupported protocol verison during initial connection negotiation. Stops the client making 2 seperate attempts to initiate failover, and removes possibility of the exception that can currently cause both of them to be skipped. Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1181204 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3526: ensure that the session is marked clean after ↵Robert Gemmell2011-10-071-0/+1
| | | | | | message.acknowledge() is used, add test to verify behaviour git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1179965 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2442: Make 0-10 TemporaryQueue#delete and TemporaryTopic#delete perform ↵Keith Wall2011-10-065-16/+52
| | | | | | the delete on the Broker git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1179754 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3525: stop the client from accidentally consuming the messages it is ↵Robert Gemmell2011-10-061-12/+24
| | | | | | | | actually trying to recover when using 0-8/9/9-1. Also stops it acking the message from the in-progress onMessage delivery after Session.recover() was called. Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1179699 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3527: update handling of auto-ack messages for 0-10 to send acks ↵Robert Gemmell2011-10-066-80/+53
| | | | | | | | (asynchronously) on a per-message basis rather than batching for 1 second, update handling for other ack modes to be clearer with respect to 0-8/0-10 behavioural differences. Remove some redundant methods from AMQSession, updating handling of 'no consume'/'isBrowseOnly' such that BasicMessageConsumer is always supplied a single consistent answer for whether it is non-consuming or not. Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1179698 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3526, QPID-3524: make sure the 0-10 client message.acknowledge() ↵Robert Gemmell2011-10-067-166/+118
| | | | | | | | actually acknowledges messages immediately, and does so synchronously, adding test to verify behaviour. Split acknowledge() and commit() methods into version specific session implementations for clarity/reuse, align 0-10 and 0-8/9 transacted publishing behaviour, refactor preDeliver and postDeliver methods, remove dead code from consumers. Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1179695 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3526: move duplicated methods into the parent abstract message ↵Robert Gemmell2011-10-065-191/+72
| | | | | | | | delegate, remove dead code from BassicMessageConsumer Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1179694 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3512: Avoid race during 0-8..0-9-1 connection close.Keith Wall2011-09-305-34/+59
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1177689 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3511: Removal of unused system property "qpid.default_wait_on_send" ↵Keith Wall2011-09-2811-107/+51
| | | | | | | | from Java Client. Applied patch from Andrew MacBean <andymacbean@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1176821 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3507: move the MessageListener check in front of the _receiving CASRobert Gemmell2011-09-271-4/+4
| | | | | | Applied patch from Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1176326 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3444: issue an invalid argument execution exception if the exchange ↵Robert Gemmell2011-09-252-2/+2
| | | | | | name is null or the empty string. Update some constants to ensure the error code is logged with the correct message git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1175625 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3466 Removed the extraneous toString()Rajith Muditha Attapattu2011-09-211-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1173693 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3415: Change 0-10 code path to utilise the CallbackHandlerRegistry to ↵Keith Wall2011-09-196-125/+550
| | | | | | create the correct CallbackHandler. The sasl_mechs property/broker option is retained, but continues to be understood only by the 0-10 path. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1172506 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3448: catch exceptions from the underlying Transport/Session/Connection ↵Robert Gemmell2011-09-138-48/+953
| | | | | | | | and rethrow as a JMSException like users are expecting Applied patch by Oleksandr Rudyy <orudyy@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1170182 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status