From 489bea5a5155ed0b9eca811878e162fc35c5d6c3 Mon Sep 17 00:00:00 2001 From: mkrzewic Date: Tue, 27 Nov 2018 13:43:54 +0100 Subject: [PATCH] Add simple test for factory pointer setting at receive --- test/protocols/_push_pull_multipart.cxx | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/test/protocols/_push_pull_multipart.cxx b/test/protocols/_push_pull_multipart.cxx index 0d07d262..d82c8cbd 100644 --- a/test/protocols/_push_pull_multipart.cxx +++ b/test/protocols/_push_pull_multipart.cxx @@ -32,6 +32,7 @@ auto RunSingleThreadedMultipart(string transport, string address) -> void { FairMQProgOptions config; config.SetValue("session", std::to_string(session)); auto factory = FairMQTransportFactory::CreateTransportFactory(transport, fair::mq::tools::Uuid(), &config); + FairMQTransportFactory* factoryptr = factory.get(); auto push = FairMQChannel{"Push", "push", factory}; ASSERT_TRUE(push.Bind(address)); auto pull = FairMQChannel{"Pull", "pull", factory}; @@ -55,8 +56,9 @@ auto RunSingleThreadedMultipart(string transport, string address) -> void { ASSERT_GE(pull.Receive(receivedMsg), 0); stringstream out; - for_each(receivedMsg.cbegin(), receivedMsg.cend(), [&out](const FairMQMessagePtr& part) { + for_each(receivedMsg.cbegin(), receivedMsg.cend(), [&out,&factoryptr](const FairMQMessagePtr& part) { out << string{static_cast(part->GetData()), part->GetSize()}; + ASSERT_EQ(part->GetTransport(),factoryptr); }); ASSERT_EQ(out.str(), "123"); }