diff --git a/experiments/speedtest/consumer.c b/experiments/speedtest/consumer.c index fb7d2f9..e2fbf66 100644 --- a/experiments/speedtest/consumer.c +++ b/experiments/speedtest/consumer.c @@ -103,8 +103,12 @@ int main(int argc, char *argv[]) { f = fdopen(fd, "a+"); - fprintf(f, "(9:subscribe5:test%c0:0:5:test%c5:login)(4:post7:factory(6:create%d:%s(2:q1)5:test%c1:k)0:)(4:post2:q1(9:subscribe0:5:test%c8:consumer5:test%c1:k)0:)\n", - idchar, idchar, (int) strlen(qclass), qclass, idchar, idchar, idchar); + fprintf(f, "(9:subscribe5:test%c0:0:5:test%c5:login)\n", idchar, idchar); + fprintf(f, "(4:post7:factory(6:create%d:%s(2:q1)5:test%c1:k)0:)\n", + (int) strlen(qclass), qclass, idchar); + fflush(f); + usleep(100000); + fprintf(f, "(4:post2:q1(9:subscribe0:5:test%c8:consumer5:test%c1:k)0:)\n", idchar, idchar); fflush(f); while (1) {