score:0

Check out org.apache.spark.streaming.rabbitmq.ConfigParameters for available map key names.

val receiverStream = RabbitMQUtils.createStream(ssc, Map(
                        "hosts" -> (host + ":" + port),
                        "queueName" -> queueName,
                        "vHost" -> vHost,
                        "userName" -> userName,
                        "password" -> password
                ))

Related Query

More Query from same tag