SendSubscribeOperationTest() |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
testSendReceiveWithRecordCheckpointMode() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
testSendReceiveWithManualCheckpointMode() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
manualCheckpointHandler(Message) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
testSendString() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
testSendByte() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
testSendUser() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
byteHandler(Message) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$testSendReceiveWithRecordCheckpointMode$1(Message) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
verifyCheckpointSuccess(Checkpointer) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
verifyCheckpointFailure(Checkpointer) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$new$0(User) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
stringHandler(Message) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
userHandler(Message) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setSendSubscribeOperation(SendOperation) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setPartitionId(String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setDestination(String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setUserMessage(Message) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setMessages(List) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getSendSubscribeOperation() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPartitionId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDestination() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getUserMessage() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMessages() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
recordCheckpointHandler(Message) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |