private class InternalStreamConnection.CommandEventSender
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private InternalStreamConnection.LazyCommandDocument |
lazyCommandDocument |
private CommandMessage |
message |
private long |
startTimeNanos |
Constructor and Description |
---|
CommandEventSender(CommandMessage message,
InternalStreamConnection.LazyCommandDocument lazyCommandDocument) |
Modifier and Type | Method and Description |
---|---|
void |
sendFailedEvent(java.lang.Throwable t) |
void |
sendStartedEvent() |
void |
sendSucceededEvent(ResponseBuffers responseBuffers) |
void |
sendSucceededEventForOneWayCommand() |
private final long startTimeNanos
private final CommandMessage message
private final InternalStreamConnection.LazyCommandDocument lazyCommandDocument
CommandEventSender(CommandMessage message, InternalStreamConnection.LazyCommandDocument lazyCommandDocument)
public void sendStartedEvent()
public void sendFailedEvent(java.lang.Throwable t)
public void sendSucceededEvent(ResponseBuffers responseBuffers)
public void sendSucceededEventForOneWayCommand()