(cherry picked from commit b3c8329cfbfa19613dfbadaea7f220443dbb7f55)
... | ... |
@@ -298,7 +298,10 @@ int _nats_pub_worker_proc( |
298 | 298 |
!= NATS_OK) { |
299 | 299 |
LM_ERR("could not connect to nats servers [%s]\n", |
300 | 300 |
natsStatus_GetText(s)); |
301 |
+ } else { |
|
302 |
+ connectedCB(worker->nc->conn, NULL); |
|
301 | 303 |
} |
304 |
+ |
|
302 | 305 |
s = natsOptions_SetEventLoop(worker->nc->opts, (void *)worker->uvLoop, |
303 | 306 |
natsLibuv_Attach, natsLibuv_Read, natsLibuv_Write, |
304 | 307 |
natsLibuv_Detach); |