public void postProcessAfterResolution()

in initializr-service/src/main/java/io/spring/initializr/service/extension/SpringCloudStreamRequestPostProcessor.java [54:78]


	public void postProcessAfterResolution(ProjectRequest request,
			InitializrMetadata metadata) {
		boolean hasSpringCloudStream = hasDependency(request, "cloud-stream");
		boolean hasReactiveSpringCloudStream = hasDependency(request,
				"reactive-cloud-stream");
		boolean hasSpringCloudBus = hasDependency(request, "cloud-bus");
		boolean hasSpringCloudTurbineStream = hasDependency(request,
				"cloud-turbine-stream");
		if (hasSpringCloudStream || hasReactiveSpringCloudStream || hasSpringCloudBus
				|| hasSpringCloudTurbineStream) {
			if (hasDependencies(request, "amqp")) {
				request.getResolvedDependencies().add(RABBIT_BINDER);
			}
			if (hasDependencies(request, "kafka")) {
				request.getResolvedDependencies().add(KAFKA_BINDER);
			}
		}
		// Spring Cloud Stream specific
		if (hasSpringCloudStream || hasReactiveSpringCloudStream) {
			if (hasDependencies(request, "kafka-streams")) {
				request.getResolvedDependencies().add(KAFKA_STREAMS_BINDER);
			}
			request.getResolvedDependencies().add(SCS_TEST);
		}
	}