com.duoec.graphql.service.message

类 ProviderRegistryMessageServiceImpl

java.lang.Object

com.duoec.graphql.service.message.ProviderRegistryMessageServiceImpl

所有已实现的接口:

MessageService

@Service
public class ProviderRegistryMessageServiceImpl
extends Object

Provider 注册消息处理器

作者:

xuwenzhen

字段概要

字段

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

构造器概要

构造器

构造器和说明
ProviderRegistryMessageServiceImpl()

方法概要

限定符和类型	方法和说明
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

构造器详细资料

ProviderRegistryMessageServiceImpl

public ProviderRegistryMessageServiceImpl()

方法详细资料

getTopic

public String getTopic()

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

返回:

topic / pattern

process

public void process(String channel,
                    String data)

从接口复制的说明: MessageService

处理消息

参数:

channel - 频道名称

data - 接收到的数据

init

@PostConstruct
public void init()