diff --git a/spring-amqp-core/src/main/java/org/springframework/amqp/core/Queue.java b/spring-amqp-core/src/main/java/org/springframework/amqp/core/Queue.java index 10bdd1f5..d0330a60 100644 --- a/spring-amqp-core/src/main/java/org/springframework/amqp/core/Queue.java +++ b/spring-amqp-core/src/main/java/org/springframework/amqp/core/Queue.java @@ -34,12 +34,12 @@ public class Queue { private final java.util.Map arguments; /** - * The queue is non-durable, non-exclusive and non auto-delete. + * The queue is durable, non-exclusive and non auto-delete. * * @param name the name of the queue. */ public Queue(String name) { - this(name, false, false, false); + this(name, true, false, false); } /** diff --git a/spring-rabbit/src/main/resources/org/springframework/amqp/rabbit/config/spring-rabbit-1.0.xsd b/spring-rabbit/src/main/resources/org/springframework/amqp/rabbit/config/spring-rabbit-1.0.xsd index 6987b148..5b7b98ad 100644 --- a/spring-rabbit/src/main/resources/org/springframework/amqp/rabbit/config/spring-rabbit-1.0.xsd +++ b/spring-rabbit/src/main/resources/org/springframework/amqp/rabbit/config/spring-rabbit-1.0.xsd @@ -49,10 +49,10 @@ ]]> - + diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/config/QueueParserTests.java b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/config/QueueParserTests.java index 05b88bb5..449103fe 100644 --- a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/config/QueueParserTests.java +++ b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/config/QueueParserTests.java @@ -41,7 +41,7 @@ public final class QueueParserTests { Queue queue = beanFactory.getBean("foo", Queue.class); assertNotNull(queue); assertEquals("foo", queue.getName()); - assertFalse(queue.isDurable()); + assertTrue(queue.isDurable()); assertFalse(queue.isAutoDelete()); assertFalse(queue.isExclusive()); }