You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gr...@apache.org on 2010/10/13 17:06:27 UTC
svn commit: r1022127 [1/15] - in
/qpid/branches/grkvlt-network-20101013/qpid/java: ./
broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/
broker-plugins/access-control/src/test/java/org/apache/qpid/server/securit...
Author: grkvlt
Date: Wed Oct 13 15:05:29 2010
New Revision: 1022127
URL: http://svn.apache.org/viewvc?rev=1022127&view=rev
Log:
Network layer changes, and then some. Actual commit history preserved elsewhere...
Added:
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/BrokerActivator.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/BrokerInstance.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/StartupException.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/BrokerReceiver.java (with props)
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/BrokerReceiverFactory.java (with props)
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/configuration/ConfigurationFileTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/topic/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/topic/TopicParserTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/topic/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/mina/transport/socket/nio/ExistingSocketConnector.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/BrokerOptions.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/protocol/ReceiverFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/IncomingNetworkTransport.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/NetworkConnection.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/OutgoingNetworkTransport.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkConnection.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkHandler.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/mina/MinaNetworkConnection.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/mina/MinaNetworkHandler.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/mina/MinaNetworkTransport.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/vm/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/vm/VMBrokerCreationException.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/vm/VmBroker.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/transport/TestNetworkConnection.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/transport/TestNetworkTransport.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/transport/network/mina/MINANetworkTransportTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/lib/mina-core-1.1.7.jar (with props)
qpid/branches/grkvlt-network-20101013/qpid/java/lib/mina-filter-ssl-1.1.7.jar (with props)
qpid/branches/grkvlt-network-20101013/qpid/java/perftests/etc/scripts/extractAll.sh (with props)
qpid/branches/grkvlt-network-20101013/qpid/java/perftests/etc/scripts/extractWiki.sh (with props)
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/temporaryqueue/TemporaryQueueNameTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/transacted/TransactionTimeoutConfigurationTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/transacted/TransactionTimeoutDisabledTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/transacted/TransactionTimeoutTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/transacted/TransactionTimeoutTestCase.java
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/default.0.10.testprofile
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/default.0.8.testprofile
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/java-udp.0.10.testprofile
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/java-udp.testprofile
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/Configuration.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/MessageStoreTool.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/AbstractCommand.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/Clear.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/Command.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/Copy.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/Dump.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/Help.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/List.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/Load.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/Move.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/Purge.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/Quit.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/Select.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/messagestore/commands/Show.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/security/
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/security/Passwd.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/utils/
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/utils/CommandParser.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/utils/Console.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/utils/SimpleCommandParser.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/utils/SimpleConsole.java
Removed:
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/configuration/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/qmf/schema/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/configuration/plugin/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolEngineFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/MultiVersionProtocolEngine.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/MultiVersionProtocolEngineFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/security/access/management/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/security/access/plugins/network/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/QpidAcceptor.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/util/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/plugin/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/tools/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/logging/rawloggers/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/securiity/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/security/access/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/txn/
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/util/LoggingProxyTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/virtualhost/plugin/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/mina/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/DispatcherCallback.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/MessageConsumerPair.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/configuration/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/transport/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/vmbroker/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/collections/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/naming/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/njms/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/testutil/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpidity/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/client/protocol/MockIoSession.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/ack/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/close/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/connection/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/protocol/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/temporaryqueue/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/close/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/ct/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/transacted/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/xa/
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/testutil/
qpid/branches/grkvlt-network-20101013/qpid/java/client/test/src/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/mina/common/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/mina/filter/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/mina/transport/socket/nio/MultiThreadSocketAcceptor.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/mina/transport/socket/nio/MultiThreadSocketConnector.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/mina/transport/socket/nio/MultiThreadSocketFilterChain.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/mina/transport/socket/nio/MultiThreadSocketIoProcessor.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/mina/transport/socket/nio/MultiThreadSocketSessionConfigImpl.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/mina/transport/socket/nio/MultiThreadSocketSessionImpl.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/mina/transport/vmpipe/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/ConsoleOutput.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/QpidConfig.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/ToyBroker.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/ToyClient.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/ToyExchange.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/bio/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/protocol/ProtocolEngine.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/protocol/ProtocolEngineFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/thread/DefaultThreadFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/thread/QpidThreadExecutor.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/thread/ThreadFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/Binding.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/NetworkDriver.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/NetworkDriverConfiguration.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/TransportBuilder.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/ConnectionBinding.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/InputHandler_0_9.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoAcceptor.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoContext.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoTransport.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/mina/MINANetworkDriver.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/mina/MinaHandler.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/nio/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/util/SliceIterator.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedMessageQueueAtomicSize.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueNoSize.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/util/MessageQueue.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/util/PrettyPrintingUtils.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/util/concurrent/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpidity/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterClient.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterServer.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/pool/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/session/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/thread/
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/transport/TestNetworkDriver.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/transport/network/mina/MINANetworkDriverTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpidity/
qpid/branches/grkvlt-network-20101013/qpid/java/common/stylesheets/
qpid/branches/grkvlt-network-20101013/qpid/java/common/templates/class/
qpid/branches/grkvlt-network-20101013/qpid/java/common/templates/field/
qpid/branches/grkvlt-network-20101013/qpid/java/integrationtests/src/main/java/org/apache/qpid/perftests/
qpid/branches/grkvlt-network-20101013/qpid/java/integrationtests/src/main/java/org/apache/qpid/test/
qpid/branches/grkvlt-network-20101013/qpid/java/integrationtests/src/main/java/org/apache/qpid/util/
qpid/branches/grkvlt-network-20101013/qpid/java/integrationtests/src/resources/org/
qpid/branches/grkvlt-network-20101013/qpid/java/junit-toolkit/src/main/org/apache/qpid/junit/concurrency/
qpid/branches/grkvlt-network-20101013/qpid/java/junit-toolkit/src/main/uk/
qpid/branches/grkvlt-network-20101013/qpid/java/lib/backport-util-concurrent-2.2.jar
qpid/branches/grkvlt-network-20101013/qpid/java/lib/mina-core-1.0.1.jar
qpid/branches/grkvlt-network-20101013/qpid/java/lib/mina-filter-ssl-1.0.1.jar
qpid/branches/grkvlt-network-20101013/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/sasl/
qpid/branches/grkvlt-network-20101013/qpid/java/perftests/src/main/java/org/apache/qpid/perftests/
qpid/branches/grkvlt-network-20101013/qpid/java/resources/META-INF/
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/mina/
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/protocol/AMQProtocolSessionTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/testutil/
qpid/branches/grkvlt-network-20101013/qpid/java/testkit/etc/
Modified:
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/AccessControl.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/access-control/src/test/java/org/apache/qpid/server/security/access/plugins/AccessControlTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/systest/InfoPluginTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/HttpPosterTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/InfoServiceImplTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/InfoTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/IniFileReaderTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/SoapClientTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/SystemInfoTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/XMLWriterTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchangeType.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchange.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchangeType.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/test/java/org/apache/qpid/server/plugins/ExtrasTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/firewall/src/main/java/org/apache/qpid/server/security/access/plugins/Firewall.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/firewall/src/test/java/org/apache/qpid/server/security/access/FirewallConfigurationTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/firewall/src/test/java/org/apache/qpid/server/security/access/FirewallPluginTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/etc/log4j.xml
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/qmf/ManagementExchange.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQBrokerManagerMBean.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/Main.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/binding/Binding.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/binding/BindingFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/configuration/ServerConfiguration.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/configuration/VirtualHostConfiguration.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/configuration/plugins/ConfigurationPlugin.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/connection/ConnectionRegistry.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/connection/IConnectionRegistry.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/DefaultExchangeFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/DirectExchange.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/Exchange.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeInitialiser.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeType.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/TopicExchange.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/headers/HeadersParser.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/topic/TopicParser.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionOpenMethodHandler.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/handler/ExchangeDeclareHandler.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/logging/actors/CurrentActor.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/logging/messages/Channel_logmessages.properties
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/message/MessageTransferHeader.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQConnectionModel.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolEngine.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQSessionModel.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/ProtocolEngine_0_10.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/registry/IApplicationRegistry.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/security/AbstractPlugin.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/security/AbstractProxyPlugin.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/security/SecurityManager.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/security/SecurityPlugin.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/security/access/ObjectProperties.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/security/access/plugins/BasicPlugin.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/security/auth/database/PropertiesPrincipalDatabase.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/security/auth/sasl/crammd5/CRAMMD5HashedServerFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/security/auth/sasl/crammd5/CRAMMD5HexServerFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription_0_10.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerConnection.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerConnectionDelegate.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSession.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSessionDelegate.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/txn/AutoCommitTransaction.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransaction.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/txn/ServerTransaction.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostConfigRecoveryHandler.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/plugins/policies/TopicDeletePolicy.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/log4j/xml/QpidLog4JConfiguratorTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/ExtractResendAndRequeueTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/RunBrokerWithCommand.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/SelectorParserTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/configuration/QueueConfigurationTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/configuration/ServerConfigurationTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/ExchangeMBeanTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersBindingTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/logging/Log4jMessageLoggerTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/logging/actors/CurrentActorTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ConnectionLogSubjectTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/protocol/InternalTestProtocolSession.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AckTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueThreadPoolTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/registry/ApplicationRegistryShutdownTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/security/auth/database/Base64MD5PasswordFilePrincipalDatabaseTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/security/auth/database/HashedUserTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/security/auth/database/PlainPasswordFilePrincipalDatabaseTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/security/auth/database/PlainUserTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/security/auth/rmi/RMIPasswordAuthenticatorTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/security/auth/sasl/CRAMMD5HexInitialiserTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/security/auth/sasl/SaslServerTestCase.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/store/MessageStoreTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/util/InternalBrokerBaseCase.java
qpid/branches/grkvlt-network-20101013/qpid/java/broker/src/test/java/org/apache/qpid/server/util/TestApplicationRegistry.java
qpid/branches/grkvlt-network-20101013/qpid/java/build.deps
qpid/branches/grkvlt-network-20101013/qpid/java/client/example/src/main/java/org/apache/qpid/example/pubsub/ConnectionSetup.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/example/src/main/java/org/apache/qpid/example/pubsub/Publisher.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/example/src/main/java/org/apache/qpid/example/transport/ExistingSocketConnectorDemo.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/AMQAuthenticationException.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_8_0.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/failover/FailoverHandler.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionCloseMethodHandler.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_8.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/security/crammd5hashed/CRAMMD5HashedSaslClientFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/client/util/FlowControllingBlockingQueue.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/main/java/org/apache/qpid/jms/BrokerDetails.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/old_test/java/org/apache/qpid/mina/AcceptorTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/old_test/java/org/apache/qpid/mina/BlockingAcceptorTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/old_test/java/org/apache/qpid/mina/WriterTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/old_test/java/org/apache/qpid/multiconsumer/AMQTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/old_test/java/org/apache/qpid/test/unit/jndi/PropertiesFileInitialContextFactoryTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/client/AMQQueueTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/client/MockAMQConnection.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/client/message/AbstractJMSMessageTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/client/protocol/AMQProtocolHandlerTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/FieldTableKeyEnumeratorTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/FieldTablePropertyTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/BrokerDetails/BrokerDetailsTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/connectionurl/ConnectionURLTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/destinationurl/DestinationURLTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/message/BytesMessageTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/message/MapMessageTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/message/StreamMessageTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/message/TextMessageTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/jndi/ConnectionFactoryTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/jndi/JNDIPropertyFileTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/MessageConverterTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/AMQDisconnectedException.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/common/Closeable.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/thread/RealtimeThreadFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/thread/Threading.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/ServerDelegate.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/Assembler.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/Disassembler.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/Frame.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/InputHandler.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/NetworkTransport.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/Transport.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkTransport.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoSender.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/mina/MinaSender.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/SecurityLayer.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/sasl/SASLReceiver.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/sasl/SASLSender.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/main/java/org/apache/qpid/transport/util/Waiter.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/AMQExceptionTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/codec/AMQDecoderTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/framing/AMQShortStringTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/framing/BasicContentHeaderPropertiesTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/framing/PropertyFieldTableTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/framing/abstraction/MessagePublishInfoImplTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/test/utils/QpidTestCase.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/transport/GenTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/transport/RangeSetTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/transport/codec/BBEncoderTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/util/CommandLineParserTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/util/FileUtilsTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/common/src/test/java/org/apache/qpid/util/SerialTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/build.xml
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/configuration/ConfigurationTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/configuration/ConfiguratorTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/configuration/MappingParsersTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/domain/handler/base/ContentIndicationMessageHandlerTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/domain/model/BaseDomainModelTestCase.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/domain/model/BaseQpidFeatureBuilderTestCase.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/domain/model/OptionalPropertiesTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/domain/model/QpidClassTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/domain/model/QpidEventTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/domain/model/QpidNumberPropertyTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/domain/model/QpidStringPropertyTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/domain/model/type/BinaryTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/domain/services/BrokerMessageListenerTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/domain/services/MessageTokenizerTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/wsdm/BaseWsDmAdapterTestCase.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/wsdm/capabilities/MBeanCapabilityBuilderTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/wsdm/capabilities/MBeanCapabilityTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/wsdm/capabilities/QManAdapterCapabilityTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/client/src/test/java/org/apache/qpid/management/wsdm/capabilities/RmdBuilderTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/common/build.xml
qpid/branches/grkvlt-network-20101013/qpid/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedConnection.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/common/src/main/java/org/apache/qpid/management/common/sasl/CRAMMD5HashedSaslClientFactory.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/common/src/test/java/org/apache/qpid/management/common/mbeans/ManagedQueueTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/console/build.xml
qpid/branches/grkvlt-network-20101013/qpid/java/management/console/src/main/java/org/apache/qpid/console/QMFObject.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/console/src/test/java/org/apache/qpid/console/ClassKeyTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/eclipse-plugin/src/test/java/org/apache/qpid/management/ui/ApiVersionTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/eclipse-plugin/src/test/java/org/apache/qpid/management/ui/ApplicationRegistryTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/management/eclipse-plugin/src/test/java/org/apache/qpid/management/ui/ManagementConsoleTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/client/AMQQueueDeferredOrderingTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/client/DispatcherTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/client/MultipleJCAProviderRegistrationTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/server/failover/FailoverMethodTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/server/logging/BrokerLoggingTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/server/logging/ChannelLoggingTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/QueueDepthWithSelectorTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/server/security/acl/AbstractACLTestCase.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/systest/GlobalQueuesTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/systest/GlobalTopicsTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/systest/MergeConfigurationTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/systest/SubscriptionTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/systest/TestingBaseCase.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/systest/TopicTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/framework/qpid/CauseFailureInVM.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/framework/qpid/InVMBrokerDecorator.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/ack/QuickAcking.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/TextMessageTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/channelclose/ChannelCloseOkTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/channelclose/ChannelCloseTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/connection/ConnectionCloseTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/connection/ConnectionTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/close/CloseBeforeAckTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/xa/FaultTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/xa/QueueTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/xa/TopicTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java
qpid/branches/grkvlt-network-20101013/qpid/java/systests/src/main/java/org/apache/qpid/util/LogMonitorTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/08StandaloneExcludes
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/Excludes
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/Java010Excludes
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/JavaExcludes
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/JavaInVMExcludes
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/JavaPersistentExcludes
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/JavaStandaloneExcludes
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/JavaTransientExcludes
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/default.testprofile
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/java.0.10.testprofile
qpid/branches/grkvlt-network-20101013/qpid/java/test-profiles/test-provider.properties
qpid/branches/grkvlt-network-20101013/qpid/java/testkit/src/main/java/org/apache/qpid/testkit/Receiver.java
qpid/branches/grkvlt-network-20101013/qpid/java/testkit/src/main/java/org/apache/qpid/testkit/TestLauncher.java
qpid/branches/grkvlt-network-20101013/qpid/java/testkit/testkit.py
qpid/branches/grkvlt-network-20101013/qpid/java/tools/build.xml
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/LatencyTest.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/PerfConsumer.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/PerfProducer.java
qpid/branches/grkvlt-network-20101013/qpid/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/AccessControl.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/AccessControl.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/AccessControl.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/AccessControl.java Wed Oct 13 15:05:29 2010
@@ -75,17 +75,6 @@ public class AccessControl extends Abstr
{
return _ruleSet.getDefault();
}
-
- /**
- * Object instance access authorisation.
- *
- * Delegate to the {@link #authorise(Operation, ObjectType, ObjectProperties)} method, with
- * the operation set to ACCESS and no object properties.
- */
- public Result access(ObjectType objectType, Object instance)
- {
- return authorise(Operation.ACCESS, objectType, ObjectProperties.EMPTY);
- }
/**
* Check if an operation is authorised by asking the configuration object about the access
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/access-control/src/test/java/org/apache/qpid/server/security/access/plugins/AccessControlTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/access-control/src/test/java/org/apache/qpid/server/security/access/plugins/AccessControlTest.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/access-control/src/test/java/org/apache/qpid/server/security/access/plugins/AccessControlTest.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/access-control/src/test/java/org/apache/qpid/server/security/access/plugins/AccessControlTest.java Wed Oct 13 15:05:29 2010
@@ -23,12 +23,11 @@ import java.io.FileNotFoundException;
import java.io.FileWriter;
import java.io.PrintWriter;
-import junit.framework.TestCase;
-
import org.apache.commons.configuration.ConfigurationException;
import org.apache.qpid.server.security.access.config.ConfigurationFile;
import org.apache.qpid.server.security.access.config.PlainConfiguration;
import org.apache.qpid.server.security.access.config.RuleSet;
+import org.apache.qpid.test.utils.QpidTestCase;
/**
* These tests check that the ACL file parsing works correctly.
@@ -36,7 +35,7 @@ import org.apache.qpid.server.security.a
* For each message that can be returned in a {@link ConfigurationException}, an ACL file is created that should trigger this
* particular message.
*/
-public class AccessControlTest extends TestCase
+public class AccessControlTest extends QpidTestCase
{
public void writeACLConfig(String...aclData) throws Exception
{
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/systest/InfoPluginTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/systest/InfoPluginTest.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/systest/InfoPluginTest.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/systest/InfoPluginTest.java Wed Oct 13 15:05:29 2010
@@ -80,14 +80,13 @@ public class InfoPluginTest extends Qpid
startSoapServer();
// Must start the server first to identify a free port.
createConfigFile();
+ super.setUp();
}
public void tearDown() throws Exception
{
- System.out.println("*** Stopping socket server...");
_socketAcceptor.join(2000);
- System.out.println("*** Deleting the config file...");
if (_tmpCfgFile.isFile())
{
_tmpCfgFile.delete();
@@ -180,7 +179,6 @@ public class InfoPluginTest extends Qpid
}
};
_socketAcceptor.start();
- System.out.println("*** Socket server started...");
}
class ConnectionHandler implements Runnable
@@ -196,21 +194,17 @@ public class InfoPluginTest extends Qpid
public void run()
{
- System.out.println("*** Connection handler running...");
List<String> buf = new ArrayList<String>();
String line;
try
{
- BufferedReader br = new BufferedReader(new InputStreamReader(
- _socket.getInputStream()));
+ BufferedReader br = new BufferedReader(new InputStreamReader(_socket.getInputStream()));
assertNotNull(br);
while ((line = br.readLine()) != null)
{
buf.add(line);
}
br.close();
- System.out.println("*** Received buffer: " + buf);
- System.out.println("*** Latch countdown");
_latch.countDown();
synchronized (_recv)
{
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/HttpPosterTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/HttpPosterTest.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/HttpPosterTest.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/HttpPosterTest.java Wed Oct 13 15:05:29 2010
@@ -24,15 +24,14 @@ import java.util.List;
import java.util.Properties;
import org.apache.qpid.info.util.HttpPoster;
+import org.apache.qpid.test.utils.QpidTestCase;
import org.mortbay.jetty.testing.ServletTester;
-import junit.framework.TestCase;
-
-/*
+/**
* This test verifies that the plugin posts correctly to a webserver
* We use an embedded jetty container to mimic the webserver
*/
-public class HttpPosterTest extends TestCase
+public class HttpPosterTest extends QpidTestCase
{
private ServletTester tester;
@@ -41,7 +40,7 @@ public class HttpPosterTest extends Test
private final String contextPath = "/info";
- /*
+ /**
* This method generates a dummy HttpPoster with a dummy body containing a
* single line. The url we are posting to can be controlled by the parameter
* url
@@ -56,9 +55,7 @@ public class HttpPosterTest extends Test
return new HttpPoster(props, sb);
}
- /*
- * (non-Javadoc)
- *
+ /**
* @see junit.framework.TestCase#setUp()
*/
protected void setUp() throws Exception
@@ -70,9 +67,7 @@ public class HttpPosterTest extends Test
tester.start();
}
- /*
- * (non-Javadoc)
- *
+ /**
* @see junit.framework.TestCase#tearDown()
*/
protected void tearDown() throws Exception
@@ -81,7 +76,7 @@ public class HttpPosterTest extends Test
tester.stop();
}
- /*
+ /**
* This test is posting a string to an embedded Jetty Servlet and captures
* the response message. If the servlet receives the message ok, it will
* print Ok. A failure test is following where we post to a non-existent URL
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/InfoServiceImplTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/InfoServiceImplTest.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/InfoServiceImplTest.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/InfoServiceImplTest.java Wed Oct 13 15:05:29 2010
@@ -28,13 +28,12 @@ import java.util.Properties;
import org.apache.qpid.info.Info;
import org.apache.qpid.info.InfoServiceImpl;
+import org.apache.qpid.test.utils.QpidTestCase;
-import junit.framework.TestCase;
-
-/*
+/**
* This test verifies the invoke() method for the info service making sure that the parameters are returned
*/
-public class InfoServiceImplTest extends TestCase
+public class InfoServiceImplTest extends QpidTestCase
{
InfoServiceImpl _isi = null;
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/InfoTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/InfoTest.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/InfoTest.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/InfoTest.java Wed Oct 13 15:05:29 2010
@@ -23,14 +23,14 @@ package org.apache.qpid.info.test;
import java.util.HashMap;
import java.util.Properties;
-import junit.framework.TestCase;
+
import org.apache.qpid.info.Info;
+import org.apache.qpid.test.utils.QpidTestCase;
-/*
+/**
* This test verifies the toString(), toProps(), toXML() and toStringBuffer() methods of the Info object
- *
*/
-public class InfoTest extends TestCase
+public class InfoTest extends QpidTestCase
{
private HashMap<String, String> _infoPayLoad = null;
@@ -38,13 +38,12 @@ public class InfoTest extends TestCase
protected void setUp() throws Exception
{
- super.setUp();
_infoPayLoad = new HashMap<String, String>();
_infoPayLoad.put("test", "Test");
_info = new Info<HashMap<String, String>>(_infoPayLoad);
}
- /*
+ /**
* Test the conversion toString() of the Info object
*/
public void testToString()
@@ -54,7 +53,7 @@ public class InfoTest extends TestCase
"test=Test\n", _info.toString());
}
- /*
+ /**
* Test the conversion toProps() of the Info object
*/
public void testToProps()
@@ -66,7 +65,7 @@ public class InfoTest extends TestCase
.toProps());
}
- /*
+ /**
* Test the conversion toStringBuffer() of the Info object
*/
public void testToStringBuffer()
@@ -76,7 +75,7 @@ public class InfoTest extends TestCase
assertEquals(sb.toString(), _info.toStringBuffer().toString());
}
- /*
+ /**
* Test conversion toXML() of the info object
*/
public void testToXML()
@@ -93,7 +92,7 @@ public class InfoTest extends TestCase
.toXML().toString(), sb.toString());
}
- /*
+ /**
* Test the conversion toMap() of the Info object
*/
public void testToMap()
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/IniFileReaderTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/IniFileReaderTest.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/IniFileReaderTest.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/IniFileReaderTest.java Wed Oct 13 15:05:29 2010
@@ -21,9 +21,6 @@
package org.apache.qpid.info.test;
-import junit.framework.TestCase;
-import org.apache.qpid.info.util.IniFileReader;
-
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
@@ -31,11 +28,14 @@ import java.io.IOException;
import java.util.Map;
import java.util.Properties;
+import org.apache.qpid.info.util.IniFileReader;
+import org.apache.qpid.test.utils.QpidTestCase;
+
/**
* Test the Loading of the ini file reader by first writing
* out a correct ini file.
*/
-public class IniFileReaderTest extends TestCase
+public class IniFileReaderTest extends QpidTestCase
{
public void testLoad()
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/SoapClientTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/SoapClientTest.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/SoapClientTest.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/SoapClientTest.java Wed Oct 13 15:05:29 2010
@@ -21,9 +21,6 @@
package org.apache.qpid.info.test;
-import junit.framework.TestCase;
-import org.apache.qpid.info.util.SoapClient;
-
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
@@ -33,19 +30,25 @@ import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Properties;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
-public class SoapClientTest extends TestCase
+import org.apache.qpid.info.util.SoapClient;
+import org.apache.qpid.test.utils.QpidTestCase;
+
+public class SoapClientTest extends QpidTestCase
{
+ private final ExecutorService exec = Executors.newCachedThreadPool();
private int _port;
-
private final String _hostName = "localhost";
-
private final String _urlPath = "/testSoap";
-
private ServerSocket _server = null;
- /*
+ /**
* Generate a soap client from a custom URL, hostname, port and soap context
* path to be derived
*/
@@ -62,96 +65,90 @@ public class SoapClientTest extends Test
return new SoapClient(soapmap, destprops);
}
- /*
+ /**
* A connection handler class that verifies the correct message is received
- *
*/
- class ConnectionHandler implements Runnable
+ class ConnectionHandler implements Callable<Void>
{
private Socket socket;
public ConnectionHandler(Socket socket)
{
this.socket = socket;
- Thread t = new Thread(this);
- t.start();
}
- public void run()
+ public Void call() throws Exception
{
- String line;
- final List<String> response = new ArrayList<String>();
+ List<String> response = new ArrayList<String>();
+ BufferedReader br = null;
try
{
- BufferedReader br = new BufferedReader(new InputStreamReader(
- socket.getInputStream()));
+ br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
assertNotNull(br);
+ String line;
while ((line = br.readLine()) != null)
{
response.add(line);
}
- br.close();
}
- catch (Exception ex)
+ finally
{
- ex.printStackTrace();
- fail("Exception while reading from the socket");
+ br.close();
}
+
assertTrue(response.contains("<ip>127.0.0.1</ip>"));
assertTrue(response.contains("SOAPAction: \"urn:send\""));
- assertTrue(response
- .contains("Content-Type: text/xml; charset=\"utf-8\""));
+ assertTrue(response.contains("Content-Type: text/xml; charset=\"utf-8\""));
assertTrue(response.contains("Host: localhost" + _port));
assertTrue(response.contains("User-Agent: Axis2"));
+
+ return null;
}
}
- /*
+ /**
* Test that the SOAP client sends the expected data to the socket We mock a
* simple SOAP envelope: <ip>127.0.0.1</ip>
*/
public void testSoapClient() throws Exception
{
- //
try
{
_server = new ServerSocket(0);
- _port = _server.getLocalPort();
- assertTrue("Server is not yet bound to a port", _port != -1);
assertNotNull(_server);
}
- catch (Exception ex)
+ catch (IOException ioe)
{
- ex.printStackTrace();
- fail("Unable to start the socket server");
+ fail("Unable to start the socket server: " + ioe.getMessage());
}
+ _port = _server.getLocalPort();
+ assertTrue("Server is not yet bound to a port", _port != -1);
- Thread _socketAcceptor = new Thread()
+ Callable<Void> acceptor = new Callable<Void>()
{
- public void run()
+ public Void call() throws Exception
{
- try
- {
- Socket socket = _server.accept();
- new ConnectionHandler(socket);
- }
- catch (IOException e)
- {
- e.printStackTrace();
- }
+ Socket socket = _server.accept();
+ Callable<Void> handler = new ConnectionHandler(socket);
+ Future<Void> result = exec.submit(handler);
+ return result.get();
}
};
- _socketAcceptor.start();
+
+ Future<Void> result = exec.submit(acceptor);
+
// Sleep for 1 second to allow the ServerSocket readiness
Thread.sleep(1000);
+
SoapClient sc = getSoapClient();
assertNotNull(sc);
sc.sendSOAPMessage();
- _socketAcceptor.join(2000);
+ result.get(2, TimeUnit.SECONDS);
+ exec.shutdown();
- assertFalse("Socket Acceptor not stopped.", _socketAcceptor.isAlive());
+ assertTrue("Socket Acceptor not stopped", exec.isTerminated());
}
/**
@@ -204,5 +201,4 @@ public class SoapClientTest extends Test
assertTrue("Replace variables did not work as expected", ("<addr>" + ip + ":" + port + "</addr>").equals(sc.getXMLData().toString()));
}
-
}
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/SystemInfoTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/SystemInfoTest.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/SystemInfoTest.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/SystemInfoTest.java Wed Oct 13 15:05:29 2010
@@ -21,15 +21,15 @@
package org.apache.qpid.info.test;
-import junit.framework.TestCase;
-import org.apache.qpid.info.SystemInfo;
-
import java.util.Arrays;
import java.util.List;
import java.util.Map;
+import org.apache.qpid.info.SystemInfo;
+import org.apache.qpid.test.utils.QpidTestCase;
+
/** Test the SystemInfo component */
-public class SystemInfoTest extends TestCase
+public class SystemInfoTest extends QpidTestCase
{
/**
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/XMLWriterTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/XMLWriterTest.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/XMLWriterTest.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/experimental/info/src/test/java/org/apache/qpid/info/test/XMLWriterTest.java Wed Oct 13 15:05:29 2010
@@ -21,16 +21,15 @@
package org.apache.qpid.info.test;
-import junit.framework.TestCase;
-import org.apache.qpid.info.util.XMLWriter;
-
import java.util.HashMap;
-/*
+import org.apache.qpid.info.util.XMLWriter;
+import org.apache.qpid.test.utils.QpidTestCase;
+
+/**
* This test verifies the XML writer custom class operations
*/
-
-public class XMLWriterTest extends TestCase
+public class XMLWriterTest extends QpidTestCase
{
private XMLWriter xw = null;
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java Wed Oct 13 15:05:29 2010
@@ -133,10 +133,11 @@ public class DiagnosticExchange extends
AMQShortString name,
boolean durable,
int ticket,
- boolean autoDelete) throws AMQException
+ boolean autoDelete,
+ Map<String, Object> arguments) throws AMQException
{
DiagnosticExchange exch = new DiagnosticExchange();
- exch.initialise(host,name,durable,ticket,autoDelete);
+ exch.initialise(host,name,durable,ticket,autoDelete, arguments);
return exch;
}
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchangeType.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchangeType.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchangeType.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchangeType.java Wed Oct 13 15:05:29 2010
@@ -21,6 +21,8 @@
package org.apache.qpid.extras.exchanges.diagnostic;
+import java.util.Map;
+
import org.apache.qpid.AMQException;
import org.apache.qpid.framing.AMQShortString;
import org.apache.qpid.server.exchange.ExchangeType;
@@ -42,11 +44,11 @@ public final class DiagnosticExchangeTyp
return DiagnosticExchange.class;
}
- public DiagnosticExchange newInstance(VirtualHost host, AMQShortString name, boolean durable, int ticket, boolean autoDelete)
+ public DiagnosticExchange newInstance(VirtualHost host, AMQShortString name, boolean durable, int ticket, boolean autoDelete, Map<String, Object> arguments)
throws AMQException
{
DiagnosticExchange exch = new DiagnosticExchange();
- exch.initialise(host, name, durable, ticket, autoDelete);
+ exch.initialise(host, name, durable, ticket, autoDelete, arguments);
return exch;
}
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchange.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchange.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchange.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchange.java Wed Oct 13 15:05:29 2010
@@ -250,7 +250,7 @@ public class TestExchange implements Exc
return 0;
}
- public void initialise(VirtualHost arg0, AMQShortString arg1, boolean arg2, int arg3, boolean arg4)
+ public void initialise(VirtualHost arg0, AMQShortString arg1, boolean arg2, int arg3, boolean arg4, Map<String, Object> arg5)
throws AMQException
{
}
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchangeType.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchangeType.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchangeType.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchangeType.java Wed Oct 13 15:05:29 2010
@@ -21,16 +21,18 @@
package org.apache.qpid.extras.exchanges.example;
+import java.util.Map;
+
import org.apache.qpid.AMQException;
import org.apache.qpid.framing.AMQShortString;
import org.apache.qpid.server.exchange.Exchange;
import org.apache.qpid.server.exchange.ExchangeType;
import org.apache.qpid.server.virtualhost.VirtualHost;
-public class TestExchangeType implements ExchangeType
+public class TestExchangeType implements ExchangeType<TestExchange>
{
- public Class getExchangeClass()
+ public Class<TestExchange> getExchangeClass()
{
return TestExchange.class;
}
@@ -40,12 +42,12 @@ public class TestExchangeType implements
return null;
}
- public Exchange newInstance(VirtualHost host, AMQShortString name, boolean durable,
- int token, boolean autoDelete)
+ public TestExchange newInstance(VirtualHost host, AMQShortString name, boolean durable,
+ int token, boolean autoDelete, Map<String, Object> arguments)
throws AMQException
{
TestExchange ex = new TestExchange();
- ex.initialise(host, name, durable, token, autoDelete);
+ ex.initialise(host, name, durable, token, autoDelete, arguments);
return ex;
}
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/test/java/org/apache/qpid/server/plugins/ExtrasTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/test/java/org/apache/qpid/server/plugins/ExtrasTest.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/test/java/org/apache/qpid/server/plugins/ExtrasTest.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/extras/src/test/java/org/apache/qpid/server/plugins/ExtrasTest.java Wed Oct 13 15:05:29 2010
@@ -18,17 +18,17 @@
*/
package org.apache.qpid.server.plugins;
-import junit.framework.TestCase;
+import java.util.Map;
+
import org.apache.commons.configuration.PropertiesConfiguration;
import org.apache.qpid.server.configuration.ServerConfiguration;
import org.apache.qpid.server.exchange.ExchangeType;
import org.apache.qpid.server.registry.ApplicationRegistry;
import org.apache.qpid.server.registry.IApplicationRegistry;
import org.apache.qpid.server.util.TestApplicationRegistry;
+import org.apache.qpid.test.utils.QpidTestCase;
-import java.util.Map;
-
-public class ExtrasTest extends TestCase
+public class ExtrasTest extends QpidTestCase
{
private static final String TEST_EXCHANGE_CLASS = "org.apache.qpid.extras.exchanges.example.TestExchangeType";
Modified: qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/firewall/src/main/java/org/apache/qpid/server/security/access/plugins/Firewall.java
URL: http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/firewall/src/main/java/org/apache/qpid/server/security/access/plugins/Firewall.java?rev=1022127&r1=1022126&r2=1022127&view=diff
==============================================================================
--- qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/firewall/src/main/java/org/apache/qpid/server/security/access/plugins/Firewall.java (original)
+++ qpid/branches/grkvlt-network-20101013/qpid/java/broker-plugins/firewall/src/main/java/org/apache/qpid/server/security/access/plugins/Firewall.java Wed Oct 13 15:05:29 2010
@@ -22,6 +22,7 @@ package org.apache.qpid.server.security.
import java.net.InetAddress;
import java.net.InetSocketAddress;
+import java.net.UnknownHostException;
import org.apache.commons.configuration.Configuration;
import org.apache.commons.configuration.ConfigurationException;
@@ -32,6 +33,7 @@ import org.apache.qpid.server.security.S
import org.apache.qpid.server.security.access.ObjectProperties;
import org.apache.qpid.server.security.access.ObjectType;
import org.apache.qpid.server.security.access.Operation;
+import org.apache.qpid.server.security.access.ObjectProperties.Property;
import org.apache.qpid.server.security.access.config.FirewallException;
import org.apache.qpid.server.security.access.config.FirewallRule;
@@ -75,22 +77,32 @@ public class Firewall extends AbstractPl
public Result authorise(Operation operation, ObjectType objectType, ObjectProperties properties)
{
- return Result.ABSTAIN; // We only deal with access requests
- }
-
- public Result access(ObjectType objectType, Object instance)
- {
- if (objectType != ObjectType.VIRTUALHOST)
+ if (operation != Operation.ACCESS && objectType != ObjectType.VIRTUALHOST)
{
return Result.ABSTAIN; // We are only interested in access to virtualhosts
}
- if (!(instance instanceof InetSocketAddress))
+ if (!properties.containsKey(Property.REMOTE_ADDRESS))
{
- return Result.ABSTAIN; // We need an internet address
+ return Result.ABSTAIN; // We need an address
}
- InetAddress address = ((InetSocketAddress) instance).getAddress();
+ String remoteAddress = properties.get(Property.REMOTE_ADDRESS);
+ int slash = remoteAddress.indexOf('/');
+ int colon = remoteAddress.indexOf(':');
+ if (slash == -1 || colon == -1)
+ {
+ return Result.ABSTAIN; // no internet address found
+ }
+ InetAddress address;
+ try
+ {
+ address = InetAddress.getByName(remoteAddress.substring(slash + 1, colon));
+ }
+ catch (UnknownHostException uhe)
+ {
+ return Result.DENIED;
+ }
try
{
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org