Adapted tests

src/Test.cpp

@@ -215,7 +215,7 @@ void testNoApp(Server& server, int time) {
 int main(int argc, char *argv[]) {
 
 	if (argc < 3) {
-		// ex: ./testcameo tcp://localhost:7000 fastout 1
+		// ex: ./testcameo tcp://localhost:10000 fastout 1
 		cout << "syntax: testcameo <endpoint> <test>\n";
 		return -1;
 	}

src/TestNonSyncSubscriberApplication.cpp

@@ -66,9 +66,9 @@ int main(int argc, char *argv[]) {
 		application::This::setRunning();
 
 		// receiving data
-		vector<int32_t> data;
+		string data;
 		while (subscriber->receive(data)) {
-			cout << "received " << data[0] << ", " << data[1] << endl;
+			cout << "received " << data << endl;
 		}
 
 		cout << "finished stream" << endl;

src/TestNonSyncSubscribersAndPublisherApplication.cpp

@@ -78,10 +78,11 @@ int main(int argc, char *argv[]) {
 		int j = 0;
 		while (j < 20) {
 
-			int data[] = {j, j * j};
-			publisher->send(data, 2);
+			string data = "{";
+			data += to_string(j) + ", " + to_string(j * j) + "}";
+			publisher->send(data);
 
-			cout << "sent " << data[0] << ", " << data[1] << endl;
+			cout << "sent " << data << endl;
 
 			this_thread::sleep_for(chrono::milliseconds(100));
 

src/TestStartWithStopApplication.cpp

@@ -59,7 +59,7 @@ int main(int argc, char *argv[]) {
 			cout << "stopping application " << stopApplication->getNameId() << endl;
 			stopApplication->stop();
 
-			stopApplication->waitFor(StateHandler());
+			//stopApplication->waitFor(StateHandler());
 
 			string result;
 			if (stopApplication->getResult(result)) {