public class SingleServiceCoreSession extends java.lang.Object implements CoreSession
| Constructor and Description |
|---|
SingleServiceCoreSession(java.lang.String host,
int port,
java.lang.String id,
java.time.Clock clock,
Connection connection,
MessageProvider messageProvider,
BackPressureNotificationHandler backPressureNotificationHandler,
java.nio.ByteBuffer sendByteBuffer,
java.nio.ByteBuffer receiveByteBuffer)
Construct
|
| Modifier and Type | Method and Description |
|---|---|
void |
connect()
Attempts to connect to the configured server by host and port.
|
void |
disconnect() |
java.lang.String |
getId() |
long |
getLastReceivedMessageTimestampMs() |
long |
getLastSentMessageTimestampMs() |
boolean |
isConnected() |
boolean |
isWritePending() |
void |
readNext(MessageHandler messageHandler) |
int |
send(int byteCount)
Tries to send the message.
|
java.lang.String |
toString() |
boolean |
tryConnect() |
int |
writePendingBytes() |
public SingleServiceCoreSession(java.lang.String host,
int port,
java.lang.String id,
java.time.Clock clock,
Connection connection,
MessageProvider messageProvider,
BackPressureNotificationHandler backPressureNotificationHandler,
java.nio.ByteBuffer sendByteBuffer,
java.nio.ByteBuffer receiveByteBuffer)
host - host to connect toport - port to connect toid - descriptive session identifierclock - clockconnection - connection to usemessageProvider - source of input messagesbackPressureNotificationHandler - handler tosendByteBuffer - buffer to send data withreceiveByteBuffer - buffer to receive data withpublic void connect()
CoreSessionconnect in interface CoreSessionpublic void disconnect()
disconnect in interface CoreSessionpublic void readNext(MessageHandler messageHandler)
readNext in interface CoreSessionpublic java.lang.String getId()
getId in interface CoreSessionpublic boolean isWritePending()
isWritePending in interface CoreSessionpublic int writePendingBytes()
writePendingBytes in interface CoreSessionpublic boolean isConnected()
isConnected in interface CoreSessionpublic boolean tryConnect()
tryConnect in interface CoreSessionpublic long getLastReceivedMessageTimestampMs()
getLastReceivedMessageTimestampMs in interface CoreSessionpublic long getLastSentMessageTimestampMs()
getLastSentMessageTimestampMs in interface CoreSessionpublic java.lang.String toString()
toString in class java.lang.Objectpublic int send(int byteCount)
CoreSessionsend in interface CoreSessionbyteCount - total number of bytes to write