Support for creating an observable from SQS queue.