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()