Open steelxiang opened 5 years ago
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
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