From e040cf02b413ccd3cc5dfddd78178c6454ac32e9 Mon Sep 17 00:00:00 2001
From: Gary Russell <grussell@pivotal.io>
Date: Tue, 23 Jan 2018 13:14:01 -0500
Subject: [PATCH] Pollable Consumer : Start Source if Lifecycle

When binding a `MessageSource`, start it if it implements `Lifecycle`.

Resolves #1189
---
 .../cloud/stream/binder/AbstractMessageChannelBinder.java      | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java
index c0c839728..a9cb100b2 100644
--- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java
+++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java
@@ -317,6 +317,9 @@ public abstract class AbstractMessageChannelBinder<C extends ConsumerProperties,
 					getPolledConsumerRecoveryCallback(resources.getErrorInfrastructure(), properties));
 		}
 		postProcessPollableSource(bindingTarget);
+		if (resources.getSource() instanceof Lifecycle) {
+				((Lifecycle) resources.getSource()).start();
+		}
 		return new DefaultBinding<PollableSource<MessageHandler>>(name, group, inboundBindTarget,
 				resources.getSource() instanceof Lifecycle ? (Lifecycle) resources.getSource() : null) {