org.noear.solon.cloud.model

类 Event

java.lang.Object

org.noear.solon.cloud.model.Event

所有已实现的接口:

java.io.Serializable

public class Event
extends java.lang.Object
implements java.io.Serializable

事件模型

从以下版本开始:

1.2

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
Event()
Event(java.lang.String topic, java.lang.String content)

方法概要

限定符和类型	方法和说明
boolean	broadcast() 是否广播的
Event	broadcast(boolean broadcast) 设置广播的
java.lang.String	channel() 获取通道：用于同时支持多个消息队列框架，区分通道
Event	channel(java.lang.String channel) 设置通道
java.lang.String	content() 获取内容
java.lang.String	group() 获取分组
Event	group(java.lang.String group) 设置分组
java.lang.String	key() 获取事件键
Event	key(java.lang.String key) 设置事件键
int	qos() 获取质量：0 只发一次；1 最少发一次；2 发一次并且不重复；（兼容mqtt,kafka）
Event	qos(int qos) 设置质量
boolean	retained() 是否保留的：是否保留最后一条（兼容mqtt）
Event	retained(boolean retained) 设置保留的
java.util.Date	scheduled() 获取预定执行时间（派发时专用）
Event	scheduled(java.util.Date scheduled) 设置预定执行时间
java.lang.String	tags() 获取检索标签
Event	tags(java.lang.String tags) 设置检索标签
int	times() 获取已派发次数（接收时专用）
Event	times(int times) 设置已派发次数
java.lang.String	topic() 获取主题
java.lang.String	toString()
EventTran	tran() 获取事务
Event	tran(EventTran tran) 配置事务

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

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

构造器详细资料

Event

public Event()

Event

public Event(java.lang.String topic,
             java.lang.String content)

参数:

topic - 主题

content - 内容

方法详细资料

tran

public EventTran tran()

获取事务

tran

public Event tran(EventTran tran)

配置事务

topic

public java.lang.String topic()

获取主题

content

public java.lang.String content()

获取内容

key

public java.lang.String key()

获取事件键

key

public Event key(java.lang.String key)

设置事件键

tags

public java.lang.String tags()

获取检索标签

tags

public Event tags(java.lang.String tags)

设置检索标签

scheduled

public java.util.Date scheduled()

获取预定执行时间（派发时专用）

scheduled

public Event scheduled(java.util.Date scheduled)

设置预定执行时间

times

public int times()

获取已派发次数（接收时专用）

times

public Event times(int times)

设置已派发次数

qos

public int qos()

获取质量：0 只发一次；1 最少发一次；2 发一次并且不重复；（兼容mqtt,kafka）

qos

public Event qos(int qos)

设置质量

retained

public boolean retained()

是否保留的：是否保留最后一条（兼容mqtt）

retained

public Event retained(boolean retained)

设置保留的

broadcast

public boolean broadcast()

是否广播的

broadcast

public Event broadcast(boolean broadcast)

设置广播的

group

public java.lang.String group()

获取分组

group

public Event group(java.lang.String group)

设置分组

channel

public java.lang.String channel()

获取通道：用于同时支持多个消息队列框架，区分通道

channel

public Event channel(java.lang.String channel)

设置通道

toString

public java.lang.String toString()

覆盖:

toString 在类中 java.lang.Object