io.appactive.java.api.bridge.mq.message

接口 MessageUnitService<T>

public interface MessageUnitService<T>

方法概要

限定符和类型	方法和说明
String	getMsgUnit(T message) message produce unit
String	getRouteId(T message) message route id
String	getRouteType(T message) message route type
boolean	isUnitGroup(T message) group have unit attribute?
boolean	isUnitTopic(T message) topic have unit attribute?

方法详细资料

isUnitTopic

boolean isUnitTopic(T message)

topic have unit attribute?

参数:

message - message obj

返回:

have? true:false

isUnitGroup

boolean isUnitGroup(T message)

group have unit attribute?

参数:

message - message obj

返回:

have? true:false

getRouteType

String getRouteType(T message)

message route type

参数:

message - message obj

返回:

route type

getRouteId

String getRouteId(T message)

message route id

参数:

message - message obj

返回:

route id

getMsgUnit

String getMsgUnit(T message)

message produce unit

参数:

message - message obj

返回:

produce unit