public class JetlangClientHandler extends Object implements Acceptor.ClientHandler, ClientPublisher
| Modifier and Type | Class and Description |
|---|---|
static interface |
JetlangClientHandler.FiberFactory |
| Constructor and Description |
|---|
JetlangClientHandler(SerializerAdapter ser,
NewSessionHandler channels,
Executor exec,
JetlangSessionConfig config,
JetlangClientHandler.FiberFactory fiberFactory,
ErrorHandler errorHandler) |
JetlangClientHandler(SerializerFactory fact,
NewSessionHandler channels,
Executor exec,
JetlangSessionConfig config,
JetlangClientHandler.FiberFactory fiberFactory,
ErrorHandler errorHandler) |
| Modifier and Type | Method and Description |
|---|---|
int |
clientCount() |
void |
close() |
void |
enqueueToAllSubscribedClients(String topic,
byte[] data)
Places the serialized bytes into the send q's for all subscribed clients.
|
void |
publishToAllSubscribedClients(String topic,
Object msg)
Publishes asynchronously on a separate global fiber, so be careful of message ordering when using with other fibers/threads.
|
void |
startClient(Socket socket) |
public JetlangClientHandler(SerializerFactory fact, NewSessionHandler channels, Executor exec, JetlangSessionConfig config, JetlangClientHandler.FiberFactory fiberFactory, ErrorHandler errorHandler)
public JetlangClientHandler(SerializerAdapter ser, NewSessionHandler channels, Executor exec, JetlangSessionConfig config, JetlangClientHandler.FiberFactory fiberFactory, ErrorHandler errorHandler)
public void startClient(Socket socket)
startClient in interface Acceptor.ClientHandlerpublic void close()
close in interface Acceptor.ClientHandlerpublic int clientCount()
public void publishToAllSubscribedClients(String topic, Object msg)
publishToAllSubscribedClients in interface ClientPublisherpublic void enqueueToAllSubscribedClients(String topic, byte[] data)
Copyright © 2016. All Rights Reserved.