Examples of EventLogger

com.couchbase.client.ViewNode.EventLogger
com.espertech.esperio.http.EventLogger
com.jbidwatcher.auction.event.EventLogger
freenet.client.events.EventLogger
Event handeling for clients. @author oskar
org.activiti.engine.impl.event.logger.EventLogger
@author Joram Barrez
org.apache.qpid.server.logging.EventLogger
org.sf.bee.app.server.http.nio.listeners.EventLogger
@author angelo.geminiani

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

        Map<String,Object> queueAttributes = new HashMap<String, Object>();
        queueAttributes.put(Queue.ID, UUID.randomUUID());
        queueAttributes.put(Queue.NAME, getName());
        final VirtualHostImpl virtualHost = mock(VirtualHostImpl.class);
        when(virtualHost.getSecurityManager()).thenReturn(mock(org.apache.qpid.server.security.SecurityManager.class));
        when(virtualHost.getEventLogger()).thenReturn(new EventLogger());


        ConfiguredObjectFactory factory = new ConfiguredObjectFactoryImpl(BrokerModel.getInstance());
        when(virtualHost.getObjectFactory()).thenReturn(factory);
        when(virtualHost.getModel()).thenReturn(factory.getModel());
        when(virtualHost.getTaskExecutor()).thenReturn(CurrentThreadTaskExecutor.newStartedInstance());

View Full Code Here

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

    @Override
    public void setUp() throws Exception
    {
        super.setUp();
        _rawLogger = new UnitTestMessageLogger(_statusUpdatesEnabled);
        _eventLogger = new EventLogger(_rawLogger);
    }

View Full Code Here

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

        queueAttributes.put(Queue.ID, UUID.randomUUID());
        queueAttributes.put(Queue.NAME, getName());
        queueAttributes.put(LastValueQueue.LVQ_KEY, CONFLATION_KEY);
        final VirtualHostImpl virtualHost = mock(VirtualHostImpl.class);
        when(virtualHost.getSecurityManager()).thenReturn(mock(SecurityManager.class));
        when(virtualHost.getEventLogger()).thenReturn(new EventLogger());
        ConfiguredObjectFactory factory = new ConfiguredObjectFactoryImpl(BrokerModel.getInstance());
        when(virtualHost.getObjectFactory()).thenReturn(factory);
        when(virtualHost.getModel()).thenReturn(factory.getModel());
        when(virtualHost.getTaskExecutor()).thenReturn(CurrentThreadTaskExecutor.newStartedInstance());
        _queue = new LastValueQueueImpl(queueAttributes, virtualHost);

View Full Code Here

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

                        String name = virtualHost.getName();
                        StatisticsCounter dataDelivered = vhostImpl.getDataDeliveryStatistics();
                        StatisticsCounter messagesDelivered = vhostImpl.getMessageDeliveryStatistics();
                        StatisticsCounter dataReceived = vhostImpl.getDataReceiptStatistics();
                        StatisticsCounter messagesReceived = vhostImpl.getMessageReceiptStatistics();
                        EventLogger logger = vhostImpl.getEventLogger();
                        logger.message(VirtualHostMessages.STATS_DATA(name,
                                                                      DELIVERED,
                                                                      dataDelivered.getPeak() / 1024.0,
                                                                      dataDelivered.getTotal()));
                        logger.message(VirtualHostMessages.STATS_MSGS(name,
                                                                      DELIVERED,
                                                                      messagesDelivered.getPeak(),
                                                                      messagesDelivered.getTotal()));
                        logger.message(VirtualHostMessages.STATS_DATA(name,
                                                                      RECEIVED,
                                                                      dataReceived.getPeak() / 1024.0,
                                                                      dataReceived.getTotal()));
                        logger.message(VirtualHostMessages.STATS_MSGS(name,
                                                                      RECEIVED,
                                                                      messagesReceived.getPeak(),
                                                                      messagesReceived.getTotal()));


                    }

View Full Code Here

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

        attributes.put(SortedQueue.SORT_KEY, "KEY");


        // Create test list
        final VirtualHostImpl virtualHost = mock(VirtualHostImpl.class);
        when(virtualHost.getSecurityManager()).thenReturn(mock(SecurityManager.class));
        when(virtualHost.getEventLogger()).thenReturn(new EventLogger());
        ConfiguredObjectFactory factory = new ConfiguredObjectFactoryImpl(BrokerModel.getInstance());
        when(virtualHost.getObjectFactory()).thenReturn(factory);
        when(virtualHost.getModel()).thenReturn(factory.getModel());
        when(virtualHost.getTaskExecutor()).thenReturn(CurrentThreadTaskExecutor.newStartedInstance());
        _testQueue = new SortedQueueImpl(attributes, virtualHost)

View Full Code Here

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

        attributes.put(Queue.LIFETIME_POLICY, LifetimePolicy.PERMANENT);
        attributes.put(SortedQueue.SORT_KEY, "KEY");


        final VirtualHostImpl virtualHost = mock(VirtualHostImpl.class);
        when(virtualHost.getSecurityManager()).thenReturn(mock(org.apache.qpid.server.security.SecurityManager.class));
        when(virtualHost.getEventLogger()).thenReturn(new EventLogger());
        ConfiguredObjectFactory factory = new ConfiguredObjectFactoryImpl(BrokerModel.getInstance());
        when(virtualHost.getObjectFactory()).thenReturn(factory);
        when(virtualHost.getModel()).thenReturn(factory.getModel());
        when(virtualHost.getTaskExecutor()).thenReturn(CurrentThreadTaskExecutor.newStartedInstance());
        SortedQueueImpl queue = new SortedQueueImpl(attributes, virtualHost)

View Full Code Here

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

        super.setUp();


        _subject.getPrincipals().add(new AuthenticatedPrincipal("mockusername"));
        when(_logger.isEnabled()).thenReturn(true);
        when(_logger.isMessageEnabled(anyString())).thenReturn(true);
        EventLogger eventLogger = new EventLogger(_logger);
        EventLoggerProvider provider = mock(EventLoggerProvider.class);
        when(provider.getEventLogger()).thenReturn(eventLogger);
        _loginLogoutReport = new LoginLogoutReporter(_subject, provider);
    }

View Full Code Here

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

        super.setUp();
        _usernameAccessor = mock(UsernameAccessor.class);
        _messageLogger = mock(MessageLogger.class);
        // Enable messaging so we can valid the generated strings
        when(_messageLogger.isMessageEnabled(anyString())).thenReturn(true);
        EventLogger eventLogger = new EventLogger(_messageLogger);
        EventLoggerProvider provider = mock(EventLoggerProvider.class);
        when(provider.getEventLogger()).thenReturn(eventLogger);
        _reporter = new ManagementLogonLogoffReporter(provider, _usernameAccessor);
    }

View Full Code Here

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


    public void setUp() throws Exception
    {
        super.setUp();
        _messageLogger = new UnitTestMessageLogger();
        _eventLogger = new EventLogger(_messageLogger);
        _plugin = null;
    }

View Full Code Here

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

        }
    }


    private EventLogger resetEventLogger()
    {
        EventLogger eventLogger = mock(EventLogger.class);
        SystemConfig<?> context = (SystemConfig<?>) _helper.getBroker().getParent(SystemConfig.class);
        when(context.getEventLogger()).thenReturn(eventLogger);
        return eventLogger;
    }

View Full Code Here

0 1 2 3 4 5

TOP

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.