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

Channel.queueDelete介绍

暂无

代码示例

代码示例来源：origin: spring-projects/spring-amqp

@Override
public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete(String queue)
    throws IOException {
  return this.delegate.queueDelete(queue);
}

代码示例来源：origin: org.springframework.amqp/spring-rabbit

@Override
public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete(String queue)
    throws IOException {
  return this.delegate.queueDelete(queue);
}

代码示例来源：origin: spring-projects/spring-amqp

@Override
public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete(String queue,
    boolean ifUnused, boolean ifEmpty) throws IOException {
  return this.delegate.queueDelete(queue, ifUnused, ifEmpty);
}

代码示例来源：origin: org.springframework.amqp/spring-rabbit

@Override
public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete(String queue,
    boolean ifUnused, boolean ifEmpty) throws IOException {
  return this.delegate.queueDelete(queue, ifUnused, ifEmpty);
}

代码示例来源：origin: org.smartdeveloperhub.harvesters.it/it-harvester-notification

@Override
public void clean(final Channel channel) throws IOException {
  channel.queueDelete(this.queueName);
}

代码示例来源：origin: meltwater/rxrabbit

@Override
public AMQP.Queue.DeleteOk queueDelete(String queue, boolean ifUnused, boolean ifEmpty) throws IOException {
  return delegate.queueDelete(queue, ifUnused, ifEmpty);
}

代码示例来源：origin: meltwater/rxrabbit

@Override
public void queueDeleteNoWait(String queue, boolean ifUnused, boolean ifEmpty) throws IOException {
  delegate.queueDelete(queue, ifUnused, ifEmpty);
}

代码示例来源：origin: org.smartdeveloperhub.curator/sdh-curator-connector

@Override
public void clean(final Channel channel) throws IOException {
  channel.queueDelete(this.queueName);
}

代码示例来源：origin: org.smartdeveloperhub.harvesters.scm/scm-harvester-backend

@Override
public void clean(final Channel channel) throws IOException {
  channel.queueDelete(this.queueName);
}

代码示例来源：origin: awin/rabbiteasy

/**
 * Removes all declared exchanges, queue and bindings
 * declared with the instance of this broker setup.
 * 
 * @throws IOException if the removing of an exchange or queue fails
 */
public void tearDown() throws IOException {
  for (String exchange : declaredExchanges) {
    channel.exchangeDelete(exchange);
  }
  for (String queue : declaredQueues) {
    channel.queueDelete(queue);
  }
}

代码示例来源：origin: ICOnator/ICOnator-backend

public RegisterAddressTestImpl deleteExchangeAndQueue(Channel channel) throws Exception {
  channel.exchangeDelete(ICONATOR_ENTRY_EXCHANGE);
  channel.queueDelete(REGISTER_CONFIRMATION_EMAIL_QUEUE);
  channel.queueDelete(REGISTER_SUMMARY_EMAIL_QUEUE);
  channel.queueDelete(ADDRESS_SET_WALLET_QUEUE);
  return this;
}

代码示例来源：origin: yanghua/banyan

public void deleteQueueNoWait(String queueName) {
  try {
    super.init();
    AMQP.Queue.DeleteOk deleteOk = channel.queueDelete(queueName);
    if (deleteOk == null) {
      throw new RuntimeException("delete queue with name : " + queueName + " failed.");
    }
  } catch (IOException e) {
    logger.error(e);
    throw new RuntimeException(e);
  } finally {
    super.close();
  }
}

代码示例来源：origin: yanghua/banyan

public void delete(String queueName) throws IOException {
  super.init();
  if (queueName.isEmpty()) {
    logger.error("[delete] queueName is empty");
    throw new IOException("[delete] queueName is empty");
  }
  if (!this.innerExists(queueName, this.channel)) {
    logger.error("[delete] queue : " + queueName + " is not exists");
  }
  this.channel.queueDelete(queueName);
  super.close();
}

代码示例来源：origin: vert-x3/vertx-rabbitmq-client

@Override
public void queueDelete(String queue, Handler<AsyncResult<JsonObject>> resultHandler) {
 forChannel(resultHandler, channel -> {
  AMQP.Queue.DeleteOk result = channel.queueDelete(queue);
  return toJson(result);
 });
}

代码示例来源：origin: spring-projects/spring-amqp

@Override
@ManagedOperation(description =
    "Delete a queue from the broker if unused and empty (when corresponding arguments are true")
public void deleteQueue(final String queueName, final boolean unused, final boolean empty) {
  this.rabbitTemplate.execute(channel -> {
    channel.queueDelete(queueName, unused, empty);
    return null;
  });
}

代码示例来源：origin: spring-projects/spring-amqp

@Override
@ManagedOperation(description = "Delete a queue from the broker")
public boolean deleteQueue(final String queueName) {
  return this.rabbitTemplate.execute(channel -> { // NOSONAR never returns null
    try {
      channel.queueDelete(queueName);
    }
    catch (IOException e) {
      return false;
    }
    return true;
  });
}

代码示例来源：origin: vert-x3/vertx-rabbitmq-client

@Override
public void queueDeleteIf(String queue, boolean ifUnused, boolean ifEmpty, Handler<AsyncResult<JsonObject>> resultHandler) {
 forChannel(resultHandler, channel -> {
  AMQP.Queue.DeleteOk result = channel.queueDelete(queue, ifUnused, ifEmpty);
  return toJson(result);
 });
}

代码示例来源：origin: org.springframework.amqp/spring-rabbit

@Override
@ManagedOperation(description =
    "Delete a queue from the broker if unused and empty (when corresponding arguments are true")
public void deleteQueue(final String queueName, final boolean unused, final boolean empty) {
  this.rabbitTemplate.execute(channel -> {
    channel.queueDelete(queueName, unused, empty);
    return null;
  });
}

代码示例来源：origin: org.springframework.amqp/spring-rabbit

@Override
@ManagedOperation(description = "Delete a queue from the broker")
public boolean deleteQueue(final String queueName) {
  return this.rabbitTemplate.execute(channel -> { // NOSONAR never returns null
    try {
      channel.queueDelete(queueName);
    }
    catch (IOException e) {
      return false;
    }
    return true;
  });
}

代码示例来源：origin: org.apache.airavata/airavata-messaging-core

public void stopListen(final String id) throws AiravataException {
  QueueDetails details = queueDetailsMap.get(id);
  if (details != null) {
    try {
      for (String key : details.getRoutingKeys()) {
        channel.queueUnbind(details.getQueueName(), exchangeName, key);
      }
      channel.queueDelete(details.getQueueName(), true, true);
    } catch (IOException e) {
      String msg = "could not un-bind queue: " + details.getQueueName() + " for exchange " + exchangeName;
      log.debug(msg);
    }
  }
}