org.apache.activemq.broker.Broker.removeDestinationInfo()方法的使用及代码示例

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

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

Broker.removeDestinationInfo介绍

[英]Remove and process a DestinationInfo object
[中]删除并处理DestinationInfo对象

代码示例

代码示例来源:origin: apache/activemq

@Override
public void removeDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception {
  getNext().removeDestinationInfo(context, info);
}

代码示例来源:origin: apache/activemq

@Override
public Response processRemoveDestination(DestinationInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  broker.removeDestinationInfo(cs.getContext(), info);
  if (info.getDestination().isTemporary()) {
    cs.removeTempDestination(info.getDestination());
  }
  return null;
}

代码示例来源:origin: pierre/meteo

public void removeDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception {
  next.removeDestinationInfo(context, info);
}

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

@Override
public void removeDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception {
  getNext().removeDestinationInfo(context, info);
}

代码示例来源:origin: org.apache.activemq/activemq-osgi

@Override
public void removeDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception {
  getNext().removeDestinationInfo(context, info);
}

代码示例来源:origin: org.apache.activemq/activemq-all

@Override
public void removeDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception {
  getNext().removeDestinationInfo(context, info);
}

代码示例来源:origin: pierre/meteo

public void removeDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception {
  getNext().removeDestinationInfo(context, info);
}

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

@Override
public Response processRemoveDestination(DestinationInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  broker.removeDestinationInfo(cs.getContext(), info);
  if (info.getDestination().isTemporary()) {
    cs.removeTempDestination(info.getDestination());
  }
  return null;
}

代码示例来源:origin: org.apache.activemq/activemq-osgi

@Override
public Response processRemoveDestination(DestinationInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  broker.removeDestinationInfo(cs.getContext(), info);
  if (info.getDestination().isTemporary()) {
    cs.removeTempDestination(info.getDestination());
  }
  return null;
}

代码示例来源:origin: org.apache.activemq/activemq-all

@Override
public Response processRemoveDestination(DestinationInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  broker.removeDestinationInfo(cs.getContext(), info);
  if (info.getDestination().isTemporary()) {
    cs.removeTempDestination(info.getDestination());
  }
  return null;
}

代码示例来源:origin: pierre/meteo

public Response processRemoveDestination(DestinationInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  broker.removeDestinationInfo(cs.getContext(), info);
  if (info.getDestination().isTemporary()) {
    cs.removeTempDestination(info.getDestination());
  }
  return null;
}

相关文章

微信公众号

最新文章

更多

Broker类方法