Package org.apache.qpid.server.logging.actors

Examples of org.apache.qpid.server.logging.actors.TestLogActor


        }

        ServerConfiguration serverConfig = new ServerConfiguration(_config);
        UnitTestMessageLogger logger = new UnitTestMessageLogger(serverConfig);

        LogActor actor = new TestLogActor(logger);

        actor.message(_subject, new LogMessage()
        {
            public String toString()
            {
                return "<Log Message>";
            }
View Full Code Here


    {
        super.setUp();

        _logger = new UnitTestMessageLogger();

        _actor = new TestLogActor(_logger);
    }
View Full Code Here

    @Override
    public void setUp() throws Exception
    {
        super.setUp();

        CurrentActor.set(new TestLogActor(new SystemOutMessageLogger()));

        XMLConfiguration configXml = new XMLConfiguration();
        configXml.addProperty("virtualhosts.virtualhost(-1).name", getName());
        configXml.addProperty("virtualhosts.virtualhost(-1)."+getName()+".store.class", TestableMemoryMessageStore.class.getName());
View Full Code Here

    }

    protected void createBroker() throws Exception
    {
        _started = true;
        CurrentActor.set(new TestLogActor(new SystemOutMessageLogger()));

        _configuration = new ServerConfiguration(_configXml);

        configure();
View Full Code Here

        }

        ServerConfiguration serverConfig = new ServerConfiguration(_config);
        UnitTestMessageLogger logger = new UnitTestMessageLogger(serverConfig);

        LogActor actor = new TestLogActor(logger);

        actor.message(_subject, new LogMessage()
        {
            public String toString()
            {
                return "<Log Message>";
            }
View Full Code Here

        return _host + ":" + _masterPort;
    }

    private TestApplicationRegistry initialize() throws Exception
    {
        CurrentActor.set(new TestLogActor(new SystemOutMessageLogger()));
        ServerConfiguration configuration = new ServerConfiguration(_configXml);
        TestApplicationRegistry registry = new TestApplicationRegistry(configuration);
        ApplicationRegistry.initialise(registry);
        registry.getVirtualHostRegistry().setDefaultVirtualHostName("test" + _masterPort);
        return registry;
View Full Code Here

        _rootMessageLogger = new RootMessageLoggerImpl(_configuration,
                                                       new Log4jMessageLogger());

        //Add a Test Actor as a lot of our System Tests reach in to the broker
        // and manipulate it so the CurrentActor is not set.
        CurrentActor.set(new TestLogActor(_rootMessageLogger));

        Properties users = new Properties();

        users.put("guest", "guest");
View Full Code Here

        UnitTestMessageLogger logger = new UnitTestMessageLogger();
        RootMessageLogger rootLogger =
                new RootMessageLoggerImpl(serverConfig, logger);

        LogActor actor = new TestLogActor(rootLogger);

        actor.message(_subject, new LogMessage()
        {
            public String toString()
            {
                return "<Log Message>";
            }
View Full Code Here

        _logger.info("Initialising NullApplicationRegistry");

        _rootMessageLogger = new RootMessageLoggerImpl(_configuration, new Log4jMessageLogger());

        //We should use a Test Actor Here not the Broker Actor
        CurrentActor.set(new TestLogActor(_rootMessageLogger));

        _configuration.setHousekeepingExpiredMessageCheckPeriod(200);

        Properties users = new Properties();
View Full Code Here

        _logger = new UnitTestMessageLogger();
        RootMessageLogger rootLogger =
                new RootMessageLoggerImpl(serverConfig, _logger);

        _actor = new TestLogActor(rootLogger);
    }
View Full Code Here

TOP

Related Classes of org.apache.qpid.server.logging.actors.TestLogActor

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.