- g_mqSelectedTopicResource = gTopicList[index];
- cout << g_mqSelectedTopicResource->uri() << " selected" << endl;
- }
- break;
-
- case '3':
- if(g_mqSelectedTopicResource == nullptr)
- {
- cout << "Topic is not selected." << endl;
- continue;
- }
-
- cout << "Put message to selected topic: ";
- cin >> cmd;
- rep["message"] = cmd;
- result = g_mqSelectedTopicResource->publishMQTopic(rep, query, &publishMessageCB,
- QualityOfService::LowQos);
- break;
-
- case '4':
- cout << "Put topic uri to create: ";
- cin >> cmd;
- result = g_mqBrokerResource->createMQTopic(rep, cmd, query, &createTopicCB,
- QualityOfService::LowQos);
- break;
-
- case '5':
- cout << "Put topic uri to create: ";
- cin >> cmd;
- cout << "Put topic type: ";
- cin >> topicType;
- query["rt"] = topicType;
- result = g_mqBrokerResource->createMQTopic(rep, cmd, query, &createTopicCB,
- QualityOfService::LowQos);
- break;
-
- case 'q':
- goto exit;
- break;
- }
+ cout << "Put message to selected topic: ";
+ cin >> cmd;
+ rep["message"] = cmd;
+ result = g_mqSelectedTopicResource->publishMQTopic(rep, query, &publishMessageCB,
+ QualityOfService::LowQos);
+ break;
+
+ case '4':
+ cout << "Put topic uri to create: ";
+ cin >> cmd;
+ result = g_mqBrokerResource->createMQTopic(rep, cmd, query, &createTopicCB,
+ QualityOfService::LowQos);
+ break;
+
+ case '5':
+ cout << "Put topic uri to create: ";
+ cin >> cmd;
+ cout << "Put topic type: ";
+ cin >> topicType;
+ query["rt"] = topicType;
+ result = g_mqBrokerResource->createMQTopic(rep, cmd, query, &createTopicCB,
+ QualityOfService::LowQos);
+ break;