svn commit: r1510068 - in /synapse/trunk/java/modules/core/src: main/java/org/apache/synapse/config/xml/ main/java/org/apache/synapse/mediators/builtin/ test/java/org/apache/synapse/config/xml/

[hiranya]

Author: hiranya
Date: Sat Aug  3 21:03:25 2013
New Revision: 1510068

URL: http://svn.apache.org/r1510068
Log:
Adding enqueue mediator serializer test

Added:
    
synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/EnqueueMediatorSerializationTest.java
Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/EnqueueMediatorSerializer.java
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/EnqueueMediator.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/EnqueueMediatorSerializer.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/EnqueueMediatorSerializer.java?rev=1510068&r1=1510067&r2=1510068&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/EnqueueMediatorSerializer.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/EnqueueMediatorSerializer.java
 Sat Aug  3 21:03:25 2013
@@ -23,7 +23,6 @@ import org.apache.axiom.om.OMElement;
 import org.apache.synapse.Mediator;
 import org.apache.synapse.mediators.builtin.EnqueueMediator;
 
-
 public class EnqueueMediatorSerializer extends AbstractMediatorSerializer{
 
     public OMElement serializeSpecificMediator(Mediator m) {
@@ -48,8 +47,10 @@ public class EnqueueMediatorSerializer e
             handleException("Invalid enqueue mediator. sequence is required");
         }
 
-        enqueue.addAttribute(fac.createOMAttribute(
-                "priority", nullNS, mediator.getPriority() + ""));
+        if (mediator.getPriority() != 0) {
+            enqueue.addAttribute(fac.createOMAttribute(
+                    "priority", nullNS, mediator.getPriority() + ""));
+        }
 
         return enqueue;
     }

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/EnqueueMediator.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/EnqueueMediator.java?rev=1510068&r1=1510067&r2=1510068&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/EnqueueMediator.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/EnqueueMediator.java
 Sat Aug  3 21:03:25 2013
@@ -38,6 +38,7 @@ import java.util.concurrent.RejectedExec
  * executor can throw exceptions.
  */
 public class EnqueueMediator extends AbstractMediator {
+
     private String executorName = null;
 
     private int priority = 0;

Added: 
synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/EnqueueMediatorSerializationTest.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/EnqueueMediatorSerializationTest.java?rev=1510068&view=auto
==============================================================================
--- 
synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/EnqueueMediatorSerializationTest.java
 (added)
+++ 
synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/EnqueueMediatorSerializationTest.java
 Sat Aug  3 21:03:25 2013
@@ -0,0 +1,46 @@
+/*
+ *  Licensed to the Apache Software Foundation (ASF) under one
+ *  or more contributor license agreements.  See the NOTICE file
+ *  distributed with this work for additional information
+ *  regarding copyright ownership.  The ASF licenses this file
+ *  to you under the Apache License, Version 2.0 (the
+ *  "License"); you may not use this file except in compliance
+ *  with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing,
+ *  software distributed under the License is distributed on an
+ *   * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ *  KIND, either express or implied.  See the License for the
+ *  specific language governing permissions and limitations
+ *  under the License.
+ */
+
+package org.apache.synapse.config.xml;
+
+public class EnqueueMediatorSerializationTest extends AbstractTestCase {
+
+    private EnqueueMediatorFactory factory;
+    private EnqueueMediatorSerializer serializer;
+
+    public EnqueueMediatorSerializationTest() {
+        super(EnqueueMediatorSerializationTest.class.getName());
+        factory = new EnqueueMediatorFactory();
+        serializer = new EnqueueMediatorSerializer();
+    }
+
+    public void testEnqueueMediatorSerializationScenarioOne() throws Exception 
{
+        String inputXml = "<enqueue xmlns=\"http://ws.apache.org/ns/synapse\"; 
" +
+                "executor=\"bar\" sequence=\"foo\"/>";
+        assertTrue(serialization(inputXml, factory, serializer));
+        assertTrue(serialization(inputXml, serializer));
+    }
+
+    public void testEnqueueMediatorSerializationScenarioTwo() throws Exception 
{
+        String inputXml = "<enqueue xmlns=\"http://ws.apache.org/ns/synapse\"; 
" +
+                "executor=\"bar\" sequence=\"foo\" priority=\"5\"/>";
+        assertTrue(serialization(inputXml, factory, serializer));
+        assertTrue(serialization(inputXml, serializer));
+    }
+}