success(DeliveryState) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
error(Throwable) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
incrementRetryAttempts() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setLastKnownException(Exception) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getTimeoutTracker() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getLastKnownException() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isWaitingForAck() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
hasBeenRetried() |   | 87% |   | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
isDeliveryStateProvided() |   | 85% |   | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
RetriableWorkItem(byte[], int, int, MonoSink, TimeoutTracker, DeliveryState) |  | 100% | | n/a | 0 | 1 | 0 | 9 | 0 | 1 |
RetriableWorkItem(byte[], int, int, MonoSink, Duration, DeliveryState) |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
setWaitingForAck() |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
getMessage() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getDeliveryState() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getEncodedMessageSize() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getMessageFormat() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |