club.codefocus.framework.rabbit.api

类 AbsMQConsumerService

java.lang.Object

club.codefocus.framework.rabbit.api.AbsMQConsumerService

所有已实现的接口:

MQConsumerService, org.springframework.amqp.core.MessageListener, org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener

public abstract class AbsMQConsumerService
extends Object
implements MQConsumerService

作者:

jackl

构造器概要

构造器

构造器和说明
AbsMQConsumerService()

方法概要

限定符和类型	方法和说明
protected void	autoAck(org.springframework.amqp.core.Message message, com.rabbitmq.client.Channel channel, boolean success)
void	onMessage(org.springframework.amqp.core.Message message, com.rabbitmq.client.Channel channel)
abstract boolean	process(org.springframework.amqp.core.Message message, com.rabbitmq.client.Channel channel)
void	setContainer(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container)
void	shutdown()
void	start()
void	stop()

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

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

从接口继承的方法 org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener

onMessage

从接口继承的方法 org.springframework.amqp.core.MessageListener

containerAckMode

构造器详细资料

AbsMQConsumerService

public AbsMQConsumerService()

方法详细资料

setContainer

public void setContainer(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container)

指定者:

setContainer 在接口中 MQConsumerService

shutdown

public void shutdown()

指定者:

shutdown 在接口中 MQConsumerService

autoAck

protected void autoAck(org.springframework.amqp.core.Message message,
                       com.rabbitmq.client.Channel channel,
                       boolean success)
                throws IOException

抛出:

IOException

onMessage

public void onMessage(org.springframework.amqp.core.Message message,
                      com.rabbitmq.client.Channel channel)
               throws Exception

指定者:

onMessage 在接口中 org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener

抛出:

Exception

start

public void start()

stop

public void stop()

process

public abstract boolean process(org.springframework.amqp.core.Message message,
                                com.rabbitmq.client.Channel channel)