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

Channel.setDefaultConsumer介绍

暂无

代码示例

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

@Override
public void setDefaultConsumer(Consumer consumer) {
  this.delegate.setDefaultConsumer(consumer);
}

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

@Override
public void setDefaultConsumer(Consumer consumer) {
  this.delegate.setDefaultConsumer(consumer);
}

代码示例来源：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: 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);
}