spark-rabbitmq
spark-rabbitmq copied to clipboard
Wrong variable name in test demo
val receiverStream = RabbitMQUtils.createStream(ssc, Map( "hosts" -> hosts, "queueName" -> queueName, "exchangeName" -> exchangeName, "exchangeType" -> exchangeType, "vHost" -> vHost, "userName" -> userName, "password" -> password ))
vhost is wrong The correct variable name is virtualHost