public class CloudEventServiceLocalImpl extends java.lang.Object implements CloudEventServicePlus
构造器和说明 |
---|
CloudEventServiceLocalImpl(CloudProps cloudProps) |
限定符和类型 | 方法和说明 |
---|---|
void |
attention(EventLevel level,
java.lang.String channel,
java.lang.String group,
java.lang.String topic,
java.lang.String tag,
int qos,
CloudEventHandler observer)
关注事件(相当于订阅)
|
void |
distribute(Event event) |
java.lang.String |
getChannel()
获取通道配置
|
java.lang.String |
getGroup()
获取默认分组配置(即给所有的发送和订阅加上分组)
|
boolean |
publish(Event event)
发布事件
|
public CloudEventServiceLocalImpl(CloudProps cloudProps)
public boolean publish(Event event) throws CloudEventException
CloudEventService
publish
在接口中 CloudEventService
event
- 事件CloudEventException
public void distribute(Event event) throws java.lang.Throwable
java.lang.Throwable
public void attention(EventLevel level, java.lang.String channel, java.lang.String group, java.lang.String topic, java.lang.String tag, int qos, CloudEventHandler observer)
CloudEventService
attention
在接口中 CloudEventService
level
- 事件级别channel
- 通道group
- 分组topic
- 主题tag
- 标签qos
- 服务质量observer
- 观察者public java.lang.String getChannel()
CloudEventServicePlus
getChannel
在接口中 CloudEventServicePlus
public java.lang.String getGroup()
CloudEventServicePlus
getGroup
在接口中 CloudEventServicePlus