activemq-flow. BrokerDatabase persistence enhancements w/ minor flow controller
refactoring
-------------------------------------------------------------------------------------------
Key: AMQ-2187
URL: https://issues.apache.org/activemq/browse/AMQ-2187
Project: ActiveMQ
Issue Type: Improvement
Affects Versions: incubation
Environment: N/A
Reporter: Colin MacNaughton
Fix For: incubation
The attached patch has the following enhancements:
1. Refactored Store interface: no longer key on MessageId/QueueSequence number,
instead use store tracking number for updates and deletes (still use queue
sequence for restore queires)
2. Refactored BrokerDatabase to batch more events per flush, and introduced a 5
ms flush delay for message adds to avoid having to sync to disk.
3. Openwire test classes updated to allow persistent (async) and durable
(dups-ok) producers and consumers.
4. Openwire and StompProtocol handlers updated. StompProtocol handler now does
database deletes for durable subscribers. Also updated the protocol handlers so
that input queues extends AbstractLimitedFlowResource
5. Introduced a StoreFactory for instantiating store impls.
6. Modified IFlowController interfaces to return IFlowResource instead of
IFlowSink and IFlowSource interfaces.
7. Adding the start of some database restore helpers (though theses are still
in rough shape)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
