qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From raj...@apache.org
Subject svn commit: r992064 - /qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java
Date Thu, 02 Sep 2010 19:13:04 GMT
Author: rajith
Date: Thu Sep  2 19:13:04 2010
New Revision: 992064

URL: http://svn.apache.org/viewvc?rev=992064&view=rev
Log:
QPID-2845
Modified the existing test cases to use the correct format when specifying x-declare arguments.

Modified:
    qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java

Modified: qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java?rev=992064&r1=992063&r2=992064&view=diff
==============================================================================
--- qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java
(original)
+++ qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java
Thu Sep  2 19:13:04 2010
@@ -203,8 +203,10 @@ public class AddressBasedDestinationTest
                                  "x-declare: " +
                                  "{" + 
                                      "auto-delete: true," +
-                                     "'qpid.max_size': 1000," +
-                                     "'qpid.max_count': 100" +
+                                     "arguments: {" +  
+                                        "'qpid.max_size': 1000," +
+                                        "'qpid.max_count': 100" +
+                                     "}" + 
                                   "}, " +   
                                   "x-bindings: [{exchange : 'amq.direct', key : test}, "
+ 
                                                "{exchange : 'amq.fanout'}," +
@@ -260,8 +262,10 @@ public class AddressBasedDestinationTest
                              "{ " + 
                                  "type:direct, " + 
                                  "auto-delete: true, " +
-                                 "'qpid.msg_sequence': 1, " +
-                                 "'qpid.ive': 1" + 
+                                 "arguments: {" +  
+                                   "'qpid.msg_sequence': 1, " +
+                                   "'qpid.ive': 1" +
+                                 "}" +
                              "}" +
                         "}" +
                       "}";
@@ -293,7 +297,7 @@ public class AddressBasedDestinationTest
                                "x-declare: " + 
                                "{ " + 
                                      "auto-delete: true," +
-                                     "'qpid.max_count': 100" +
+                                     "arguments: {'qpid.max_count': 100}" +
                                "}, " +
                                "x-bindings: [{exchange : 'amq.direct', key : test}, " +
                                             "{exchange : 'amq.topic', key : 'a.#'}," + 
@@ -391,7 +395,7 @@ public class AddressBasedDestinationTest
     {
         Hashtable<String,String> map = new Hashtable<String,String>();      
 
         map.put("destination.myQueue1", "ADDR:my-queue/hello; {create: always, node: " +

-                "{x-declare: {auto-delete: true,'qpid.max_size': 1000}}}");
+                "{x-declare: {auto-delete: true, arguments : {'qpid.max_size': 1000}}}}");
         
         map.put("destination.myQueue2", "ADDR:my-queue2; { create: receiver }");
 
@@ -469,7 +473,7 @@ public class AddressBasedDestinationTest
         String addr = "ADDR:amq.direct/x512; {create: receiver, " +
                       "link : {name : 'MY.RESP.QUEUE', " + 
                       "x-declare : { auto-delete: true, exclusive: true, " +
-                                   "'qpid.max_size': 1000, 'qpid.policy_type': ring } } }";
+                                   "arguments : {'qpid.max_size': 1000, 'qpid.policy_type':
ring }} } }";
         
         Destination replyTo = new AMQAnyDestination(addr);
         Destination dest =new AMQAnyDestination("ADDR:amq.direct/Hello");
@@ -527,7 +531,7 @@ public class AddressBasedDestinationTest
         String addr = "ADDR:amq.direct/x512; {create: receiver, " +
         "link : {name : 'MY.RESP.QUEUE', " + 
         "x-declare : { auto-delete: true, exclusive: true, " +
-                     "'qpid.max_size': 1000, 'qpid.policy_type': ring } } }";
+                     "arguments : {'qpid.max_size': 1000, 'qpid.policy_type': ring} } } }";
         queue = ssn.createQueue(addr);
         
         prod = ssn.createProducer(queue); 
@@ -574,8 +578,10 @@ public class AddressBasedDestinationTest
                "{ " + 
                    "type:direct, " + 
                    "auto-delete: true, " +
-                   "'qpid.msg_sequence': 1, " +
-                   "'qpid.ive': 1" + 
+                   "arguments: {" +  
+                       "'qpid.msg_sequence': 1, " +
+                       "'qpid.ive': 1" + 
+                   "}" +
                "}" +
           "}, " +
           "link: {name : my-topic, " +
@@ -649,7 +655,7 @@ public class AddressBasedDestinationTest
         
         String addr = "ADDR:my-ring-queue; {create: always, mode: browse, " +
             "node: {x-bindings: [{exchange : 'amq.direct', key : test}], " +
-                   "x-declare:{'qpid.policy_type':ring, 'qpid.max_count':2}}}";
+                   "x-declare:{arguments : {'qpid.policy_type':ring, 'qpid.max_count':2}}}}";
         
         Destination dest = ssn.createQueue(addr);
         MessageConsumer browseCons = ssn.createConsumer(dest);



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message