| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
| |
this will affect all tests. The NoLocalAfterRecoveryTest now updates a ConnectionURL based on the JNDI data and uses that to start a connection. NLART also provides a default location for the derbyDB store as the DMS class does not correctly attempt to put the store in QPID_WORK. This will be re-addressed when ServerConfiguration is again available from a VHC object. ConnectionTest was updated to remove the literal values for the BrokerDetail options.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@765608 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
functionality after a broker restart.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@765604 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
null rather than an NPE.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@765600 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
virtualhost on recovery
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@765597 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
persistent store as they are always created first.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@765596 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Exchange or Queue
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@765593 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@765250 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
MessageStores rather than TransactionLogs
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@764850 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@764838 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
enqueue list, as it often wont be required
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@764113 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
during requeue and then throws that after it has attempted to requeue all the messsagse from the unackedMap.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@764111 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
cloned we can simply use the original list
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@764105 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Note: As our queues do not stop processing on the close() call it is possible that the backing store may not beable to be deleted. In this case all that will occur is that it will log the failure to disk so an operations team can manually clean it up. When we improve the Queueing model for AMQP 1-0 we can address this behaviour.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@764095 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
store. Also updated so that we store the queues evenly over 256 bins, thus giving us the ability to have around 8.1 million actives queues. The Hash function was borrowed from Apache Harmony. Added manual testing to ensure we are not limited by Linux's max file/dir per Inode of 31998. Made the test manual as creating 32000 queues does take a little while.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@764083 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
picked up from the configuration files.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@764082 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
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@764079 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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@764078 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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@764075 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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@764026 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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@763959 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@763363 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@763362 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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@763361 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
requeued. Not on critical path so logging should not impact performance.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@763360 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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@762992 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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@762365 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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@761741 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
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@761721 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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@761700 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@761674 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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@761671 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
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@761670 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Relax MessageFactory to allow out of order. Updated test
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@760952 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
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@760951 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@759297 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@758748 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
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@758742 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@758733 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@758730 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
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@758397 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
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@758395 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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@758377 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
the relevant exception message
Merged from branches/0.5-release : r757268
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@757270 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Merged from branches/0.5-release : r757257
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@757258 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
in r748516
Merged from branches/0.5-release : r756506
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@756518 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
KBytes, make size descriptions in other methods consistent
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@755256 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@754958 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@754934 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
before we had fully initialised it.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@753253 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
persistent recovery as we do not have a working persistent module.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@753220 13f79535-47bb-0310-9956-ffa450edef68
|