diff --git a/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/StubRabbitConnectionFactory.java b/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/StubRabbitConnectionFactory.java index 4cec31e540..9d712daa09 100644 --- a/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/StubRabbitConnectionFactory.java +++ b/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/StubRabbitConnectionFactory.java @@ -35,6 +35,7 @@ import com.rabbitmq.client.AMQP.Exchange.UnbindOk; import com.rabbitmq.client.AMQP.Queue.PurgeOk; import com.rabbitmq.client.AMQP.Tx.CommitOk; import com.rabbitmq.client.AMQP.Tx.RollbackOk; +import com.rabbitmq.client.BuiltinExchangeType; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Command; import com.rabbitmq.client.ConfirmListener; @@ -592,6 +593,34 @@ public class StubRabbitConnectionFactory implements ConnectionFactory { return 0; } + @Override + public DeclareOk exchangeDeclare(String exchange, BuiltinExchangeType type) throws IOException { + return null; + } + + @Override + public DeclareOk exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable) + throws IOException { + return null; + } + + @Override + public DeclareOk exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, + Map arguments) throws IOException { + return null; + } + + @Override + public DeclareOk exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, + boolean internal, Map arguments) throws IOException { + return null; + } + + @Override + public void exchangeDeclareNoWait(String exchange, BuiltinExchangeType type, boolean durable, + boolean autoDelete, boolean internal, Map arguments) throws IOException { + } + } }