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

Queue.removeConsumer介绍

暂无

代码示例

代码示例来源：origin: org.apache.activemq/artemis-aerogear-integration

@Override
public void stop() throws Exception {
 if (!started) {
   return;
 }
 queue.removeConsumer(this);
}

代码示例来源：origin: apache/activemq-artemis

@Override
public void removeItself() throws Exception {
 if (browseOnly) {
   browserDeliverer.close();
 } else {
   messageQueue.removeConsumer(this);
 }
 session.removeConsumer(id);
}

代码示例来源：origin: apache/activemq-artemis

protected void fail(final boolean permanently) {
 logger.debug(this + "\n\t::fail being called, permanently=" + permanently);
 //we need to make sure we remove the node from the topology so any incoming quorum requests are voted correctly
 if (targetNodeID != null) {
   serverLocator.notifyNodeDown(System.currentTimeMillis(), targetNodeID);
 }
 if (queue != null) {
   try {
    if (logger.isTraceEnabled()) {
      logger.trace("Removing consumer on fail " + this + " from queue " + queue);
    }
    queue.removeConsumer(this);
   } catch (Exception dontcare) {
    logger.debug(dontcare);
   }
 }
 cancelRefs();
 if (queue != null) {
   queue.deliverAsync();
 }
}

代码示例来源：origin: org.apache.activemq/artemis-vertx-integration

@Override
public void stop() throws Exception {
 if (!this.isStarted) {
   return;
 }
 ActiveMQVertxLogger.LOGGER.debug(connectorName + ": receive shutdown request");
 this.queue.removeConsumer(this);
 this.platformManager.stop();
 System.clearProperty("vertx.clusterManagerFactory");
 this.isStarted = false;
 ActiveMQVertxLogger.LOGGER.debug(connectorName + ": stopped");
}

代码示例来源：origin: apache/activemq-artemis

synchronized void stop() throws Exception {
 for (ServerConsumer consumer : consumers.values()) {
   consumer.setStarted(false);
   consumer.disconnect();
   consumer.getQueue().removeConsumer(consumer);
   consumer.close(false);
 }
}

代码示例来源：origin: org.apache.activemq/artemis-mqtt-protocol

synchronized void stop() throws Exception {
 for (ServerConsumer consumer : consumers.values()) {
   consumer.setStarted(false);
   consumer.disconnect();
   consumer.getQueue().removeConsumer(consumer);
   consumer.close(false);
 }
}

代码示例来源：origin: apache/activemq-artemis

@Override
public void run() {
  logger.debug("stopping bridge " + BridgeImpl.this);
  queue.removeConsumer(BridgeImpl.this);

代码示例来源：origin: org.apache.activemq/artemis-aerogear-integration

@Override
public void onComplete(int statusCode) {
 if (statusCode != 200) {
   handled = false;
   if (statusCode == 401) {
    ActiveMQAeroGearLogger.LOGGER.reply401();
   } else if (statusCode == 404) {
    ActiveMQAeroGearLogger.LOGGER.reply404();
   } else {
    ActiveMQAeroGearLogger.LOGGER.replyUnknown(statusCode);
   }
   queue.removeConsumer(this);
   started = false;
 } else {
   handled = true;
 }
}

代码示例来源：origin: apache/activemq-artemis

@Override
public void run() {
  try {
   queue.removeConsumer(BridgeImpl.this);
   if (!pendingAcks.await(60, TimeUnit.SECONDS)) {
     ActiveMQServerLogger.LOGGER.timedOutWaitingCompletions(BridgeImpl.this.toString(), pendingAcks.getCount());
   }
   synchronized (BridgeImpl.this) {
     started = false;
     active = false;
   }
   internalCancelReferences();
   ActiveMQServerLogger.LOGGER.bridgePaused(name);
  } catch (Exception e) {
   ActiveMQServerLogger.LOGGER.errorPausingBridge(e);
  }
}