summaryrefslogtreecommitdiff
path: root/java
Commit message (Collapse)AuthorAgeFilesLines
...
* NO-JIRA : [Java] Tidy up import statements across the codebase, remove ↵Robert Godfrey2012-01-27927-4533/+4515
| | | | | | 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-3559: AMQQueueMBean: Switched timestamp formatting to static ↵Keith Wall2012-01-261-18/+11
| | | | | | | | FastDateFormat instance to avoid the need for synchronisation or the generation of lots of SDF and Date instance garbage. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1236397 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-946, QPID-2379 : code review - move statements inside try blockRobert Godfrey2012-01-261-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1236332 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-3783 The AddressParser will now set the subject to Null if it equals to ↵Rajith Muditha Attapattu2012-01-261-0/+4
| | | | | | | | | | None. The only drawback is that if somebody wants to use a subject called "None" which is hard to imagine :) However even if they want to use such a subject it will not be easy to distinguish due to the fact we print null subjects as None. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1236196 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3779: replace the old ImmediateMessageTest and MandatoryMessageTest ↵Robert Gemmell2012-01-268-930/+213
| | | | | | | | with understandable versions and remove duplicate/obsolete tests FailoverTest and RollbackTest. 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@1236127 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3604 Added a note on the exclude fileRajith Muditha Attapattu2012-01-251-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1235872 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3604 Excluded testConnectionStop method from 0-91 profile as theRajith Muditha Attapattu2012-01-251-0/+1
| | | | | | fix was only made to the 0-10 code path. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1235795 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3780 : [Java Broker] reduce scavenge overhead on large queuesRobert Godfrey2012-01-251-18/+26
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1235771 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3604 Added a test case to cover this issue.Rajith Muditha Attapattu2012-01-241-0/+39
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1235556 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-3774 : Work around Java BDB issue with cursors and flushLogRobert Godfrey2012-01-211-63/+25
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1234410 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3774 : allow out of order completion of persistent enqueues / dequeues ↵Robert Godfrey2012-01-2121-40/+148
| | | | | | (0-9 codepath) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1234215 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3774 : allow out of order completion of persistent enqueues / dequeuesRobert Godfrey2012-01-2010-101/+627
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1234111 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3768: Refactor test case to avoid possibility of spurious test failureKeith Wall2012-01-181-29/+39
| | | | | | Changed impl of testGetNextWithAck() to avoid unsafe assumption that pre-fetching will mean sorting will never occur. Remove unnecessary message payloads used by some test (time in ms) as this was not contributing to test. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1233125 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-3756: ManagedConnectionMBeanTest.testChannels occasionally fails on ↵Keith Wall2012-01-182-20/+38
| | | | | | | | | | | 0-10 spawned profiles This problem is caused by the connection mbean being deregistered too late (as the TCP/IP socket) is closed, thus creating a race between the client using JMX to observe connection state, and the unregistering of the bean. This patch changes the 0-10 code path to unregister the bean on receipt of ConnectionClose and before ConnectionCloseOkay is sent to the client. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1232785 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3766 Committing a patch by Weston Price.Rajith Muditha Attapattu2012-01-171-12/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1232612 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3764 Committing a patch by Weston Price.Rajith Muditha Attapattu2012-01-173-6/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1232611 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-3720 : Fix issue with default group assignment pointed out by RobbieRobert Godfrey2012-01-161-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1232058 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3762: make sure to close the IoSender when the IoReciever indicates the ↵Robert Gemmell2012-01-161-1/+8
| | | | | | TCP connection went away, fixes leak for forcefully clsoed 0-9-1 connections git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1232032 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3761: rename the fallback config to ensure it isnt just picked up by ↵Robert Gemmell2012-01-164-8/+8
| | | | | | Log4J automatically scanning the classpath git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1232031 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3720 : Reorder an ack in the test to prevent spurious failuresRobert Godfrey2012-01-161-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1232022 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3758 : Reduce memory overhead of SessionsRobert Godfrey2012-01-131-40/+47
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1231141 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3697: SortedQueue synchronisation can cause deadlockKeith Wall2012-01-134-3/+86
| | | | | | | Sorted queue enqueue() should lock on a private rather than the lock of the object to avoid the possibility of a deadlock with a thread performing subscription operations. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1231095 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3747: Prefetch behaviour test occasionally fails on 0-10 profileKeith Wall2012-01-131-22/+28
| | | | | | Reorder the sequence of test to avoid the possibility that the 3rd message will go to the 'wrong' consumer. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1231094 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3753 : [Java Broker] Improve automatic conversion of messages between ↵Robert Godfrey2012-01-129-28/+417
| | | | | | 0-8/9/9-1 and 0-10 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1230661 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3635: Refactored testcase to make objectives more clearKeith Wall2012-01-128-359/+295
| | | | | | | | Move testPrefetchSystemProperty to PrefetchBehaviourTest for better division of responsibilities between tests. Split AMQConnectionTest into QueueSessionFactoryTest and TopicSessionFactoryTest. Removed AMQSSLConnectionTest as there is nothing transport specific and therefore added nothing not already tested by SSLTest. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1230477 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3720 : Fix bug which causes failure in 0-9-1 tests, namely ↵Robert Godfrey2012-01-111-3/+3
| | | | | | SimpleAMQQueue.QueueEntryListener assuming that all listeners are of the same type git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1230251 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3604 Reverting the changes as it releases messages everytime theRajith Muditha Attapattu2012-01-113-77/+9
| | | | | | 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-3720 : Remove debugging log statementsRobert Godfrey2012-01-111-3/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1230013 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3720 : Add alternative (C++ style) grouping and apply comments from ↵Robert Godfrey2012-01-116-209/+693
| | | | | | Robbie Gemmel git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229996 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3736 : Upgrade to BDB version 5.0.34Robert Godfrey2012-01-114-5/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229957 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3717 - Fixes based on review by Robbie GemmellRobert Godfrey2012-01-111-9/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229943 13f79535-47bb-0310-9956-ffa450edef68
* NO_JIRA Modified the test to stop the connection to ensure the consumerRajith Muditha Attapattu2012-01-111-5/+14
| | | | | | doesn't prefetch the messages until after the first message is replaced. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229858 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3604 The code now drains individual consumer queues as well as theRajith Muditha Attapattu2012-01-113-6/+77
| | | | | | | | | 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-3744, committing a patch by Weston Price.Rajith Muditha Attapattu2012-01-101-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229753 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3735, committing patch by Weston Price.Rajith Muditha Attapattu2012-01-101-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229619 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3705, committing patch by Weston Price.Rajith Muditha Attapattu2012-01-101-2/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229618 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3700, Committing patch from Weston Price.Rajith Muditha Attapattu2012-01-103-2/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229617 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3731, committing patch from Weston Price.Rajith Muditha Attapattu2012-01-101-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229612 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3733, committing patch from Weston Price.Rajith Muditha Attapattu2012-01-101-19/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229578 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3730: remove ReadWriteJobQueue, it is no longer necessary as the only ↵Robert Gemmell2012-01-098-528/+12
| | | | | | things now using the thread pool are write jobs, so there is no need/benefit to request it be write-biased. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229112 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: remove unused codeRobert Gemmell2012-01-092-5/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229111 13f79535-47bb-0310-9956-ffa450edef68
* QPID-946 , QPID-2379 : Fix for BDBUpgradeTest failure introduced by previous ↵Robert Godfrey2012-01-081-108/+117
| | | | | | commit git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1228853 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
View Lorry Controller Status