com.duoec.graphql.service.message

类 SubscriptionMessageServiceImpl

java.lang.Object

com.duoec.graphql.service.message.SubscriptionMessageServiceImpl

所有已实现的接口:

MessageService

@Service
public class SubscriptionMessageServiceImpl
extends Object

订阅消息处理

作者:

xuwenzhen

字段概要

字段

限定符和类型	字段和说明
protected GraphqlRegisterConfigure	graphQLRegisterConfigure

构造器概要

构造器

构造器和说明
SubscriptionMessageServiceImpl()

方法概要

限定符和类型	方法和说明
String	getTopic() 获取当前消息处理的topic或pattern
void	init()
void	process(String channel, String data) 处理消息

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

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

字段详细资料

graphQLRegisterConfigure

@Autowired
protected GraphqlRegisterConfigure graphQLRegisterConfigure

构造器详细资料

SubscriptionMessageServiceImpl

public SubscriptionMessageServiceImpl()

方法详细资料

getTopic

public String getTopic()

获取当前消息处理的topic或pattern

返回:

topic / pattern

process

public void process(String channel,
                    String data)

处理消息

参数:

channel - 频道名称

data - 接收到的数据

init

@PostConstruct
public void init()