public class RabbitConsumer
extends java.lang.Object
| 构造器和说明 |
|---|
RabbitConsumer(RabbitConfig config,
com.rabbitmq.client.Channel channel,
RabbitProducer producer) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
init(CloudEventObserverManger observerManger)
初始化
|
public RabbitConsumer(RabbitConfig config, com.rabbitmq.client.Channel channel, RabbitProducer producer)
public void init(CloudEventObserverManger observerManger) throws java.io.IOException, java.util.concurrent.TimeoutException
java.io.IOExceptionjava.util.concurrent.TimeoutException