diff --git a/asyncqueue.c b/asyncqueue.c index e258feb2..fedc9c84 100644 --- a/asyncqueue.c +++ b/asyncqueue.c @@ -178,13 +178,13 @@ static int TimedReconnect(void *cntx, int mode) self->queue_name, __func__, state_name(self->state)); self->state = eAsyncConnecting; } else { - snprintf(line, 132, "Reconnect on AsyncQueue '%s'", self->queue_name); - SICSLogWrite(line, eStatus); - AQ_Notify(self, AQU_RECONNECT); NetWatchSetMode(self->nw_ctx, nwatch_read); SICSLogPrintf(eStatus, "In %s:%s: state %s => eAsyncConnected\n", self->queue_name, __func__, state_name(self->state)); self->state = eAsyncConnected; + snprintf(line, 132, "Reconnect on AsyncQueue '%s'", self->queue_name); + SICSLogWrite(line, eStatus); + AQ_Notify(self, AQU_RECONNECT); } return 1; }