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

INT-3409 Update to Spring AMQP 1.3.3

Browse Source 
JIRA: https://jira.spring.io/browse/INT-3409

Stub connection factory API changes.
This commit is contained in:
Gary Russell
2014-05-16 11:08:11 -04:00
parent 157fc2a084
commit 7ec1b3cc4c
2 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
build.gradle
View File

@@ -107,7 +107,7 @@ subprojects { subproject ->
servletApiVersion = '3.1.0'
slf4jVersion = "1.7.6"
smackVersion = '3.2.1'
springAmqpVersion = project.hasProperty('springAmqpVersion') ? project.springAmqpVersion : '1.3.2.RELEASE'
springAmqpVersion = project.hasProperty('springAmqpVersion') ? project.springAmqpVersion : '1.3.3.RELEASE'
springDataMongoVersion = '1.5.0.BUILD-SNAPSHOT'
springDataRedisVersion = '1.3.0.BUILD-SNAPSHOT'
springGemfireVersion = '1.4.0.BUILD-SNAPSHOT'

20
spring-integration-amqp/src/test/java/org/springframework/integration/amqp/StubRabbitConnectionFactory.java
View File

@@ -27,7 +27,6 @@ import org.springframework.amqp.rabbit.connection.ConnectionListener;
import com.rabbitmq.client.AMQP.Basic.RecoverOk;
import com.rabbitmq.client.AMQP.BasicProperties;
import com.rabbitmq.client.AMQP.Channel.FlowOk;
import com.rabbitmq.client.AMQP.Confirm.SelectOk;
import com.rabbitmq.client.AMQP.Exchange.BindOk;
import com.rabbitmq.client.AMQP.Exchange.DeclareOk;
@@ -148,13 +147,8 @@ public class StubRabbitConnectionFactory implements ConnectionFactory {
}
@Override
public FlowOk flow(boolean active) throws IOException {
return null;
}
@Override
public FlowOk getFlow() {
return null;
public boolean flowBlocked() {
return false;
}
@Override
@@ -205,6 +199,10 @@ public class StubRabbitConnectionFactory implements ConnectionFactory {
public void basicQos(int prefetchSize, int prefetchCount, boolean global) throws IOException {
}
@Override
public void basicQos(int prefetchCount, boolean global) throws IOException {
}
@Override
public void basicQos(int prefetchCount) throws IOException {
}
@@ -412,6 +410,12 @@ public class StubRabbitConnectionFactory implements ConnectionFactory {
return null;
}
@Override
public String basicConsume(String queue, boolean autoAck, Map<String, Object> arguments, Consumer callback)
throws IOException {
return null;
}
@Override
public String basicConsume(String queue, boolean autoAck,
String consumerTag, boolean noLocal, boolean exclusive,