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

AMQP-178: make named queue durable by default

Browse Source
This commit is contained in:
Dave Syer
2011-07-12 10:40:40 +01:00
parent c39cea66ab
commit f1f7beba9c
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-amqp-core/src/main/java/org/springframework/amqp/core/Queue.java
View File

@@ -34,12 +34,12 @@ public class Queue {
private final java.util.Map<java.lang.String, java.lang.Object> 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);
}
/**

4
spring-rabbit/src/main/resources/org/springframework/amqp/rabbit/config/spring-rabbit-1.0.xsd
View File

@@ -49,10 +49,10 @@
]]></xsd:documentation>
</xsd:annotation>
</xsd:attribute>
<xsd:attribute name="durable" use="optional" type="xsd:boolean" default="false">
<xsd:attribute name="durable" use="optional" type="xsd:boolean" default="true">
<xsd:annotation>
<xsd:documentation><![CDATA[
Flag indicating that the queue is durable, meaning that it will survive broker restarts (not that the messages in it will, although they might if they are persistent). Default is false.
Flag indicating that the queue is durable, meaning that it will survive broker restarts (not that the messages in it will, although they might if they are persistent). Default is true.
]]></xsd:documentation>
</xsd:annotation>
</xsd:attribute>

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

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