Interface SessionWriteRequest
-
public interface SessionWriteRequest
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description IgniteInClosure<IgniteException>ackClosure()Objectmessage()booleanmessageThread()voidmessageThread(boolean msgThread)Sets flag indicating that message send future was created in thread that was processing a message.voidonAckReceived()The method will be called when ack received.voidonError(Exception e)voidonMessageWritten()voidresetSession(GridNioSession ses)GridNioSessionsession()booleanskipRecovery()Spanspan()Stored span for tracing.
-
-
-
Method Detail
-
messageThread
void messageThread(boolean msgThread)
Sets flag indicating that message send future was created in thread that was processing a message.- Parameters:
msgThread-Trueif future was created in thread that is processing message.
-
messageThread
boolean messageThread()
- Returns:
Trueif future was created in thread that was processing message.
-
skipRecovery
boolean skipRecovery()
- Returns:
Trueif skip recovery for this operation.
-
onAckReceived
void onAckReceived()
The method will be called when ack received.
-
ackClosure
IgniteInClosure<IgniteException> ackClosure()
- Returns:
- Ack closure.
-
session
GridNioSession session()
- Returns:
- Session.
-
resetSession
void resetSession(GridNioSession ses)
- Parameters:
ses- Session.
-
onError
void onError(Exception e)
-
message
Object message()
- Returns:
- Message.
-
onMessageWritten
void onMessageWritten()
-
span
Span span()
Stored span for tracing.- Returns:
- Span.
-
-