Skip to content

Commit ccf308a

Browse files
fix unit test
1 parent 0707623 commit ccf308a

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

‎application/src/test/java/org/thingsboard/mqtt/broker/actors/device/PersistedDeviceActorMessageProcessorTest.java‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -337,6 +337,7 @@ public void givenDevicePublishMsg_whenChannelNonWritable_thenStopProcessing() {
337337

338338
@Test
339339
public void givenDevicePublishMsg_whenMessageIsNotExpired_thenProcessingIsCorrect() {
340+
persistedDeviceActorMessageProcessor.setSessionCtx(mock(ClientSessionCtx.class));
340341
MqttProperties properties = new MqttProperties();
341342
properties.add(new MqttProperties.IntegerProperty(BrokerConstants.PUB_EXPIRY_INTERVAL_PROP_ID, 100));
342343

0 commit comments

Comments
 (0)