[BAHIR-233] Add SNS message support for SQS streaming source (#97)
[bahir.git] / sql-streaming-sqs / src / test / scala / org / apache / spark / sql / streaming / sqs / SqsSourceOptionsSuite.scala
index 6382fb1f87e96875f3845dd7661e8e1e81db94c4..e43bae32aea9ce539bd2cc275690d1b2f498d102 100644 (file)
@@ -74,6 +74,8 @@ class SqsSourceOptionsSuite extends StreamTest {
       "for option 'shouldSortFiles', must be true or false")
     testBadOptions("useInstanceProfileCredentials" -> "x")("Invalid value 'x' " +
       "for option 'useInstanceProfileCredentials', must be true or false")
+    testBadOptions("messageWrapper" -> "x")("Invalid value 'x' " +
+      "for option 'messageWrapper', must be one of [none, sns]")
 
   }