public class CloudEventServiceManagerImpl extends java.lang.Object implements CloudEventServiceManager
构造器和说明 |
---|
CloudEventServiceManagerImpl() |
限定符和类型 | 方法和说明 |
---|---|
void |
attention(EventLevel level,
java.lang.String channel,
java.lang.String group,
java.lang.String topic,
java.lang.String tag,
int qos,
CloudEventHandler observer)
关注事件
|
CloudEventServicePlus |
get(java.lang.String channel)
获取事件服务
|
CloudEventInterceptor |
getEventInterceptor()
获取拦截器
|
CloudEventServicePlus |
getOrThrow(java.lang.String channel)
获取事件服务,如果没有则异常
|
boolean |
publish(Event event)
发布事件
|
void |
register(CloudEventServicePlus service)
注册事件服务
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
newTran, newTranAndJoin
public CloudEventInterceptor getEventInterceptor()
getEventInterceptor
在接口中 CloudEventServiceManager
public void register(CloudEventServicePlus service)
register
在接口中 CloudEventServiceManager
service
- 事件服务public CloudEventServicePlus get(java.lang.String channel)
get
在接口中 CloudEventServiceManager
channel
- 通道public CloudEventServicePlus getOrThrow(java.lang.String channel)
getOrThrow
在接口中 CloudEventServiceManager
channel
- 通道public boolean publish(Event event) throws CloudEventException
publish
在接口中 CloudEventService
event
- 事件CloudEventException
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)
attention
在接口中 CloudEventService
level
- 级别channel
- 通道group
- 分组topic
- 主题observer
- 观察者tag
- 标签qos
- 服务质量