mqtt/src/mqtt.c - diff

Return to mqtt.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

-version 1.1.1.1.2.1, 2011/11/18 17:23:59
+version 1.1.1.1.2.6, 2011/11/23 00:56:46
  Line 1
  #include "global.h"
+ #include "rtlm.h"
+ sl_config cfg;
  int
  main(int argc, char **argv)
  {
-        mqtt_msg_t *m;
+        sqlite3 *acc = NULL, *pub = NULL;
-        int i;
-        m = mqtt_msgAlloc(14);
+        if (LoadConfig("/etc/mqtt.conf", &cfg)) {
-        printf("connect=%d/%d\n", m->msg_len, mqtt_msgCONNECT(m));
+                printf("Error:: Load config #%d - %s\n", cfg_GetErrno(), cfg_GetError());
-        for (i = 0; i < m->msg_len; i++)
+                return 1;
-                printf("%d\n", ((u_char*) m->msg_base)[i]);
+        }
-        mqtt_msgFree(&m, 42);
+        if (!mqttLoadRTLM(&cfg, 0)) {
+                printf("Error:: Can't load RTL module\n");
+                return 2;
+        }
+        acc = mqttOpenDB(&cfg, 0);
+        if (!acc)
+                goto end;
+        pub = mqttOpenDB(&cfg, 1);
+        if (!pub)
+                goto end;
+        printf("success!\n");
+end:
+        mqttCloseDB(pub);
+        mqttCloseDB(acc);
+        mqttUnloadRTLM(0);
+        UnloadConfig(&cfg);
          return 0;
  }