From 88434745d4fb3f4272985b906c3c27f5ec9b62e1 Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@pivotal.io>
Date: Tue, 28 Nov 2017 21:14:16 -0500
Subject: [PATCH] Removed warnings

---
 spring-cloud-stream-binder-rabbit-core/pom.xml               | 5 +++++
 .../stream/binder/rabbit/admin/RabbitBindingCleaner.java     | 2 --
 .../stream/binder/rabbit/RabbitMessageChannelBinder.java     | 2 +-
 .../cloud/stream/binder/rabbit/RabbitBinderCleanerTests.java | 1 -
 .../binder/rabbit/integration/RabbitBinderModuleTests.java   | 1 -
 5 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/spring-cloud-stream-binder-rabbit-core/pom.xml b/spring-cloud-stream-binder-rabbit-core/pom.xml
index 5d548ce2f..df8771bfe 100644
--- a/spring-cloud-stream-binder-rabbit-core/pom.xml
+++ b/spring-cloud-stream-binder-rabbit-core/pom.xml
@@ -26,5 +26,10 @@
 			<groupId>org.springframework.integration</groupId>
 			<artifactId>spring-integration-amqp</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-configuration-processor</artifactId>
+			<optional>true</optional>
+		</dependency>
 	</dependencies>
 </project>
diff --git a/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/admin/RabbitBindingCleaner.java b/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/admin/RabbitBindingCleaner.java
index 1a0b493cf..6f56b3490 100644
--- a/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/admin/RabbitBindingCleaner.java
+++ b/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/admin/RabbitBindingCleaner.java
@@ -119,7 +119,6 @@ public class RabbitBindingCleaner implements BindingCleaner {
 		URI uri = UriComponentsBuilder.fromUriString(adminUri + "/api")
 				.pathSegment("queues", "{vhost}")
 				.buildAndExpand(vhost).encode().toUri();
-		@SuppressWarnings("unchecked")
 		List<Map<String, Object>> queues = restTemplate.getForObject(uri, List.class);
 		return queues;
 	}
@@ -139,7 +138,6 @@ public class RabbitBindingCleaner implements BindingCleaner {
 		}
 	}
 
-	@SuppressWarnings("unchecked")
 	private List<String> findExchanges(String adminUri, String vhost, String binderPrefix, String entity,
 			RestTemplate restTemplate) {
 		List<String> removedExchanges = new ArrayList<>();
diff --git a/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java b/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java
index fe1e15371..d535fb105 100644
--- a/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java
+++ b/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java
@@ -139,7 +139,7 @@ public class RabbitMessageChannelBinder
 
 	public RabbitMessageChannelBinder(ConnectionFactory connectionFactory, RabbitProperties rabbitProperties,
 			RabbitExchangeQueueProvisioner provisioningProvider) {
-		super(true, new String[0], provisioningProvider);
+		super(new String[0], provisioningProvider);
 		Assert.notNull(connectionFactory, "connectionFactory must not be null");
 		Assert.notNull(rabbitProperties, "rabbitProperties must not be null");
 		this.connectionFactory = connectionFactory;
diff --git a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderCleanerTests.java b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderCleanerTests.java
index dd4f67401..1100d314f 100644
--- a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderCleanerTests.java
+++ b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderCleanerTests.java
@@ -139,7 +139,6 @@ public class RabbitBinderCleanerTests {
 
 				Object consumers = null;
 				while (n++ < 100 && (consumers == null || consumers.equals(Integer.valueOf(state)))) {
-					@SuppressWarnings("unchecked")
 					Map<String, Object> queueInfo = template.getForObject(uri, Map.class);
 					consumers = queueInfo.get("consumers");
 					if (consumers == null || consumers.equals(Integer.valueOf(state))) {
diff --git a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java
index 84164cda4..3cc571026 100644
--- a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java
+++ b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java
@@ -145,7 +145,6 @@ public class RabbitBinderModuleTests {
 				CompositeHealthIndicator.class);
 		DirectFieldAccessor directFieldAccessor = new DirectFieldAccessor(bindersHealthIndicator);
 		assertThat(bindersHealthIndicator).isNotNull();
-		@SuppressWarnings("unchecked")
 		Map<String, HealthIndicator> healthIndicators = (Map<String, HealthIndicator>) directFieldAccessor
 				.getPropertyValue("indicators");
 		assertThat(healthIndicators).containsKey("rabbit");