--- mqtt/src/dl.c 2012/01/27 15:05:38 1.2 +++ mqtt/src/dl.c 2012/02/01 15:04:24 1.2.2.1 @@ -91,11 +91,15 @@ mqttLoadRTLM(sl_config *cfg, int modtype) call.InitSessPUB = dlsym(rtlm, "mqtt_rtlm_init_session"); call.FiniSessPUB = dlsym(rtlm, "mqtt_rtlm_fini_session"); call.ChkSessPUB = dlsym(rtlm, "mqtt_rtlm_chk_session"); - call.WritePUB = dlsym(rtlm, "mqtt_rtlm_write_topic"); - call.ReadPUB = dlsym(rtlm, "mqtt_rtlm_read_topic"); - call.DeletePUB = dlsym(rtlm, "mqtt_rtlm_delete_topic"); + call.WritePUB_topic = dlsym(rtlm, "mqtt_rtlm_write_topic"); + call.ReadPUB_topic = dlsym(rtlm, "mqtt_rtlm_read_topic"); + call.DeletePUB_topic = dlsym(rtlm, "mqtt_rtlm_delete_topic"); + call.WritePUB_subscribe = dlsym(rtlm, "mqtt_rtlm_write_subscribe"); + call.ReadPUB_subscribe = dlsym(rtlm, "mqtt_rtlm_read_subscribe"); + call.DeletePUB_subscribe = dlsym(rtlm, "mqtt_rtlm_delete_subscribe"); if (!call.InitSessPUB || !call.FiniSessPUB || !call.ChkSessPUB || - !call.WritePUB || !call.ReadPUB || !call.DeletePUB) { + !call.WritePUB_topic || !call.ReadPUB_topic || + !call.DeletePUB_topic) { mqttLog("Error:: incorrect module ...\n"); dlclose(rtlm); return NULL;