summaryrefslogtreecommitdiff
path: root/qpid/java/client
Commit message (Collapse)AuthorAgeFilesLines
* QPID-3990:Weston M. Price2012-05-141-4/+5
| | | | | | *Fixed inefficient and unnecessary log entry in XAResourceImpl.javal git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1338369 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3990: Multiple XAResources isSameRM behaviorWeston M. Price2012-05-142-28/+102
| | | | | | | | | *Track XAResource siblings in start/end methods *Added AMQXAResource interface *Added systemtest for new XAResource behavior *Refactored XAResourceTest to extend AbstractXATest git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1338355 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3994: trivial changes to the build.xml files to aid people regenerating ↵Robert Gemmell2012-05-131-0/+1
| | | | | | their Eclipse project files using Ant Eclipse following the Ivy related changes git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1337925 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3971: resolve CI failure (hopefully), make misc test improvementsRobert Gemmell2012-05-132-69/+58
| | | | | | | | | | | - Use File.createTempFile to target the tmp dir, hopefully resolving the CI failure, ensure it is deleted even if the test subsequently fails. - Use QpidTestCase system property handling, ensuring modified properties are unset/restored to prior values following the test. - Move the properties used in the test internally as opposed to loading from another file. - Verify the values returned from the loaded Context are as expected an not only non-null. - Remove unused imports, fields. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1337871 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3971:PropertiesFileInitialContextFactory cannot open file URIWeston M. Price2012-05-131-1/+0
| | | | | | | | *Fixed issue with unit test and temp file *Cleaned up PropertiesFileInitialContext getInitialContext() method git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1337830 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3994: add support for optionally retrieving FindBugs using IvyWeston M. Price2012-05-132-35/+51
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1337829 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3941 Moved the printing of header information into it's ownRajith Muditha Attapattu2012-05-091-29/+34
| | | | | | function so that it can be reused by the other classes. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1336277 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3986 : [Java Broker] Add producer flow control based on total disk usageRobert Godfrey2012-05-072-0/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1335290 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3791: PropertiesFileInitialContextFactory cannot open file URLWeston M. Price2012-05-031-19/+0
| | | | | | | | | | *Removing new test for now as absolute file path is not working on test machine *Excludes mechanism did not work to remove a single test, or the entire class *Will rework git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1333645 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3971: PropertiesFileInitialContextFactory cannot open file URLWeston M. Price2012-05-034-39/+114
| | | | | | | | | | *Added capability to read java.naming.provider.url from file:// URI *Added PropertiesFileInitialContextFactoryTest *Moved functionaly from old JNDIPropertiesTest to new test class *Minor cleanup. Added @SuppressWarnings annotation to PropertiesFileInitialContext git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1333586 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3864: fix licence URLRobert Gemmell2012-04-191-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1327912 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3911: Fix deadlock on concurrent invocation of MessageConsumer#close() ↵Robert Gemmell2012-04-062-21/+11
| | | | | | | | | | | | | | and Session#rollback() from consumer MessageListener This patch contains the following changes: - Add synchronization on AMSession#_messageDeliveryLock into MessageConsumer#close() in order to block until message listener in progress has completed(as required in JMS javadoc for MessageConsumer#close()). - Change the session dispatcher to stop messages delivery into consumer local message queue if the consumer in the process of closing. This eliminates the need to stop the dispatcher on rejecting pending messages for closing consumer. - Remove the synchronization on the dispatcher lock from AMQSession.Dispatcher#rejectPending and code to stop the dispatcher, as we are synchronizing on the deliveryLock now and incoming messages are not dispatched into closing consumers anymore. - Add a system test to reproduce the deadlock and verify its resolution. Applied patch from Oleksandr Rudyy <orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1310275 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3912: Client failover fails to reconnect if a previous attempted ↵Keith Wall2012-03-282-1/+7
| | | | | | | | reconnection has failed 'late' in the connection start process. Applied patch from Andrew MacBean <andymacbean@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1306208 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3913: Add functionality to upgrade bdbstore automatically on broker ↵Keith Wall2012-03-271-2/+5
| | | | | | | | start-up. Store message content using single chunk. Change store version to 6. Remove implementations of tuple bindings for previous versions. Applied patch from Phil Harvey<phil@philharveyonline.com> Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1305809 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3903: Session#close() should not wait forever if broker fails to ↵Keith Wall2012-03-252-22/+20
| | | | | | respond to channel close (0-8..0-9-1 protocols) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1304971 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3905: NullPointerException is thrown on rejecting messages whilst ↵Keith Wall2012-03-251-3/+3
| | | | | | closing the connection git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1304970 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3904: Java client should set AMQConnection#_closed flag on receipt of ↵Keith Wall2012-03-211-0/+2
| | | | | | 0-10 connection.close git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1303360 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3879: Session#close() on session can produce spurious "dispatcher is ↵Keith Wall2012-03-111-1/+1
| | | | | | not started" messages at ERROR to client logs git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1299426 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3884 Applying a patch by Kevin Conner.Rajith Muditha Attapattu2012-03-082-0/+24
| | | | | | | The message-acks are now sent when we "end" the transaction as opposed to sending them synchronously after each message. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1298564 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3885 Changed the log level for flow control messages to info (wasRajith Muditha Attapattu2012-03-081-4/+4
| | | | | | debug). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1298556 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3885 Applying a patch by Kevin Conner.Rajith Muditha Attapattu2012-03-088-43/+81
| | | | | | | | | For the most part it reduces noise by downgrading most log messages from info to debug. It also adds a if(logger.isDebugEnabled()) to save on any unnecessary (and potentially expensive) string concatenations. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1298555 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3864: Adjust version numbers on trunk for development toward 0.18Justin Ross2012-03-081-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1298340 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3605 : [Java Broker] Durable subscriber with no-local true receives ↵Robert Godfrey2012-02-282-0/+8
| | | | | | messages on re-connection git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1294884 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2621 : [Java Client] Calling QueueBrowser.getEnumeration on a stopped ↵Robert Godfrey2012-02-271-0/+4
| | | | | | connection will hang git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1294397 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2020 : [Java Client] create[Durable]ConnectionConsumer should throw ↵Robert Godfrey2012-02-271-4/+5
| | | | | | JMSException, not return null (until such time as QPID-3693 is completed) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1294370 13f79535-47bb-0310-9956-ffa450edef68
* QPID-792 : [Java Client] Validate queue browser selector on client side, not ↵Robert Godfrey2012-02-275-34/+101
| | | | | | broker git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1294194 13f79535-47bb-0310-9956-ffa450edef68
* QPID-509 : [Java Client] Messages sent to topics should not default to mandatoryRobert Godfrey2012-02-276-129/+150
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1294135 13f79535-47bb-0310-9956-ffa450edef68
* AMQP-24 : [Java Broker] Implement distributed transactions for AMQP 0-10Robert Godfrey2012-02-231-7/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1292984 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3095 : AMQBrokerDetails equals() and hashCode() methods do not adhere ↵Robert Godfrey2012-02-201-4/+4
| | | | | | to contract git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1291353 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@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@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@1243389 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3830: remove stale reference to old examples READMERobert Gemmell2012-02-131-2/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1243388 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3830: remove stale/confusing old 'examples' for the java clientRobert Gemmell2012-02-1327-2874/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1243385 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@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@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@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@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@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@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@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@1240813 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3801 : [Java] Move JMS Selector code into commonRobert Godfrey2012-02-0220-2635/+222
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@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@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@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