Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AMQP-195 Update AMQP Client to 2.7.1

Browse Source 
LongString moved from client.impl to client

Channel.setReturnListener changed to Channel.addReturnListener
This commit is contained in:
Gary Russell
2012-01-09 13:42:20 -05:00
committed by Oleg Zhurakousky
parent 39637aef4b
commit fb2cf5fb5d
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-amqp-parent/pom.xml
View File

@@ -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>

2
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/support/DefaultMessagePropertiesConverter.java
View File

@@ -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.

2
spring-rabbit/src/test/java/org/springframework/amqp/rabbit/MulticastMain.java
View File

@@ -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();