本文整理了Java中org.apache.qpid.server.model.Broker.isManagementMode()
方法的一些代码示例,展示了Broker.isManagementMode()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Broker.isManagementMode()
方法的具体详情如下:
包路径:org.apache.qpid.server.model.Broker
类名称: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)
内容来源于网络,如有侵权,请联系作者删除!