org.noear.solon.cloud.extend.rabbitmq.impl

类 RabbitConsumeHandler

java.lang.Object

com.rabbitmq.client.DefaultConsumer

org.noear.solon.cloud.extend.rabbitmq.impl.RabbitConsumeHandler

所有已实现的接口:

com.rabbitmq.client.Consumer

public class RabbitConsumeHandler
extends com.rabbitmq.client.DefaultConsumer

消费者接收处理

从以下版本开始:

1.3, 2.6

字段概要

字段

限定符和类型	字段和说明
protected RabbitConfig	config
protected java.lang.String	eventChannelName
protected CloudEventObserverManger	observerManger
protected RabbitProducer	producer

构造器概要

构造器

构造器和说明
RabbitConsumeHandler(RabbitProducer producer, RabbitConfig config, com.rabbitmq.client.Channel channel, CloudEventObserverManger observerManger)

方法概要

限定符和类型	方法和说明
void	handleDelivery(java.lang.String consumerTag, com.rabbitmq.client.Envelope envelope, com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body)

从类继承的方法 com.rabbitmq.client.DefaultConsumer

getChannel, getConsumerTag, handleCancel, handleCancelOk, handleConsumeOk, handleRecoverOk, handleShutdownSignal

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

observerManger

protected final CloudEventObserverManger observerManger

config

protected final RabbitConfig config

producer

protected final RabbitProducer producer

eventChannelName

protected final java.lang.String eventChannelName

构造器详细资料

RabbitConsumeHandler

public RabbitConsumeHandler(RabbitProducer producer,
                            RabbitConfig config,
                            com.rabbitmq.client.Channel channel,
                            CloudEventObserverManger observerManger)

方法详细资料

handleDelivery

public void handleDelivery(java.lang.String consumerTag,
                           com.rabbitmq.client.Envelope envelope,
                           com.rabbitmq.client.AMQP.BasicProperties properties,
                           byte[] body)
                    throws java.io.IOException

指定者:

handleDelivery 在接口中 com.rabbitmq.client.Consumer

覆盖:

handleDelivery 在类中 com.rabbitmq.client.DefaultConsumer

抛出:

java.io.IOException