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.IOException
java.util.concurrent.TimeoutException