--- mqtt/src/Attic/mqtt.c 2011/11/24 01:13:28 1.1.1.1.2.11 +++ mqtt/src/Attic/mqtt.c 2011/11/24 13:57:12 1.1.1.1.2.12 @@ -57,6 +57,12 @@ main(int argc, char **argv) } else call.LOG(logg, "Login: %s\n", ret ? "ALLOW" : "DENIED"); + if ((ret = call.InitSessPUB(&cfg, pub, "misho", "127.0.0.1", 12345)) == -1) { + printf("Error:: Session problem\n"); + goto end; + } else + call.LOG(logg, "InitSess: %d\n", ret); + end: call.CloseLOG(logg); call.ClosePUB(pub);