From 33ceb3616bc0d2a5ba7156e136f786071dbb36e3 Mon Sep 17 00:00:00 2001
From: Dave Syer <dsyer@vmware.com>
Date: Mon, 27 Jun 2011 12:51:48 +0100
Subject: [PATCH] AMQP-175: Upgrade to rabbit 2.5.0

---
 spring-amqp-parent/pom.xml                    |  2 +-
 .../DefaultMessagePropertiesConverter.java    | 32 +++++++++----------
 .../amqp/rabbit/MulticastMain.java            |  2 +-
 3 files changed, 18 insertions(+), 18 deletions(-)

diff --git a/spring-amqp-parent/pom.xml b/spring-amqp-parent/pom.xml
index 9e475afb..6cb950ed 100644
--- a/spring-amqp-parent/pom.xml
+++ b/spring-amqp-parent/pom.xml
@@ -17,7 +17,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.3.1</com.rabbitmq.version>
+		<com.rabbitmq.version>2.5.0</com.rabbitmq.version>
 		<org.springframework.version>3.0.5.RELEASE</org.springframework.version>
 	</properties>
 	<profiles>
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 58099231..3c4b46bd 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
@@ -92,26 +92,26 @@ public class DefaultMessagePropertiesConverter implements MessagePropertiesConve
 	}
 
 	public BasicProperties fromMessageProperties(final MessageProperties source, final String charset) {
-		BasicProperties target = new BasicProperties();
-		target.setHeaders(this.convertHeadersIfNecessary(source.getHeaders()));
-		target.setTimestamp(source.getTimestamp());
-		target.setMessageId(source.getMessageId());
-		target.setUserId(source.getUserId());
-		target.setAppId(source.getAppId());
-		target.setClusterId(source.getClusterId());
-		target.setType(source.getType());
+		BasicProperties.Builder target = new BasicProperties.Builder();
+		target.headers(this.convertHeadersIfNecessary(source.getHeaders()));
+		target.timestamp(source.getTimestamp());
+		target.messageId(source.getMessageId());
+		target.userId(source.getUserId());
+		target.appId(source.getAppId());
+		target.clusterId(source.getClusterId());
+		target.type(source.getType());
 		MessageDeliveryMode deliveryMode = source.getDeliveryMode();
 		if (deliveryMode != null) {
-			target.setDeliveryMode(MessageDeliveryMode.toInt(deliveryMode));
+			target.deliveryMode(MessageDeliveryMode.toInt(deliveryMode));
 		}
-		target.setExpiration(source.getExpiration());
-		target.setPriority(source.getPriority());
-		target.setContentType(source.getContentType());
-		target.setContentEncoding(source.getContentEncoding());
+		target.expiration(source.getExpiration());
+		target.priority(source.getPriority());
+		target.contentType(source.getContentType());
+		target.contentEncoding(source.getContentEncoding());
 		byte[] correlationId = source.getCorrelationId();
 		if (correlationId != null && correlationId.length > 0) {
 			try {
-				target.setCorrelationId(new String(correlationId, charset));
+				target.correlationId(new String(correlationId, charset));
 			}
 			catch (UnsupportedEncodingException ex) {
 				throw new AmqpUnsupportedEncodingException(ex);
@@ -119,9 +119,9 @@ public class DefaultMessagePropertiesConverter implements MessagePropertiesConve
 		}
 		Address replyTo = source.getReplyTo();
 		if (replyTo != null) {
-			target.setReplyTo(replyTo.toString());
+			target.replyTo(replyTo.toString());
 		}
-		return target;
+		return target.build();
 	}
 
 	private Map<String, Object> convertHeadersIfNecessary(Map<String, Object> headers) {
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 a201119c..fbc8c06b 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
@@ -250,7 +250,7 @@ public class MulticastMain {
 			this.message = new byte[minMsgSize];
 		}
 
-		public void handleBasicReturn(int replyCode, String replyText, String exchange, String routingKey,
+		public void handleReturn(int replyCode, String replyText, String exchange, String routingKey,
 				AMQP.BasicProperties properties, byte[] body) throws IOException {
 			logBasicReturn();
 		}