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

Channel.waitForConfirms介绍

暂无

代码示例

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

@Override
public boolean waitForConfirms(long timeout) throws InterruptedException,
    TimeoutException {
  return this.delegate.waitForConfirms(timeout);
}

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

@Override
public boolean waitForConfirms(long timeout) throws InterruptedException,
    TimeoutException {
  return this.delegate.waitForConfirms(timeout);
}

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

@Override
public boolean waitForConfirms() throws InterruptedException {
  return this.delegate.waitForConfirms();
}

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

@Override
public boolean waitForConfirms() throws InterruptedException {
  return this.delegate.waitForConfirms();
}

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

@Override
  public boolean waitForConfirms() throws InterruptedException {
    return delegate.waitForConfirms();
  }
}

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

@Override
public boolean waitForConfirms(long closeTimeoutMillis) throws InterruptedException, TimeoutException {
  return delegate.waitForConfirms(closeTimeoutMillis);
}

代码示例来源：origin: gmr/rabbitmq-flume-plugin

private void waitForConfirmation() throws EventDeliveryException {
  try {
    rmqChannel.waitForConfirms();
  } catch (InterruptedException ex) {
    logger.error("Error waiting for publisher confirmation: {}", ex.toString());
    closeRabbitMQConnection();
    throw new EventDeliveryException(ex.toString());
  }
}

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

@Override
public boolean waitForConfirms(long timeout) {
  Channel channel = this.dedicatedChannels.get();
  Assert.state(channel != null, "This operation is only available within the scope of an invoke operation");
  try {
    return channel.waitForConfirms(timeout);
  }
  catch (TimeoutException e) {
    throw RabbitExceptionTranslator.convertRabbitAccessException(e);
  }
  catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    throw RabbitExceptionTranslator.convertRabbitAccessException(e);
  }
}

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

@Override
public boolean waitForConfirms(long timeout) {
  Channel channel = this.dedicatedChannels.get();
  Assert.state(channel != null, "This operation is only available within the scope of an invoke operation");
  try {
    return channel.waitForConfirms(timeout);
  }
  catch (TimeoutException e) {
    throw RabbitExceptionTranslator.convertRabbitAccessException(e);
  }
  catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    throw RabbitExceptionTranslator.convertRabbitAccessException(e);
  }
}

代码示例来源：origin: kodokojo/kodokojo

private boolean publishAndAck(PublishCallback callback) throws Exception {
  requireNonNull(callback, "callback must be defined.");
  boolean res = false;
  synchronized (channel) {
    channel.confirmSelect();
    callback.callback(channel);
    res = channel.waitForConfirms();
    if (LOGGER.isDebugEnabled()) {
      LOGGER.debug("Publish with confirmation a message from channel {}: {}", channel.getChannelNumber());
    }
  }
  return res;
}

代码示例来源：origin: aillamsun/devX

if (confirm) {
  try {
    return channel.waitForConfirms();
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();

代码示例来源：origin: com.ecfront.dew/cluster-spi-rabbit

if (confirm) {
  try {
    return channel.waitForConfirms();
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();

代码示例来源：origin: com.ecfront.dew/cluster-spi-rabbit

if (confirm) {
  try {
    return channel.waitForConfirms();
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();

代码示例来源：origin: aillamsun/devX

if (confirm) {
  try {
    return channel.waitForConfirms();
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();

代码示例来源：origin: caojx-git/learn

if(!channel.waitForConfirms()){
  System.out.println("message send failed!");
}else{

代码示例来源：origin: caojx-git/learn

if(!channel.waitForConfirms()){
  System.out.println("message batch send failed!");
}else{

代码示例来源：origin: gudaoxuri/dew

if (confirm) {
  try {
    return channel.waitForConfirms();
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();

代码示例来源：origin: gudaoxuri/dew

if (confirm) {
  try {
    return channel.waitForConfirms();
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();

代码示例来源：origin: org.graylog2/gelfj

channel.waitForConfirms();

代码示例来源：origin: t0xa/gelfj

channel.waitForConfirms();