@Override
		/** Called when a receiver has reported an error */
		public void onReceiverError(StreamingListenerReceiverError receiverError) {
			logger.info("Error starting spark streaming receiver " + receiverError.receiverInfo());
			receiverStartSuccess.set(false);
			receiverStartLatch.countDown();
		}
Called when a receiver has been started
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/plugins/spark/streaming/SparkStreamingPlugin.java