diff --git a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AsyncAmqpOutboundGateway.java b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AsyncAmqpOutboundGateway.java
index 78f03c9e4a..7b54531a91 100644
--- a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AsyncAmqpOutboundGateway.java
+++ b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AsyncAmqpOutboundGateway.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2016 the original author or authors.
+ * Copyright 2016-2017 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -58,6 +58,18 @@ public class AsyncAmqpOutboundGateway extends AbstractAmqpOutboundEndpoint {
 		return "amqp:outbound-async-gateway";
 	}
 
+	@Override
+	protected void doStart() {
+		super.doStart();
+		this.template.start();
+	}
+
+	@Override
+	protected void doStop() {
+		this.template.stop();
+		super.doStop();
+	}
+
 	@Override
 	protected Object handleRequestMessage(Message<?> requestMessage) {
 		org.springframework.amqp.core.Message amqpMessage = MappingUtils.mapMessage(requestMessage,
diff --git a/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/outbound/OutboundEndpointTests.java b/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/outbound/OutboundEndpointTests.java
index c441c46ac8..b81d555944 100644
--- a/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/outbound/OutboundEndpointTests.java
+++ b/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/outbound/OutboundEndpointTests.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2016 the original author or authors.
+ * Copyright 2002-2017 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -106,6 +106,7 @@ public class OutboundEndpointTests {
 		gateway.setBeanFactory(mock(BeanFactory.class));
 		gateway.setOutputChannel(new NullChannel());
 		gateway.afterPropertiesSet();
+		gateway.start();
 		ArgumentCaptor<Message> captor = ArgumentCaptor.forClass(Message.class);
 		gateway.handleMessage(new GenericMessage<>("foo"));
 		verify(amqpTemplate).sendAndReceive(eq("foo"), eq("bar"), captor.capture());