Move support for queued emits and persistent emits to the generic socket service implementation