Fix group is set error if producer id not set (#8)
diff --git a/src/main/cpp/sdk/common/UtilAll.cpp b/src/main/cpp/sdk/common/UtilAll.cpp
index 9a4fc59..55de74f 100644
--- a/src/main/cpp/sdk/common/UtilAll.cpp
+++ b/src/main/cpp/sdk/common/UtilAll.cpp
@@ -46,7 +46,7 @@
memset(&fp, 0, sizeof(factory_property));
string groupID(factoryProperty.getGroupId());
if (!groupID.empty()) {
- fp.group_id = const_cast<char *>(factoryProperty.getProducerId());
+ fp.group_id = const_cast<char *>(factoryProperty.getGroupId());
} else {
if (is_producer) {
fp.group_id = const_cast<char *>(factoryProperty.getProducerId());
diff --git a/src/test/c/CPushConsumerTest.cpp b/src/test/c/CPushConsumerTest.cpp
index 9926785..df7cf82 100644
--- a/src/test/c/CPushConsumerTest.cpp
+++ b/src/test/c/CPushConsumerTest.cpp
@@ -19,7 +19,7 @@
void SetUp() override {
consumer_ = CreatePushConsumer("GID_opensource_unit_test");
SetPushConsumerNameServerAddress(consumer_, "47.100.33.127:9876");
- SetPushConsumerSessionCredentials(consumer_, "AK", "SK", "LOCAL");
+ //SetPushConsumerSessionCredentials(consumer_, "AK", "SK", "LOCAL");
//StartPushConsumer(consumer_);
}
@@ -41,6 +41,7 @@
RegisterMessageCallback(consumer_,onMessages);
StartPushConsumer(consumer_);
std::this_thread::sleep_for(std::chrono::milliseconds(10 * 1000));
+ ShutdownPushConsumer(consumer_);
ASSERT_TRUE(nullptr != consumer_);
}