| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@824198 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816261 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
ReadWriteThreadModel. Move the couple of necessary methods to Job.
Fix imports.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816232 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
service in the same class as it's acquired
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@815729 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
there's still stuff to process. Let the cleanup thread do that so that publishes
which are denied don't result in instant connection death.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@815705 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Allow an existing SocketConnector to be passed into a MINANetworkDriver, for
use with the ExistingSocket bit of TransportConnection.
Move the ExistingSocket stuff to one place, use MINANetworkDriver in
TransportConnection and make AMQProtocolHandler implement ProtocolEngine. Remove MINA specific gubbins from AMQProtocolHandler and AMQProtocolSession.
Move fireAsynchEvent to Job
Add getLocalAddress to AMQProtocolEngine
Move TestNetworkDriver to common
Use correct class for logger in AMQProtocolEngine
Check the exception is thrown properly in SimpleACLTest, make it a little less
prone to obscure race conditions.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@815704 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@812936 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@811326 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@810953 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
AMQMinaProtocolSession. Remove various now-unused classes and update references. Add tests for AMQDecoder. Net -1500 lines, +25% performance on transient messaging. Nice.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@810110 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
in the xml file, and relax the level-check to allow undefined system properties. Move the Log4J initialisation override inside Main instead of the startup scripts, and have it check for -Dlog4j.configuration first before engaging.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@805188 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
if the rename/move succeeds, and if not attempt a copy instead
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@805020 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
rename/move succeeds, and if not attempt a copy instead
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@805019 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
attempt the move if the new file is created successfully. Check if the rename/move succeeds, and if not attempt a copy instead
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@805018 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
the move if the new file is created successfully. Check if the rename/move succeeds, and if not attempt a copy instead
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@805017 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
JMXManagedObjectRegistry
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@804781 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Highlight the Runtime Loggers that have a level defined in the configuration file to aid inheritance visibility.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@804768 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
using the management console
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@804767 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
QpidLog4JConfigurator,protecting against concurrent access/modifications to the logging configuration file by JMX clients and the WatchDog thread.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@804766 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
initialisation process. Add QpidLog4JConfigurator that validates the XML file before allowing it to be applied. Alter startup behaviour to shut the broker down if the specified log4j XML file is present present but invalid. Uses the -Damqj.logging.level(defaults to info) with the log4j.properties file in the broker jar if the XML file is not found.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@804765 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@804201 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
before it is closed
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803652 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
all production environments it has shown to be but as the other tests highlight it will fail if the name is not as expected. Better to be defensive that just broken.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803651 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
the connection closed
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803650 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Logging Interfaces
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803649 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803648 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803647 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
cause the re-generation of the *Messages classes
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803642 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803639 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
processQueue thread
Made QueueLogSubject public so it can be reused by QueueActor
Updated SAMQQ to create a QueueActor for use during the processQueue thread run
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803638 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803636 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Update tests to ensure Owner is not present
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803635 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
the current Locale is not one that has a specific file.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@803630 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
return value to report the number of messages deleted. Updated management console accordingly, also indicating that it is only non-acquired messaes that are cleared
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@802819 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
be excluded due to the way we stop test brokers.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@802627 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@802626 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
sizes.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@802625 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
QueueEntryFilter based version that correctly excludes the final message if it has been deleted, and is in general easier to reason about than the previous version
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@802615 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
names/values for every Queue in the vhost in a single call. Remove previous viewQueueNamesDepths() method. Add new ManagedQueue attribute names constants, and a test to ensure any attributes added to the Queue MBeans in future are also added to the constants.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@802601 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@802128 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@802127 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
persistent stores
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@802113 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@801726 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
close logging on the Subscription Flush thread. Alternative would be to create a Virtualhost Logger.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@801725 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
replacement is performed. Encountered a problem creating Binding Tests where the brackets '[]' logged by the messsage caused the option removal to fail. Performing the removal before formatting will remove this problem.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@801724 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@801723 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@801720 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
exclusive flag on setQueue
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@801719 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
improved logging. Value should be retained in the Subscription for MC display
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@801715 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Subscription arguments.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@801712 13f79535-47bb-0310-9956-ffa450edef68
|