| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
| |
applied to queue.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@750867 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
big in inhaler/purger to ensure priority data is correctly reloaded.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749699 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749697 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749572 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749340 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
| |
adjusted.
QueueEntries are now the point of entry to load/unload rather than the List. This is because it is only the QueueEntryList that the QueueEntry that is attached to that can correctly account for the inMemory usage. In the Priority Queue case the priority queue does not know which sub list the QueueEntry is on. As the QEI knows it makes sence to request load/unload through the entry.
Set the default Maximum InMemory to -1, disabled.
Removed the FlowableQueueEntryList interface, merged with QueueEntryList
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749331 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
test exposed.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749315 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749285 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
management capabilities
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749282 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
depth in bytes rather than kilbytes, matching their respective setter methods. Augment the management console's navigation queue selection list to show the appropriate numbers
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749149 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
String to fix issue with createTempFile and absolute paths. Stop catching IOExceptions in saveAccessFile() and make calling methods catch them to check for and report failure and act accordingly to reverse actions in memory. Add additional unit tests to cover access rights file manipulation.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748686 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
required hashing itself in order to present a consistent interface for user management. Alter management console to use mbean versioning to detect this and send plaintext to v2+ user management mbeans. Update RMIPasswordAuthenticator to make use of the new PD input consistency
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748680 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
by the management console and cached in memory like the B64MD5 PD. Add unit tests for the PlainPD
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748641 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
comments from robbie.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748591 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
SIGHUP. Add jmx method to do so.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748561 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
values from AMQMessage, _flags and expiry this allows the checking of immediate delivery and expiry on unloaded messages.
Updated nomenclature to use load/unload rather than the overloaded flow/recover.
Created new FileQueueBackingStoreFactory to ensure that validates and creates initial flowToDiskLocation and creates a new BackingStore.
Responsibility for FlowToDisk has been added to the QueueEntryLists. This will allow the easy unloading of the structure in the future. Inorder to do this the size,count and memory count properties had to be moved from the SimpleAMQQueue to the QueueEntryList.
An Inhaler thread was created in addition to the synchronous loading of messages. This is initiated as a result of a flowed QEL dropping below the minimumMemory value.
A test to ensure that the queue never exceeds its set memory usage and that the count does not go negative has been added to SimpleAMQQueueTest.
The SimpleAMQQueue is responsible for deciding when a message can be unloaded after delivery takes place. The QEL cannot decide this as there is no state for a message being marked as sent to a consumer. Only Aquired and Dequeued. The unloaded message is only deleted after the QueueEntry is deleted from the QEL. This negates the need to recreated the data on disk if the message needs to be unloaded again.
All files/directories relating to FtD are created as deleteOnExit files so that under clean shutdown the VM will ensure that the files are deleted. On startup the flowToDiskLocation is also purged to ensure a clean starting point.
SAMQQueueThreadPoolTest was augmented to take in to account the new inhaler executor reference.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748519 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
QueueEntry to allow processing whilst messasge has been flowed. Moved : _flags (for Immediate and delivered status), expiry, messageID. Created base class to maintain counts of data and objects in queue. Removed this responsibility from the AMQQueues and on to the QueueEntryLists. This will more easily allow the QEL structure to be flowed to disk at a later stage. Updated tests as a result of moves.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748516 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
logging.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748514 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748513 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747875 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
reloading of log4j file. Update sample log4js so that they aren't arbitrarily rewritten.
Patch from Robbie Gemmell <gemmellr@dcs.gla.ac.uk>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747870 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
style issue with field name.
Patch from Robbie Gemmell <gemmellr@dcs.gla.ac.uk>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747869 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Patch from Robbie Gemmell <gemmellr@dcs.gla.ac.uk>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747868 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
are bugs in ApplicationRegistry.close that prevent this from working.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747783 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
complete this JIRA.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747755 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
FileQueueBackingStore. Tested by FileQueueBackingStoreTest.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747754 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
getters/setters from the ServerConfiguration and Management Console.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747753 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747751 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747376 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
new-style file parsing.
This depends on an upgraded commons-configuration, which needs commons-digester and commons-beanutils.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747370 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
housekeeping timer.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747369 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747367 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747363 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
be disabled. Updates as a result of merging configuration changes.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@746265 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
reduced in size as reference counting is now not modified until the transaction completes.
Replaced MessageReferenceCoutingTest with PersistentMessageTest and further tests wil be created when DerbyDBMessageStore is also updated.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@746260 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
TransactionLog based reference counting
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@746259 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
SecurityConfiguration classes. Move almost all uses of o.a.commons.configuration.Configuration behind there.
@Configured delenda est
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@745799 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
all references and provided a test to ensure that whilst we are transitioning the configuration we can use the old MessageStore classes that now implement both interfaces without any config updates. Updates to the configuration can come when the store are renamed *TransactionLog
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@744184 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
messagIDs. Several tests needed updating as they relied upon specified messageIDs.
Added a recovery mode to the MessageFactory where by new messages can have their ids specified but only as long as the new id is larger than the last one.
Recovered messages are always persistent.
Simplified a interfaces as a result of not requiring the messageID to be passed through.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@744140 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
based JMXConnectorServer in use, enforces use of the custom MBeanInvocationhandlerImp when using the RMI based JMX, and implements a customised RMI registry to prevent external changes being possible. Updated Management console accordingly.
Patch from Robbert Gemmell <gemmellr@dcs.gla.ac.uk>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@744113 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
Transient/PersistentAMQMessage implementations
Removed the use of WeakReferences from PersistentAMQMessage and therefore the need to have a StoreContext on get requests.
NOTE: this checking will break persistent recovery.
Coverted all uses of *MessageHandle to AMQMessage. A number of tests (SimpleAMQQueueTest, TxAckTest.TestMessage, AbstractHeaderExchangeTestBase.Message) still use a custom constructor on Transient/PersistentAMQMessage. This is because they have their own Message implemntations that are used for testing. However, I'm sure they could be modified to override the required functionality rather than attempt to use the existing Factory and Wrap the resulting Message. A new JIRA to address this QPID-1659.
QPID-1628 : The update to MessageFactory removes the commented out code
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@744079 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@744076 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@744074 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
| |
otherwise inactive.
AMQQueue, VirtualHost, MockAMQQueue: change name of removeExpiredIfNoSubscribers to checkMessageStatus.
AMQQueueMBean: remove unthrown exception
SimpleAMQQueue: add notification checks to checkMessageStatus, remove catch for JMException which checkForNotification no longer throws.
NullApplicationRegistry: set small housekeeping check period so that it runs freuqently and tests don't need to sleep for excessive periods of time
AMQQueueAlertTest: remove subsequent send, notification alerts shouldn't depend on queue activity.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743357 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
hostnames.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743311 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
creating an address.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743306 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Conflicts:
qpid/java/common/src/main/java/org/apache/qpid/util/NetMatcher.java
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743304 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743028 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
PluginManager: add support for getting ACLPluginFactories from OSGi and the ones we already know about.
*ApplicationRegistry*: return an ACLManager, not an ACLPlugin from getAccessManager.
ACLManager: use PluginManager to get all the available plugins. When being asked to authorize a particular request, hold a vote amongst all the plugins as to whether to allow or deny access.
ACLPlugin: return a ALLOWED/DENIED/ABSTAIN vote result. Fix typo in method name.
ACLPluginFactory: Factory class for ACLPlugins.
AccessResult: just use class SimpleName instead of getPluginName
PrincipalPermissions: return AuthzResult instead of boolean. Might want to maek use of Abstain for things it doesn't actually acare about instead of defaulting to Allowed.
AllowAll, DenyAll, BasicACLPlugin, SimpleXML: add Factory, return AuthzResult instead of boolean.
VirtualHost: get a new ACLManager and configure it with the virtualhost security section. Ensure that old config files which have the access_control_list outside of the main security.access section continue to work.
MockPluginManager: add mock class for tests
PluginTest: not having any plugins now returns an empty set, not null
MockAMQQueue: support name attribute
ACLManagerTest: tests for ACLManager class
ExchangeDenier, QueueDenier: new test classes for ACLManagerTest
PrincipalPermissionsTest: check for correct return result, not true/false anymore
Move plugin configuration to <security> section, not <security><access>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@742626 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
several annoynmous classes that did all the same work.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@742496 13f79535-47bb-0310-9956-ffa450edef68
|