| 限定符和类型 | 方法和说明 |
|---|---|
protected Message |
MsgCodecImpl.createMessage(java.lang.String command,
java.util.List<Header> headers,
java.lang.String payload) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
Stomp.ack(Message message)
确认收到某条消息
|
java.lang.String |
MsgCodecImpl.encode(Message input) |
java.lang.String |
MsgCodec.encode(Message input)
编码
|
protected java.util.List<Header> |
MsgCodecImpl.msgHeaders(Message input) |
void |
Stomp.send(Message message)
发送消息给服务器
|
boolean |
Subscriber.tryCallback(java.lang.String id,
Message msg) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected void |
MsgCodecImpl.decode(OnCallback<Message> out,
int start) |
void |
MsgCodecImpl.decode(java.lang.String input,
OnCallback<Message> out) |
void |
MsgCodec.decode(java.lang.String input,
OnCallback<Message> out)
解码
|
Stomp |
Stomp.queue(java.lang.String destination,
java.util.List<Header> headers,
OnCallback<Message> callback)
监听队列消息
|
Stomp |
Stomp.queue(java.lang.String destination,
OnCallback<Message> callback)
监听队列消息
|
Stomp |
Stomp.setOnError(OnCallback<Message> onError)
错误回调(服务器返回的错误信息)
|
Stomp |
Stomp.subscribe(java.lang.String destination,
java.util.List<Header> headers,
OnCallback<Message> callback)
订阅消息
|
Stomp |
Stomp.topic(java.lang.String destination,
java.util.List<Header> headers,
OnCallback<Message> callback)
监听主题消息
|
Stomp |
Stomp.topic(java.lang.String destination,
OnCallback<Message> callback)
监听主题消息
|
| 构造器和说明 |
|---|
Subscriber(Stomp stomp,
java.lang.String destination,
OnCallback<Message> callback,
java.util.List<Header> headers) |
Copyright © 2021 江苏一键联信息科技有限公司. All Rights Reserved.