Cleaning up QueueConnector implementation.