Examples of EventLogger

Examples of org.apache.qpid.server.logging.EventLogger

55
56
57
58
59
60
61
62
63
        queueAttributes.put(Queue.ID, UUID.randomUUID());
        queueAttributes.put(Queue.NAME, getName());
        queueAttributes.put(Queue.LVQ_KEY, CONFLATION_KEY);
        final VirtualHost virtualHost = mock(VirtualHost.class);
        when(virtualHost.getSecurityManager()).thenReturn(mock(SecurityManager.class));
        when(virtualHost.getEventLogger()).thenReturn(new EventLogger());
        _queue = new ConflationQueue(virtualHost, queueAttributes);
        _list = (ConflationQueueList) _queue.getEntries();
    }
View Full Code Here

Examples of org.apache.qpid.server.logging.EventLogger

54
55
56
57
58
59
60
61
62
63
64
        queueAttributes.put(Queue.ID, UUID.randomUUID());
        queueAttributes.put(Queue.NAME, getName());
        queueAttributes.put(Queue.PRIORITIES, 10);
        final VirtualHost virtualHost = mock(VirtualHost.class);
        when(virtualHost.getSecurityManager()).thenReturn(mock(SecurityManager.class));
        when(virtualHost.getEventLogger()).thenReturn(new EventLogger());
        PriorityQueue queue = new PriorityQueue(virtualHost, queueAttributes);
        _list = (PriorityQueueList) queue.getEntries();

        for (int i = 0; i < PRIORITIES.length; i++)
        {
View Full Code Here

Examples of org.apache.qpid.server.logging.EventLogger

66
67
68
69
70
71
72
73
74
75
        when(broker.getAttribute(Broker.CONNECTION_SESSION_COUNT_LIMIT)).thenReturn(1);
        when(broker.getAttribute(Broker.CONNECTION_CLOSE_WHEN_NO_ROUTE)).thenReturn(false);
        when(broker.getAttribute(Broker.VIRTUALHOST_HOUSEKEEPING_CHECK_PERIOD)).thenReturn(10000l);
        when(broker.getId()).thenReturn(UUID.randomUUID());
        when(broker.getSubjectCreator(any(SocketAddress.class))).thenReturn(subjectCreator);
        when(broker.getVirtualHostRegistry()).thenReturn(new VirtualHostRegistry(new EventLogger()));
        when(broker.getSecurityManager()).thenReturn(new SecurityManager(mock(Broker.class), false));
        when(broker.getEventLogger()).thenReturn(new EventLogger());
        return broker;
    }
View Full Code Here

Examples of org.apache.qpid.server.logging.EventLogger

108
109
110
111
112
113
114
    }

    public static VirtualHost createVirtualHost(VirtualHostConfiguration virtualHostConfiguration) throws Exception
    {

        return createVirtualHost(virtualHostConfiguration, new VirtualHostRegistry(new EventLogger()));
    }
View Full Code Here

Examples of org.apache.qpid.server.logging.EventLogger

68
69
70
71
72
73
74
75
76
77
78
        _virtualHost = mock(VirtualHost.class);
        when(_virtualHost.getSecurityManager()).thenReturn(mock(SecurityManager.class));

        VirtualHostConfiguration vhostConfig = mock(VirtualHostConfiguration.class);
        when(_virtualHost.getConfiguration()).thenReturn(vhostConfig);
        when(_virtualHost.getEventLogger()).thenReturn(new EventLogger());
        _queueConfiguration = mock(QueueConfiguration.class);
        when(vhostConfig.getQueueConfiguration(anyString())).thenReturn(_queueConfiguration);
        DurableConfigurationStore store = mock(DurableConfigurationStore.class);
        when(_virtualHost.getDurableConfigurationStore()).thenReturn(store);
View Full Code Here

Examples of org.apache.qpid.server.logging.EventLogger

179
180
181
182
183
184
185
186
187
188
        {
            recovererMap.put(recoverer.getType(), recoverer);
        }
        _durableConfigurationRecoverer =
                new DurableConfigurationRecoverer(_vhost.getName(), recovererMap,
                                                  new DefaultUpgraderProvider(_vhost, _exchangeRegistry), new EventLogger());

        _store = mock(DurableConfigurationStore.class);

    }
View Full Code Here

Examples of org.apache.qpid.server.logging.EventLogger

145
146
147
148
149
150
151
152
153
154
155
        _count++;
        _queue = mock(AMQQueue.class);
        VirtualHost vhost = mock(VirtualHost.class);
        when(_queue.getVirtualHost()).thenReturn(vhost);
        when(vhost.getSecurityManager()).thenReturn(mock(org.apache.qpid.server.security.SecurityManager.class));
        final EventLogger eventLogger = new EventLogger();
        when(vhost.getEventLogger()).thenReturn(eventLogger);
        _exchange = mock(ExchangeImpl.class);
        when(_exchange.getExchangeType()).thenReturn(mock(ExchangeType.class));
        when(_exchange.getEventLogger()).thenReturn(eventLogger);
    }
View Full Code Here

Examples of org.apache.qpid.server.logging.EventLogger

115
116
117
118
119
120
121
122
123
124
125
        when(_queueEntryRecoveryHandler.completeQueueEntryRecovery()).thenReturn(_dtxRecordRecoveryHandler);
        when(_exchange.getName()).thenReturn(EXCHANGE_NAME);

        when(_exchange.getId()).thenReturn(_exchangeId);
        when(_exchange.getExchangeType()).thenReturn(mock(ExchangeType.class));
        when(_exchange.getEventLogger()).thenReturn(new EventLogger());
        when(_configuration.getString(eq(MessageStoreConstants.ENVIRONMENT_PATH_PROPERTY), anyString())).thenReturn(
                _storePath);
        when(_virtualHost.getAttribute(eq(VirtualHost.STORE_PATH))).thenReturn(_storePath);

        _bindingArgs = new HashMap<String, Object>();
View Full Code Here

Examples of org.apache.qpid.server.logging.EventLogger

94
95
96
97
98
99
100
101
102
103
104
        startup(new BrokerOptions());
    }

    public void startup(final BrokerOptions options) throws Exception
    {
        _eventLogger = new EventLogger(new SystemOutMessageLogger());

        Subject.doAs(SecurityManager.getSystemTaskSubject("Broker"), new PrivilegedExceptionAction<Object>()
        {
            @Override
            public Object run() throws Exception
View Full Code Here

Examples of org.apache.qpid.server.logging.EventLogger

42
43
44
45
46
47
48
    {
        super.setUp();

        BrokerTestHelper.setUp();
        _logger = new UnitTestMessageLogger();
        _eventLogger = new EventLogger(_logger);
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.