From a5ae204b585fd2b0abe89d2556facf6a49f14d71 Mon Sep 17 00:00:00 2001 From: IrynaMatveieva Date: Wed, 7 Aug 2024 13:17:24 +0300 Subject: [PATCH] changed initialization for test --- .../org/thingsboard/rule/engine/kafka/TbKafkaNodeTest.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/kafka/TbKafkaNodeTest.java b/rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/kafka/TbKafkaNodeTest.java index e89ac2bd10..add12dcec2 100644 --- a/rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/kafka/TbKafkaNodeTest.java +++ b/rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/kafka/TbKafkaNodeTest.java @@ -181,12 +181,11 @@ public class TbKafkaNodeTest { } @Test - public void givenInitErrorIsNotNull_whenOnMsg_thenTellFailure() throws TbNodeException { + public void givenInitErrorIsNotNull_whenOnMsg_thenTellFailure() { // GIVEN - mockSuccessfulInit(); - node.init(ctxMock, new TbNodeConfiguration(JacksonUtil.valueToTree(config))); String errorMsg = "Error during kafka initialization!"; - ReflectionTestUtils.setField(node, "initError", new RuntimeException(errorMsg)); + ReflectionTestUtils.setField(node, "config", config); + ReflectionTestUtils.setField(node, "initError", new ThingsboardKafkaClientError(errorMsg)); // WHEN TbMsg msg = TbMsg.newMsg(TbMsgType.POST_TELEMETRY_REQUEST, DEVICE_ID, TbMsgMetaData.EMPTY, TbMsg.EMPTY_JSON_OBJECT);