public class JetlangFiberSession extends Object implements JetlangSession
| Constructor and Description |
|---|
JetlangFiberSession(JetlangSession session,
org.jetlang.fibers.Fiber targetFiber) |
| Modifier and Type | Method and Description |
|---|---|
void |
disconnect()
Attempts to disconnect the client.
|
org.jetlang.fibers.Fiber |
getFiber() |
org.jetlang.channels.Subscriber<HeartbeatEvent> |
getHeartbeatChannel() |
org.jetlang.channels.Subscriber<LogoutEvent> |
getLogoutChannel() |
org.jetlang.channels.Subscriber<ReadTimeoutEvent> |
getReadTimeoutChannel() |
org.jetlang.channels.Subscriber<SessionCloseEvent> |
getSessionCloseChannel() |
Object |
getSessionId() |
org.jetlang.channels.Subscriber<SessionMessage<?>> |
getSessionMessageChannel() |
org.jetlang.channels.Subscriber<SessionRequest> |
getSessionRequestChannel() |
org.jetlang.channels.Subscriber<SessionTopic> |
getSubscriptionRequestChannel() |
Map<String,SessionTopic> |
getSubscriptions() |
org.jetlang.channels.Subscriber<String> |
getUnsubscribeChannel() |
boolean |
isSubscribed(String topic) |
void |
publish(byte[] data)
publish raw bytes.
|
<T> void |
publish(String topic,
T msg) |
public JetlangFiberSession(JetlangSession session, org.jetlang.fibers.Fiber targetFiber)
public Map<String,SessionTopic> getSubscriptions()
public boolean isSubscribed(String topic)
public org.jetlang.fibers.Fiber getFiber()
public Object getSessionId()
getSessionId in interface JetlangSessionpublic org.jetlang.channels.Subscriber<SessionTopic> getSubscriptionRequestChannel()
getSubscriptionRequestChannel in interface JetlangSessionpublic org.jetlang.channels.Subscriber<String> getUnsubscribeChannel()
getUnsubscribeChannel in interface JetlangSessionpublic org.jetlang.channels.Subscriber<LogoutEvent> getLogoutChannel()
getLogoutChannel in interface JetlangSessionpublic org.jetlang.channels.Subscriber<HeartbeatEvent> getHeartbeatChannel()
getHeartbeatChannel in interface JetlangSessionpublic org.jetlang.channels.Subscriber<SessionMessage<?>> getSessionMessageChannel()
getSessionMessageChannel in interface JetlangSessionpublic org.jetlang.channels.Subscriber<SessionRequest> getSessionRequestChannel()
getSessionRequestChannel in interface JetlangSessionpublic org.jetlang.channels.Subscriber<ReadTimeoutEvent> getReadTimeoutChannel()
getReadTimeoutChannel in interface JetlangSessionpublic org.jetlang.channels.Subscriber<SessionCloseEvent> getSessionCloseChannel()
getSessionCloseChannel in interface JetlangSessionpublic void disconnect()
JetlangSessiondisconnect in interface JetlangSessionpublic void publish(byte[] data)
JetlangSessionpublish in interface JetlangSessionpublic <T> void publish(String topic, T msg)
publish in interface JetlangSessionCopyright © 2016. All Rights Reserved.