@@ -170,3 +170,22 @@ TEST_F(MqttAdapterTest, should_change_if_host_changes)
170170 ASSERT_EQ (" mqtt://localhost:1883/" , adapter->getName ());
171171 ASSERT_EQ (" _4cd2e64d4e" , adapter->getIdentity ());
172172}
173+
174+ TEST_F (MqttAdapterTest, should_be_able_to_set_adapter_identity)
175+ {
176+ asio::io_context ioc;
177+ asio::io_context::strand strand (ioc);
178+ ConfigOptions options {{configuration::Url, " mqtt://mybroker.com:1883" s},
179+ {configuration::Host, " mybroker.com" s},
180+ {configuration::Port, 1883 },
181+ {configuration::Protocol, " mqtt" s},
182+ {configuration::AdapterIdentity, " MyIdentity" s},
183+ {configuration::Topics, StringList {" pipeline/#" s}}};
184+ boost::property_tree::ptree tree;
185+ pipeline::PipelineContextPtr context = make_shared<pipeline::PipelineContext>();
186+ context->m_contract = make_unique<MockPipelineContract>(SCHEMA_VERSION (2 , 5 ));
187+ auto adapter = make_unique<MqttAdapter>(ioc, context, options, tree);
188+
189+ ASSERT_EQ (" mqtt://mybroker.com:1883/" , adapter->getName ());
190+ ASSERT_EQ (" MyIdentity" , adapter->getIdentity ());
191+ }
0 commit comments