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

Channel.addConfirmListener介绍

暂无

代码示例

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

@Override
public ConfirmListener addConfirmListener(ConfirmCallback ackCallback, ConfirmCallback nackCallback) {
  return this.delegate.addConfirmListener(ackCallback, nackCallback);
}

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

@Override
public void addConfirmListener(ConfirmListener listener) {
  this.delegate.addConfirmListener(listener);
}

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

@Override
public ConfirmListener addConfirmListener(ConfirmCallback ackCallback, ConfirmCallback nackCallback) {
  return this.delegate.addConfirmListener(ackCallback, nackCallback);
}

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

@Override
public void addConfirmListener(ConfirmListener listener) {
  this.delegate.addConfirmListener(listener);
}

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

@Override
public void addConfirmListener(ConfirmListener confirmListener) {
  delegate.addConfirmListener(confirmListener);
}

代码示例来源：origin: openmessaging/openmessaging-benchmark

channel.addConfirmListener(listener);

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

@Nullable
private ConfirmListener addConfirmListener(@Nullable com.rabbitmq.client.ConfirmCallback acks,
    @Nullable com.rabbitmq.client.ConfirmCallback nacks, Channel channel) {
  ConfirmListener listener = null;
  if (acks != null && nacks != null && channel instanceof ChannelProxy
      && ((ChannelProxy) channel).isConfirmSelected()) {
    listener = channel.addConfirmListener(acks, nacks);
  }
  return listener;
}

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

@Nullable
private ConfirmListener addConfirmListener(@Nullable com.rabbitmq.client.ConfirmCallback acks,
    @Nullable com.rabbitmq.client.ConfirmCallback nacks, Channel channel) {
  ConfirmListener listener = null;
  if (acks != null && nacks != null && channel instanceof ChannelProxy
      && ((ChannelProxy) channel).isConfirmSelected()) {
    listener = channel.addConfirmListener(acks, nacks);
  }
  return listener;
}

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

/**
 * Add the listener and return the internal map of pending confirmations for that listener.
 * @param listener the listener.
 */
@Override
public void addListener(Listener listener) {
  Assert.notNull(listener, "Listener cannot be null");
  if (this.listeners.size() == 0) {
    this.delegate.addConfirmListener(this);
    this.delegate.addReturnListener(this);
  }
  if (this.listeners.putIfAbsent(listener.getUUID(), listener) == null) {
    this.pendingConfirms.put(listener, new ConcurrentSkipListMap<Long, PendingConfirm>());
    if (this.logger.isDebugEnabled()) {
      this.logger.debug("Added listener " + listener);
    }
  }
}

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

/**
 * Add the listener and return the internal map of pending confirmations for that listener.
 * @param listener the listener.
 */
@Override
public void addListener(Listener listener) {
  Assert.notNull(listener, "Listener cannot be null");
  if (this.listeners.size() == 0) {
    this.delegate.addConfirmListener(this);
    this.delegate.addReturnListener(this);
  }
  if (this.listeners.putIfAbsent(listener.getUUID(), listener) == null) {
    this.pendingConfirms.put(listener, new ConcurrentSkipListMap<Long, PendingConfirm>());
    if (this.logger.isDebugEnabled()) {
      this.logger.debug("Added listener " + listener);
    }
  }
}

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

channel.addConfirmListener(new ConfirmListener() {

代码示例来源：origin: net.jodah/lyra

/**
 * Migrates the channel's configuration to the given {@code channel}.
 */
private void migrateConfiguration(Channel channel) throws Exception {
 channel.setDefaultConsumer(delegate.getDefaultConsumer());
 if (flowBlocked)
  channel.flowBlocked();
 if (basicQos != null)
  basicQos.invoke(channel);
 if (confirmSelect)
  channel.confirmSelect();
 if (txSelect)
  channel.txSelect();
 synchronized (shutdownListeners) {
  for (ShutdownListener listener : shutdownListeners)
   channel.addShutdownListener(listener);
 }
 for (ConfirmListener listener : confirmListeners)
  channel.addConfirmListener(listener);
 for (FlowListener listener : flowListeners)
  channel.addFlowListener(listener);
 for (ReturnListener listener : returnListeners)
  channel.addReturnListener(listener);
}

代码示例来源：origin: jhalterman/lyra

/**
 * Migrates the channel's configuration to the given {@code channel}.
 */
private void migrateConfiguration(Channel channel) throws Exception {
 channel.setDefaultConsumer(delegate.getDefaultConsumer());
 if (flowBlocked)
  channel.flowBlocked();
 if (basicQos != null)
  basicQos.invoke(channel);
 if (confirmSelect)
  channel.confirmSelect();
 if (txSelect)
  channel.txSelect();
 synchronized (shutdownListeners) {
  for (ShutdownListener listener : shutdownListeners)
   channel.addShutdownListener(listener);
 }
 for (ConfirmListener listener : confirmListeners)
  channel.addConfirmListener(listener);
 for (FlowListener listener : flowListeners)
  channel.addFlowListener(listener);
 for (ReturnListener listener : returnListeners)
  channel.addReturnListener(listener);
}

代码示例来源：origin: com.github.combinedmq/combinedmq

channel.addConfirmListener(CONFIRM_LISTENER);