acknowledgeRejectedIncomingMessageIfShouldNotRedeliver | 0.12 sec | Passed |
doNotRedeliverRejectedMessageIfShouldDeliverButReconnectForRedeliveryIsDisabled | 0.12 sec | Passed |
mqttPublishSourceGetsThrottledIfThrottlingIsEnabled | 1 sec | Passed |
mqttPublishSourceThrottlingWorksAsExpected | 2 sec | Passed |
mqttPublishesAreDroppedIfConsumerActorOperatesInDryRunMode | 1 sec | Passed |
mqttPublishesAreMappedToExternalMessagesAndSentToInboundMappingSink | 56 ms | Passed |
propsProcessingWithNullConnectionSourceThrowsException | 1 ms | Passed |
propsProcessingWithNullConnectionThrowsException | 1 ms | Passed |
propsProcessingWithNullConnectivityConfigThrowsException | 1 ms | Passed |
propsProcessingWithNullConnectivityStatusResolverThrowsException | 1 ms | Passed |
propsProcessingWithNullInboundMappingSinkThrowsException | 1 ms | Passed |
propsProcessingWithNullMqttPublishSourceThrowsException | 0 ms | Passed |
reconnectConsumerClientForRedeliveryIfInboundMessageIsRejected | 16 ms | Passed |
rejectIncomingMessageDueToDittoRuntimeExceptionInsteadOfAcknowledgement | 0.12 sec | Passed |
sendGracefulStopShutsDownProcessingMqttConsumerActor | 13 ms | Passed |
sendRetrieveAddressStatusToMqttConsumerActorReturnsCurrentSourceStatus | 0.28 sec | Passed |
successfullyAcknowledgeMqttPublish | 0.27 sec | Passed |