diff --git a/asyncqueue.c b/asyncqueue.c
index f34c47eb..1d3d7124 100644
--- a/asyncqueue.c
+++ b/asyncqueue.c
@@ -231,6 +231,7 @@ static int AQ_Reconnect(pAsyncQueue self)
     }
     return iRet;
   }
+  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;