New Dstream to read sqs messages from AWS via spark job