summaryrefslogtreecommitdiff
path: root/java
Commit message (Collapse)AuthorAgeFilesLines
* QPID-1804 : Provide testing for Flow to Disk when using ack modes Client, ↵Martin Ritchie2009-04-102-3/+60
| | | | | | Transacted and No-Ack git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764080 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1791 : Replaced the get call before the dequeueAndDelete with a remove. ↵Martin Ritchie2009-04-102-4/+161
| | | | | | | | So the remove call after the delete is now nolonger requried. Added manual test to assist identifing the problem git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764079 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1794 : Moved processing of single message removals to just before the ↵Martin Ritchie2009-04-101-30/+29
| | | | | | transaction commit rather than before the dequeue. As previously the list of dequeues was being traversed for every dequeue in that transaction batch with nothing to do. So removing this loop should increase performance in large batch cases. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764078 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1803 : Fixed potential NPE in FileUtils.deleteMartin Ritchie2009-04-101-2/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764076 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1800: modify SAMQQ to record transactionlog etry even when queue isnt ↵Robert Gemmell2009-04-102-9/+65
| | | | | | durable(consistent with restof broker) and send both current and new queue to BTL for enqueue to ensure references are kept properly. Update BTL to check for prevous enqueues and record new enques in any existing list, despatching only new enqueues to the delegate git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764075 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1798: Update AMQQueueMBean to use new constant value of DeliveryMode, ↵Robert Gemmell2009-04-105-6/+12
| | | | | | replacing previously incorrect literal value used in conditional statement and thus preventing the reversal of delivery mode status. Also update other broker classes making similar comparisons using a literal value to use a constant git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764026 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1801 Added method to show failure to PrincipalPermissionsTest.java and ↵Marnie McCormack2009-04-102-2/+11
| | | | | | then adjusted the ternary operator in PrincipalPermissions.java to ensure we don't pass a null into the map (see JIRA descriptions). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@763959 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1794 : Removed unnecessary synchronisationMartin Ritchie2009-04-082-76/+70
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@763363 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1799 : Wrapped log statement so it doesn't perform resolution when not ↵Martin Ritchie2009-04-081-1/+4
| | | | | | logging. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@763362 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1794 : Clear the StoreContext after non-transactional processing. ↵Martin Ritchie2009-04-084-117/+148
| | | | | | Updated BaseTransactionLog to synchronize the on the enqueued messages from the _idToQueue Map as this will be being modified by many ack-ing threads and closing/requeue threads. Updated BaseTransactionLogTest so that it uses a single StoreContext per test rather than a fresh context for each operation. This was masking the problem. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@763361 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1793 : Increase logging on requeue to help diagnose what is being ↵Martin Ritchie2009-04-081-1/+9
| | | | | | requeued. Not on critical path so logging should not impact performance. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@763360 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1792: make JMXManagedObjectRegistry.close() method attempt to ↵Robert Gemmell2009-04-071-10/+15
| | | | | | de-register only qpid related MBeans, preventing the RuntimeException that is a result of attempting to de-register the platform MBeanServerDelegate MBean, which is not allowed. Also remove unused imports. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@762992 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1790: add new attribute to logging management mbean to indicate ↵Robert Gemmell2009-04-063-8/+45
| | | | | | available output levels. Update jmx management console to understand String[] attribute value and display contents properly git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@762365 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1764 : Updated all tests to use the TestTransactionLog interface and ↵Martin Ritchie2009-04-0316-261/+397
| | | | | | split testing code into subclasses. TestableTransactionLog will now correctly wrap a TransactionLog for testing. To enable testing of the BaseTransactionLog a TestableBaseTransactionLog was needed to only return values that are actually stored in the BaseTL the TestableTransactionLog actually stores single enqueues so that they can be queried by the test. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@761741 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1730: make it easy to configure queues, fix inheriting settings from ↵Aidan Skinner2009-04-037-21/+207
| | | | | | | | | | | | | the virtualhost. AMQQueue.configure: new method AMQQueueFactory: use AMQQueue.configure, don't set things directly SimpleAMQQueue.configure, MockAMQQueue.configure: implement new method from the interface QueueConfiguration: use VirtualHostConfiguration for default values if they're unset VirtualHostConfiguration: if a queue doesn't exist, give it a default configuration. Add methods to get default settings for configuration items QueueConfigurationTest: test case, checks that inheritance and defaults work along with explicitly set values. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@761721 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1764 : Resolved ConcurrentME. Perils of using the 'syntax sugar' for ↵Martin Ritchie2009-04-031-2/+17
| | | | | | loop hides the message iterator that you need to call .remove(). Calling remove on the underlying Map will cause the resulting CME. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@761700 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1784 : Fixed compile errorMartin Ritchie2009-04-031-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@761674 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1784 Update to FlowableBaseQueueEntryList to ensure that the inhaler ↵Martin Ritchie2009-04-031-5/+18
| | | | | | and purger threads will stop when the inMemory values are within the correct range. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@761671 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1764 : Update to BaseTransactionLog to create a TestableTransactionLog, ↵Martin Ritchie2009-04-037-88/+261
| | | | | | | | which will replace TestableMessageStore. Update to BaseTransactionLog/Test to work correctly with transactions and to fully test that functionality. Updated StoreContext to know when it is in a transaction as relying on a payload being set is not sufficient as that is not set when running with the MessageMemoryStore and so transactional testing in the BTLT was not correct. Update to Virtualhost to correctly set the RoutingTable when the specified TransactionLog is wrapped in a BaseTransactionLog. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@761670 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1778 : Increased delay as tcp testing takes longer than inVm. Now ↵Martin Ritchie2009-04-031-1/+2
| | | | | | checks failover doesn't occur and we know about it in less time than the connectiondelay which would be waited for if we attempted failover. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@761668 13f79535-47bb-0310-9956-ffa450edef68
* Fixed spelling errorMartin Ritchie2009-04-011-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760953 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1783 : Relax MessageFactory to allow out of order recoveryMartin Ritchie2009-04-012-18/+26
| | | | | | Relax MessageFactory to allow out of order. Updated test git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760952 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1764 : Add a BaseTransactionLog that takes care of handling persistent ↵Martin Ritchie2009-04-0120-176/+1124
| | | | | | | | | | | | | | | | | | | | | | message references so that the underlying TransactionLog need not worry about that. Updated MemoryMS to use this even to ensure that the code is exercised. To ensure that the new BaseTransactionLog was correctly used when used by a TransactionLog. The configure() method now returns an Object(TransactionLog) that is the newly configured TL. Existing tests and code where the original TL reference was used have been changed to use the output of the configure() call. NOTE: the return type should be changed to TransactionLog but until we have completely split the TransactionLog and RoutingTable implementations then this is not possible. The implementation also includes a number of items from the Flow To Disk review: - The old get* Methods have been removed from the TransactionLog interface. - Rollback should now rollback enqueues. (No test provided) - StoreContext now has enqueue/dequeue methods that track the messageId/Queue pairing - The linked list per message has been reduced to a link list per message that is enqueued on multiple queues. Messages that exist on only one queue have no additional overhead. - Optimisation also included to: Include message delete in 'dequeue transaction' where the message was only ever enqueued on a single queue. All other message deletes are peformed as part of an asynchrounous commit. The asynchrounous commit is setup via the StoreContext, which has had some work done to move it towards becomming a Qpid Transaction Object where all operations are performed against rather than going via the TransactionLog. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760951 13f79535-47bb-0310-9956-ffa450edef68
* Dial up default server threads to 32. Red ones go faster.Aidan Skinner2009-04-011-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760919 13f79535-47bb-0310-9956-ffa450edef68
* Dial down default log output to warn for non-qpid classes.Aidan Skinner2009-03-311-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760477 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1781Rajith Muditha Attapattu2009-03-312-2/+18
| | | | | | | Added an ant target called test-interop git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760312 13f79535-47bb-0310-9956-ffa450edef68
* This is a test case for QPID-1777Rajith Muditha Attapattu2009-03-312-0/+98
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760305 13f79535-47bb-0310-9956-ffa450edef68
* Reduce logging to ease CC buildsMartin Ritchie2009-03-271-3/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@759297 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1778 : Add NoFailover FailoverMethod that blocks that still allows ↵Martin Ritchie2009-03-275-5/+146
| | | | | | connection retry but only on the initial connection. Failover will not be attempted after an established connection is lost. Updated FailoverMethodTest to test this behaviour. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@759097 13f79535-47bb-0310-9956-ffa450edef68
* This is a simple fix for the problem highlighted in QPID-1777Rajith Muditha Attapattu2009-03-261-5/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758820 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1768 : Added multithreaded test to ensure multiple concurrent adds are ok.Martin Ritchie2009-03-261-0/+123
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758748 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1768 : Removed all the special priority queue code. Added the ability ↵Martin Ritchie2009-03-266-335/+89
| | | | | | | | | | | for a FlowableBaseQueueEntryList to delegate its accounting to a parent QueueEntryList. This results in the PriorityQueueEntryList using the same FtD algorithm as SimpleQELs. - New Messages on a flowed queue are pushed optimistically pushed to disk, this should potentially be removed and just rely on the purger to flush the correct message which in the Priority case may not be the last message in. - When space is available messages are loaded in queue order, so in this case Priority order. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758742 13f79535-47bb-0310-9956-ffa450edef68
* QPID-949 : renamed _disabled to _disableFlowtoDisk based on review feedbackMartin Ritchie2009-03-262-11/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758733 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1776: fix interpolation of variables.Aidan Skinner2009-03-262-4/+28
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758730 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1735 : Added Documentation to QueueBackingStore around thread safety of ↵Martin Ritchie2009-03-2511-122/+258
| | | | | | | | | | load/unload, Updated FQBS to adhere to the thread safety specified by the interface. QueueEntry was updated to return the AMQMessage from the load() to complete the getMessage() interface. As in a flowed state the message may be purged before a reference can be taken. Added new Test QueueEntryImplThreadingTest that should later be run for longer but aims to show that load always returns the message even when unloads are occuring asynchronously. Commit from 0.5-release : r758388 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758397 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1735 : Removed duplicated methods with differing functionality that was ↵Martin Ritchie2009-03-254-22/+8
| | | | | | | | | | causing FtD to fail. Annoyingly the tests work as they used the method with the extra functionality. Commit from 0.5-release : r758382 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758395 13f79535-47bb-0310-9956-ffa450edef68
* QEIT.testExpiry() only allows 10ms for creating the QueueEntry. Depending on ↵Martin Ritchie2009-03-251-7/+8
| | | | | | the running platform and the result of currentTimeMillis() it can be a close to allowing expiry git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758377 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1773Rajith Muditha Attapattu2009-03-241-1/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758017 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1662 : Converted PassiveTTL to a transacted session so we can ensure ↵Martin Ritchie2009-03-241-1/+6
| | | | | | all messages are on broker and aging before we start our sleep cycle. The transacted session won't affect the way messages age. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757696 13f79535-47bb-0310-9956-ffa450edef68
* The example verification was broken.Rajith Muditha Attapattu2009-03-2421-35/+35
| | | | | | | Fixed the verify files to use the correct paths for log4j file, python and c++ examples. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757641 13f79535-47bb-0310-9956-ffa450edef68
* This is to correct a mistake pointed out in the dev listRajith Muditha Attapattu2009-03-241-1/+1
| | | | | | | | The method connect(host, port, vhost, username, password, false,"PLAIN"); is using the hardcoded value false for the ssl paramter. This commit modified the code to use ssl as the parameter instead. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757640 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1511: add scripts to generate example ssl stores, and add refrence in ↵Robert Gemmell2009-03-223-1/+77
| | | | | | | | | the relevant exception message Merged from branches/0.5-release : r757268 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757270 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1767: add units to message age attribute descriptionRobert Gemmell2009-03-221-3/+3
| | | | | | | Merged from branches/0.5-release : r757257 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757258 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1763 : Fixed slow down due to fs lookup for unloaded message introduced ↵Martin Ritchie2009-03-201-5/+11
| | | | | | | | | | in r748516 Merged from branches/0.5-release : r756506 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756518 13f79535-47bb-0310-9956-ffa450edef68
* Fix for QPID-1761 and QPID-1762: made BBEncoder.grow() flip the buffer ↵Rafael H. Schloming2009-03-206-26/+80
| | | | | | before copying; added a BBEncoder test; made unrecognized mime types default to BytesMessage; added logging of exception root cause to AMQSession; fixed miscelaneous test failures git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756328 13f79535-47bb-0310-9956-ffa450edef68
* These classes are not used in any meaningful way.Rajith Muditha Attapattu2009-03-192-335/+0
| | | | | | | I am removing them to avoid any confusion they may cause. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756231 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1760Rajith Muditha Attapattu2009-03-194-47/+12
| | | | | | | | The AbstractBytesMessage will now use the toString method from AbstractJMSMessage Also I have modified the toBodyString method in AbstractBytesMessage to use a function that can handle unprintable charachters and print contents upto a maximum of 100 bytes. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756228 13f79535-47bb-0310-9956-ffa450edef68
* Modified README to match runSample.shJonathan Robie2009-03-191-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756072 13f79535-47bb-0310-9956-ffa450edef68
* Modified runSample.sh to use a relative path to the example source.Jonathan Robie2009-03-191-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756071 13f79535-47bb-0310-9956-ffa450edef68
* Changed the default location for examples.Jonathan Robie2009-03-192-2/+2
| | | | | | | | | | !!! HACK ALERT !!! These files have long contained a default path used in one particular vendor's installation. We need to fix this! Today's fix makes the default correct for at least that one vendor, but we need to find a better way to do this. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756032 13f79535-47bb-0310-9956-ffa450edef68