X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=resource%2Funittests%2FOCMQResourceTest.cpp;h=c79f51f03fdea11caf543e9688e52c02d509b37f;hb=eb4cf6824439d79e05685766f2d1e263abeba209;hp=bf2bcb3f4550834a971dfa577403e75abaf07ee2;hpb=6dc5c6adbc159bbeb11ef6a387ad39dfbd0d3d52;p=platform%2Fupstream%2Fiotivity.git diff --git a/resource/unittests/OCMQResourceTest.cpp b/resource/unittests/OCMQResourceTest.cpp index bf2bcb3..c79f51f 100644 --- a/resource/unittests/OCMQResourceTest.cpp +++ b/resource/unittests/OCMQResourceTest.cpp @@ -30,23 +30,26 @@ namespace OCMQResourceTest using namespace OC; #ifdef MQ_SUBSCRIBER - void onObserve(const HeaderOptions, const OCRepresentation&, const int&, const int&) + void onSubscribe(const HeaderOptions, const OCRepresentation&, const int&, const int&) + { + } + + void onReqPub(const HeaderOptions&, const OCRepresentation&, const int) { } #endif #ifdef MQ_PUBLISHER - void onGetPut(const HeaderOptions&, const OCRepresentation& , const int eCode) + void onPublish(const HeaderOptions&, const OCRepresentation&, const int) { } #endif - void foundResource(std::shared_ptr) + void foundResource(const int, const std::string, std::shared_ptr) { } - void createdTopic(const HeaderOptions &, const OCRepresentation &, const int, - std::shared_ptr) + void createdTopic(const int, const std::string, std::shared_ptr) { } @@ -54,7 +57,7 @@ namespace OCMQResourceTest OCResource::Ptr ConstructResourceObject(std::string host, std::string uri) { OCConnectivityType connectivityType = CT_DEFAULT; - std::vector types = {"tkss.wk"}; + std::vector types = {"oic.ps"}; std::vector ifaces = {DEFAULT_INTERFACE}; auto ret = OCPlatform::constructResourceObject(host, uri, @@ -75,7 +78,8 @@ namespace OCMQResourceTest OCResource::Ptr resource = ConstructResourceObject("coap://192.168.1.2:5000", "/resource"); EXPECT_TRUE(resource != NULL); QueryParamsMap query = {}; - EXPECT_EQ(OC_STACK_OK, resource->discoveryMQTopics(query, &foundResource)); + EXPECT_EQ(OC_STACK_OK, resource->discoveryMQTopics(query, &foundResource, + QualityOfService::LowQos)); } TEST(MessageQueueTest, CreateMQTopicValid) @@ -84,7 +88,8 @@ namespace OCMQResourceTest EXPECT_TRUE(resource != NULL); OCRepresentation rep; QueryParamsMap query = {}; - EXPECT_EQ(OC_STACK_OK, resource->createMQTopic(rep, "/ps/nweTopic", query, &createdTopic)); + EXPECT_EQ(OC_STACK_OK, resource->createMQTopic(rep, "/lightTopic", query, &createdTopic, + QualityOfService::LowQos)); } #ifdef MQ_PUBLISHER @@ -94,7 +99,8 @@ namespace OCMQResourceTest EXPECT_TRUE(resource != NULL); OCRepresentation rep; QueryParamsMap query = {}; - EXPECT_EQ(OC_STACK_OK, resource->publishMQTopic(rep, query, &onGetPut)); + EXPECT_EQ(OC_STACK_OK, resource->publishMQTopic(rep, query, &onPublish, + QualityOfService::LowQos)); } #endif @@ -104,7 +110,8 @@ namespace OCMQResourceTest OCResource::Ptr resource = ConstructResourceObject("coap://192.168.1.2:5000", "/resource"); EXPECT_TRUE(resource != NULL); QueryParamsMap query = {}; - EXPECT_EQ(OC_STACK_OK, resource->subscribeMQTopic(ObserveType::Observe, query, &onObserve)); + EXPECT_EQ(OC_STACK_OK, resource->subscribeMQTopic(ObserveType::Observe, query, + &onSubscribe, QualityOfService::LowQos)); } TEST(MessageQueueTest, RequestMQPublishValid) @@ -112,7 +119,8 @@ namespace OCMQResourceTest OCResource::Ptr resource = ConstructResourceObject("coap://192.168.1.2:5000", "/resource"); EXPECT_TRUE(resource != NULL); QueryParamsMap query = {}; - EXPECT_EQ(OC_STACK_OK, resource->requestMQPublish(query, &onGetPut)); + EXPECT_EQ(OC_STACK_OK, resource->requestMQPublish(query, &onReqPub, + QualityOfService::LowQos)); } #endif }