MessageContext

• Type interface
• Package: com.euonia.bus
• Author: damon(zhaorong@outlook.com)
• Extends: AutoCloseable

Methods¶

getMessage(): Object¶

Returns: Object — 消息对象

getMessageId(): String¶

Returns: String — 消息 ID

setMessageId(String messageId): void¶

Parameters: - messageId (String): 消息 ID

getCorrelationId(): String¶

Returns: String — 关联 ID

setCorrelationId(String correlationId): void¶

Parameters: - correlationId (String): 关联 ID

getConversationId(): String¶

Returns: String — 会话 ID

setConversationId(String conversationId): void¶

Parameters: - conversationId (String): 会话 ID

getRequestTraceId(): String¶

Returns: String — 请求追踪 ID

setRequestTraceId(String requestTraceId): void¶

Parameters: - requestTraceId (String): 请求追踪 ID

getAuthorization(): String¶

Returns: String — 授权字符串

setAuthorization(String authorization): void¶

Parameters: - authorization (String): 授权字符串

getUser(): UserPrincipal¶

Returns: UserPrincipal — 用户主体，可能为 null

getHeaders(): Map<String, String>¶

Returns: Map<String, String> — 包含所有消息头的不可变映射

getMetadata(): MessageMetadata¶

Returns: MessageMetadata — 消息元数据，可能为 null

setMetadata(MessageMetadata metadata): void¶

Parameters: - metadata (MessageMetadata): 消息元数据

response(R message): void¶

Type Parameters: <R> — 响应消息类型

Parameters: - message (R): 响应消息

failure(Throwable throwable): void¶

Parameters: - throwable (Throwable): 处理过程中抛出的异常

complete(Object message): void¶

Parameters: - message (Object): 响应消息

complete(Object message, Class<?> handlerType): void¶

Parameters: - message (Object): 响应消息 - handlerType (Class<?>): 处理器类型