private Properties getMessageBusProperties(Module module) {
		ConfigurableEnvironment env = module.getApplicationContext().getEnvironment();
		Properties busProperties = new Properties();
		busProperties.put("XD_TRANSPORT", env.getProperty("XD_TRANSPORT"));
		Iterator<PropertySource<?>> i = env.getPropertySources().iterator();
		while (i.hasNext()) {
			PropertySource<?> p = i.next();
			if (p instanceof EnumerablePropertySource) {
				for (String name : ((EnumerablePropertySource) p).getPropertyNames()) {
					if ((name.startsWith(REDIS_CONNECTION_PROPERTY_PREFIX)) ||
							name.startsWith(RABBIT_CONNECTION_PROPERTY_PREFIX) ||
							name.startsWith(MESSAGE_BUS_PROPERTY_PREFIX)) {
						busProperties.put(name, env.getProperty(name));
					}
				}
			}
		}
		return busProperties;
	}
Get the configured message bus properties for the given transport.
@param module
@return the message bus properties for the spark streaming module.
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/plugins/spark/streaming/SparkStreamingPlugin.java