MessageClientConsumer (RedkaleProject 2.8.0-SNAPSHOT API)

java.lang.Object
- org.redkale.mq.spi.MessageClientConsumer

所有已实现的接口:

MessageProcessor
```
public abstract class MessageClientConsumer
extends Object
implements MessageProcessor
```
详情见: https://redkale.org

从以下版本开始:

2.1.0

作者:

zhangjx

字段概要

字段
修饰符和类型字段说明

protected Logger logger

protected MessageClient messageClient

构造器概要

构造器
限定符构造器说明

protected MessageClientConsumer(MessageClient messageClient)

方法概要

所有方法实例方法抽象方法具体方法
修饰符和类型	方法	说明
`Collection<String>`	`getTopics()`
`void`	`process(MessageRecord message, long time)`
`abstract void`	`start()`
`abstract void`	`stop()`

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

logger
```
protected final Logger logger
```

messageClient
```
protected MessageClient messageClient
```

构造器详细资料

MessageClientConsumer

protected MessageClientConsumer(MessageClient messageClient)

方法详细资料

getTopics
```
public Collection<String> getTopics()
```

process

public void process(MessageRecord message,
                    long time)

指定者:: process 在接口中 MessageProcessor

start
```
public abstract void start()
```

stop
```
public abstract void stop()
```