本文整理了Java中org.apache.qpid.server.model.Broker.getEventLogger()方法的一些代码示例，展示了Broker.getEventLogger()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Broker.getEventLogger()方法的具体详情如下：
包路径：org.apache.qpid.server.model.Broker
类名称：Broker
方法名：getEventLogger

Broker.getEventLogger介绍

暂无

代码示例

代码示例来源：origin: org.apache.qpid/qpid-broker-plugins-management-jmx

private EventLogger getEventLogger()
{
  return _broker.getEventLogger();
}

代码示例来源：origin: org.apache.qpid/qpid-bdbstore

private EventLogger getEventLogger()
{
  return _broker.getEventLogger();
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

@Override
protected void logOperation(final String operation)
{
  _broker.getEventLogger().message(AccessControlMessages.OPERATION(operation));
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

@Override
protected void logOperation(final String operation)
{
  _broker.getEventLogger().message(TrustStoreMessages.OPERATION(operation));
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

@Override
protected void logOperation(final String operation)
{
  _broker.getEventLogger().message(KeyStoreMessages.OPERATION(operation));
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

@Override
  protected void logOperation(final String operation)
  {
    _broker.getEventLogger().message(KeyStoreMessages.OPERATION(operation));
  }
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

Map<String, String> options)
broker.getEventLogger().message(BrokerMessages.OPERATION("setJVMOptions"));
StringBuilder exceptionMessages = new StringBuilder();
for (Map.Entry<String, String> entry : options.entrySet())

代码示例来源：origin: org.apache.qpid/qpid-broker-core

public static void dumpHeap(Broker<?> broker,
                PlatformManagedObject hotSpotDiagnosticMXBean,
                Method dumpHeapMethod,
                String outputFile,
                boolean live)
  {
    broker.getEventLogger().message(BrokerMessages.OPERATION("dumpHeap"));
    try
    {
      dumpHeapMethod.invoke(hotSpotDiagnosticMXBean, outputFile, live);
    }
    catch (IllegalAccessException e)
    {
      LOGGER.warn("Cannot access dumpHeap " + dumpHeapMethod);
    }
    catch (InvocationTargetException e)
    {
      String causeAsString = e.getTargetException().toString();
      LOGGER.warn("Cannot collect heap dump into {} (with parameter 'live' set to '{}') due to {}",
            outputFile,
            live,
            causeAsString);
      throw new IllegalConfigurationException("Unexpected exception on collecting heap dump : "
                          + causeAsString,
                          e.getTargetException());
    }
  }
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

@Override
  protected void logOperation(final String operation)
  {
    getAncestor(Broker.class).getEventLogger().message(VirtualHostMessages.OPERATION(operation));
  }
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

AbstractTrustStore(Map<String, Object> attributes, Broker<?> broker)
{
  super(broker, attributes);
  _broker = broker;
  _eventLogger = broker.getEventLogger();
  _eventLogger.message(TrustStoreMessages.CREATE(getName()));
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

public AbstractKeyStore(Map<String, Object> attributes, Broker<?> broker)
{
  super(broker, attributes);
  _broker = broker;
  _eventLogger = broker.getEventLogger();
  _eventLogger.message(KeyStoreMessages.CREATE(getName()));
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

@Override
protected ListenableFuture<Void> onDelete()
{
  _broker.getEventLogger().message(AccessControlMessages.DELETE(getName()));
  return super.onDelete();
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

@ManagedObjectFactoryConstructor(conditionallyAvailable = true)
public AutoGeneratedSelfSignedKeyStoreImpl(final Map<String, Object> attributes, Broker<?> broker)
{
  super(attributes, broker);
  _broker = broker;
  _eventLogger = _broker.getEventLogger();
  _eventLogger.message(KeyStoreMessages.CREATE(getName()));
}

代码示例来源：origin: org.apache.qpid/qpid-broker-plugins-management-http

private void logOperationalShutdownMessage(final int localPort)
{
  getBroker().getEventLogger().message(ManagementConsoleMessages.SHUTTING_DOWN(Protocol.HTTP.name(),
                                         localPort));
}

代码示例来源：origin: org.apache.qpid/qpid-broker-plugins-management-http

@Override
protected ListenableFuture<Void> onClose()
{
  getBroker().removeChangeListener(_brokerChangeListener);
  if (_server != null)
  {
    try
    {
      logOperationalShutdownMessage();
      _server.stop();
    }
    catch (Exception e)
    {
      throw new ServerScopedRuntimeException("Failed to stop HTTP management", e);
    }
  }
  if (_jettyServerExecutor != null)
  {
    _jettyServerExecutor.shutdown();
  }
  getBroker().getEventLogger().message(ManagementConsoleMessages.STOPPED(OPERATIONAL_LOGGING_NAME));
  return Futures.immediateFuture(null);
}

代码示例来源：origin: org.apache.qpid/qpid-broker-plugins-management-http

getBroker().getEventLogger().message(ManagementConsoleMessages.STARTUP(OPERATIONAL_LOGGING_NAME));
  getBroker().getEventLogger().message(PortMessages.BIND_FAILED("HTTP", e.getAddress().getPort()));
  throw e;
getBroker().getEventLogger().message(ManagementConsoleMessages.READY(OPERATIONAL_LOGGING_NAME));

代码示例来源：origin: org.apache.qpid/qpid-broker-plugins-management-http

private void logOperationalListenMessages(final HttpPort<?> port, final int localPort)
{
  Set<Transport> transports = port.getTransports();
  for (Transport transport: transports)
  {
    getBroker().getEventLogger().message(ManagementConsoleMessages.LISTENING(Protocol.HTTP.name(),
                                         transport.name(),
                                         localPort));
  }
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

@Override
public int tick(final long currentTime)
{
  int nextTick = getTimeToNextTick(currentTime);
  if(nextTick <= 0)
  {
    if (isProtocolEstablished())
    {
      _aggregateTicker.removeTicker(this);
      _network.removeSchedulingDelayNotificationListeners(this);
    }
    else
    {
      LOGGER.warn("Connection has taken more than {} ms to send complete protocol header.  Closing as possible DoS.",
             _allowedTime);
      _broker.getEventLogger().message(ConnectionMessages.IDLE_CLOSE("Protocol header not received within timeout period", true));
      _network.close();
    }
  }
  return nextTick;
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

@Override
public boolean validateConnectionCreation(final AMQPConnection<?> connection,
                     final QueueManagingVirtualHost<?> virtualHost)
{
  String connectionVersion = connection.getClientVersion();
  if (connectionVersion == null)
  {
    connectionVersion = "";
  }
  boolean valid = true;
  if (!connectionMatches(virtualHost, VIRTUALHOST_ALLOWED_CONNECTION_VERSION, connectionVersion))
  {
    if (connectionMatches(virtualHost, VIRTUALHOST_LOGGED_CONNECTION_VERSION, connectionVersion))
    {
      virtualHost.getBroker().getEventLogger().message(ConnectionMessages.CLIENT_VERSION_LOG(connection.getClientVersion()));
    }
    else if (connectionMatches(virtualHost, VIRTUALHOST_REJECTED_CONNECTION_VERSION, connectionVersion))
    {
      virtualHost.getBroker().getEventLogger().message(ConnectionMessages.CLIENT_VERSION_REJECT(connection.getClientVersion()));
      valid = false;
    }
  }
  return valid;
}

代码示例来源：origin: org.apache.qpid/qpid-broker-core

_broker.getEventLogger().message(new PortLogSubject(_port),
                 PortMessages.UNSUPPORTED_PROTOCOL_HEADER(Functions.str(headerBytes),
                                     supportedReplyVersion.toString()));