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, waitnewTran, newTranAndJoinpublic CloudEventInterceptor getEventInterceptor()
getEventInterceptor 在接口中 CloudEventServiceManagerpublic void register(CloudEventServicePlus service)
register 在接口中 CloudEventServiceManagerservice - 事件服务public CloudEventServicePlus get(java.lang.String channel)
get 在接口中 CloudEventServiceManagerchannel - 通道public CloudEventServicePlus getOrThrow(java.lang.String channel)
getOrThrow 在接口中 CloudEventServiceManagerchannel - 通道public boolean publish(Event event) throws CloudEventException
publish 在接口中 CloudEventServiceevent - 事件CloudEventExceptionpublic 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 在接口中 CloudEventServicelevel - 级别channel - 通道group - 分组topic - 主题observer - 观察者tag - 标签qos - 服务质量