Add an internal subscribe call to MemQ consumer's assign()#38