public class JetlangStreamSession extends JetlangBaseSession implements JetlangRemotingProtocol.Handler
Heartbeat, id, Logout, Messages, ReadTimeout, SessionClose, SessionRequest, SubscriptionRequest, UnsubscribeRequest| Constructor and Description |
|---|
JetlangStreamSession(Object id,
MessageStreamWriter socket,
org.jetlang.fibers.Fiber sendFiber,
ErrorHandler errorHandler) |
| Modifier and Type | Method and Description |
|---|---|
void |
disconnect()
Attempts to disconnect the client.
|
void |
onLogout() |
void |
onRequestReply(int reqId,
String dataTopicVal,
Object readObject) |
void |
onSubscriptionRequest(String topic) |
void |
onUnknownMessage(int read) |
void |
onUnsubscribeRequest(String top) |
void |
publish(byte[] data)
publish raw bytes.
|
<T> void |
publish(String topic,
T msg) |
void |
publishIfSubscribed(String topic,
byte[] data) |
void |
reply(int reqId,
String replyTopic,
Object replyMsg) |
void |
startHeartbeat(int interval,
TimeUnit unit) |
getHeartbeatChannel, getLogoutChannel, getReadTimeoutChannel, getSessionCloseChannel, getSessionId, getSessionMessageChannel, getSessionRequestChannel, getSubscriptionRequestChannel, getUnsubscribeChannel, newChannel, onClose, onHb, onMessage, onReadTimeout, onRequestclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitonHb, onMessage, onRequestpublic JetlangStreamSession(Object id, MessageStreamWriter socket, org.jetlang.fibers.Fiber sendFiber, ErrorHandler errorHandler)
public void startHeartbeat(int interval,
TimeUnit unit)
public void onSubscriptionRequest(String topic)
onSubscriptionRequest in interface JetlangRemotingProtocol.HandleronSubscriptionRequest in class JetlangBaseSessionpublic void onUnsubscribeRequest(String top)
onUnsubscribeRequest in interface JetlangRemotingProtocol.HandleronUnsubscribeRequest in class JetlangBaseSessionpublic void disconnect()
JetlangSessiondisconnect in interface JetlangSessionpublic void onLogout()
onLogout in interface JetlangRemotingProtocol.HandleronLogout in class JetlangBaseSessionpublic void onUnknownMessage(int read)
onUnknownMessage in interface JetlangRemotingProtocol.Handlerpublic <T> void publish(String topic, T msg)
publish in interface JetlangMessagePublisherpublish in interface JetlangSessionpublic void publish(byte[] data)
JetlangSessionpublish in interface JetlangSessionpublish in class JetlangBaseSessionpublic void reply(int reqId,
String replyTopic,
Object replyMsg)
reply in interface JetlangMessagePublisherreply in class JetlangBaseSessionpublic void onRequestReply(int reqId,
String dataTopicVal,
Object readObject)
onRequestReply in interface JetlangRemotingProtocol.Handlerpublic void publishIfSubscribed(String topic, byte[] data)
publishIfSubscribed in class JetlangBaseSessionCopyright © 2016. All Rights Reserved.