diff --git a/spring-amqp-parent/pom.xml b/spring-amqp-parent/pom.xml
index e544d053..1f0ba8a9 100644
--- a/spring-amqp-parent/pom.xml
+++ b/spring-amqp-parent/pom.xml
@@ -20,7 +20,7 @@
 		<org.mockito.version>1.8.4</org.mockito.version>
 		<org.codehaus.jackson.version>1.4.3</org.codehaus.jackson.version>
 		<org.erlang.otp.version>1.5.3</org.erlang.otp.version>
-		<com.rabbitmq.version>2.5.0</com.rabbitmq.version>
+		<com.rabbitmq.version>2.7.1</com.rabbitmq.version>
 		<org.springframework.version>3.0.5.RELEASE</org.springframework.version>
 	</properties>
 	<licenses>
diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/support/DefaultMessagePropertiesConverter.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/support/DefaultMessagePropertiesConverter.java
index 4cbc1e82..61a93796 100644
--- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/support/DefaultMessagePropertiesConverter.java
+++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/support/DefaultMessagePropertiesConverter.java
@@ -29,7 +29,7 @@ import org.springframework.util.CollectionUtils;
 
 import com.rabbitmq.client.AMQP.BasicProperties;
 import com.rabbitmq.client.Envelope;
-import com.rabbitmq.client.impl.LongString;
+import com.rabbitmq.client.LongString;
 
 /**
  * Default implementation of the {@link MessagePropertiesConverter} strategy.
diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/MulticastMain.java b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/MulticastMain.java
index fbc8c06b..40e37863 100644
--- a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/MulticastMain.java
+++ b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/MulticastMain.java
@@ -136,7 +136,7 @@ public class MulticastMain {
 				channel.exchangeDeclare(exchangeName, exchangeType);
 				final Producer p = new Producer(channel, exchangeName, id, flags, producerTxSize,
 						1000L * samplingInterval, rateLimit, minMsgSize, timeLimit, messageCount);
-				channel.setReturnListener(p);
+				channel.addReturnListener(p);
 				Thread t = new Thread(p);
 				producerThreads[i] = t;
 				t.start();