com.github.thisxulz.redmq.client.consumer.service.impl

类 ConsumerServiceImpl

java.lang.Object

com.github.thisxulz.redmq.client.consumer.service.impl.ConsumerServiceImpl

所有已实现的接口:

ConsumerService

public class ConsumerServiceImpl
extends Object
implements ConsumerService

作者:

xulz

字段概要

字段

限定符和类型	字段和说明
private DefaultConsumer	defaultConsumer
private static ClientLog	log
private com.github.thisxulz.redmq.utils.redis.RedisService	redisService

构造器概要

构造器

构造器和说明
ConsumerServiceImpl(DefaultConsumer defaultConsumer, com.github.thisxulz.redmq.utils.redis.RedisService redisService)

方法概要

限定符和类型	方法和说明
ConsumeMessageResult	dealMessage() 处理消息
DefaultConsumer	getDefaultConsumer()
void	setRedisService(com.github.thisxulz.redmq.utils.redis.RedisService redisService)

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

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

字段详细资料

log

private static final ClientLog log

defaultConsumer

private DefaultConsumer defaultConsumer

redisService

private com.github.thisxulz.redmq.utils.redis.RedisService redisService

构造器详细资料

ConsumerServiceImpl

public ConsumerServiceImpl(DefaultConsumer defaultConsumer,
                           com.github.thisxulz.redmq.utils.redis.RedisService redisService)

方法详细资料

dealMessage

public ConsumeMessageResult dealMessage()

从接口复制的说明: ConsumerService

处理消息

指定者:

dealMessage 在接口中 ConsumerService

返回:

getDefaultConsumer

public DefaultConsumer getDefaultConsumer()

指定者:

getDefaultConsumer 在接口中 ConsumerService

返回:

setRedisService

public void setRedisService(com.github.thisxulz.redmq.utils.redis.RedisService redisService)