org.apache.qpid.server.model.Broker.isManagementMode()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(2.1k)|赞(0)|评价(0)|浏览(113)

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

Broker.isManagementMode介绍

暂无

代码示例

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

@Override
  public void onFailure(final Throwable t)
  {
    setState(State.ERRORED);
    if (((Broker) getParent()).isManagementMode())
    {
      LOGGER.warn("Failed to make {} active.", this, t);
      resultFuture.set(null);
    }
    else
    {
      resultFuture.setException(t);
    }
  }
}, getTaskExecutor());

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

private void onActivationFailure(final SettableFuture<Void> returnVal, final Throwable e)
{
  doAfterAlways(stopAndSetStateTo(State.ERRORED), () -> {
    if (_broker.isManagementMode())
    {
      LOGGER.warn("Failed to make " + this + " active.", e);
      returnVal.set(null);
    }
    else
    {
      returnVal.setException(e);
    }
  });
}

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

@StateTransition(currentState = {State.UNINITIALIZED, State.QUIESCED, State.ERRORED}, desiredState = State.ACTIVE)
@SuppressWarnings("unused")
private ListenableFuture<Void> activate()
{
  setState(_broker.isManagementMode() ? State.QUIESCED : State.ACTIVE);
  return Futures.immediateFuture(null);
}

代码示例来源:origin: org.apache.qpid/qpid-broker-plugins-access-control

@StateTransition(currentState = {State.UNINITIALIZED, State.QUIESCED, State.ERRORED}, desiredState = State.ACTIVE)
@SuppressWarnings("unused")
private ListenableFuture<Void> activate()
{
  try
  {
    recreateAccessController();
    setState(_broker.isManagementMode() ? State.QUIESCED : State.ACTIVE);
  }
  catch (RuntimeException e)
  {
    setState(State.ERRORED);
    if (_broker.isManagementMode())
    {
      LOGGER.warn("Failed to activate ACL provider: " + getName(), e);
    }
    else
    {
      throw e;
    }
  }
  return Futures.immediateFuture(null);
}

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

getEventLogger().message(getGroupLogSubject(), HighAvailabilityMessages.INTRUDER_DETECTED(node.getName(), hostAndPort));
boolean inManagementMode = ((Broker) getParent()).isManagementMode();
if (inManagementMode)

相关文章