svn commit: r463754 - in /incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix: components/util/EchoComponent.java jbi/framework/Endpoint.java jbi/util/MessageUtil.java

[gn...@apache.org]

Author: gnodet
Date: Fri Oct 13 10:52:16 2006
New Revision: 463754

URL: http://svn.apache.org/viewvc?view=rev&rev=463754
Log:
Add some constructors to EchoComponent and MessageUtil implementations
Fix a type in Endpoint mbean

Modified:
    incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/components/util/EchoComponent.java
    incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/framework/Endpoint.java
    incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/util/MessageUtil.java

Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/components/util/EchoComponent.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/components/util/EchoComponent.java?view=diff&rev=463754&r1=463753&r2=463754
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/components/util/EchoComponent.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/components/util/EchoComponent.java Fri Oct 13 10:52:16 2006
@@ -23,6 +23,7 @@
 import javax.jbi.messaging.MessageExchange;
 import javax.jbi.messaging.MessagingException;
 import javax.jbi.messaging.NormalizedMessage;
+import javax.xml.namespace.QName;
 
 /**
  * A simple, yet useful component for testing synchronous flows. Echos back Exchanges
@@ -31,6 +32,13 @@
  */
 public class EchoComponent extends TransformComponentSupport implements MessageExchangeListener {
     private static final Log log = LogFactory.getLog(EchoComponent.class);
+    
+    public EchoComponent() {
+    }
+    
+    public EchoComponent(QName service, String endpoint) {
+        super(service, endpoint);
+    }
     
     protected boolean transform(MessageExchange exchange, NormalizedMessage in, NormalizedMessage out) throws MessagingException {
         getMessageTransformer().transform(exchange, in, out);

Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/framework/Endpoint.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/framework/Endpoint.java?view=diff&rev=463754&r1=463753&r2=463754
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/framework/Endpoint.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/framework/Endpoint.java Fri Oct 13 10:52:16 2006
@@ -166,7 +166,7 @@
             }
             return null;
         } catch (Exception e) {
-            log.debug("Error processing test exchange", e);
+            log.debug("Error proces test exchange", e);
             throw new RuntimeException(e);
         } finally {
             if (client != null) {

Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/util/MessageUtil.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/util/MessageUtil.java?view=diff&rev=463754&r1=463753&r2=463754
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/util/MessageUtil.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/util/MessageUtil.java Fri Oct 13 10:52:16 2006
@@ -121,7 +121,7 @@
         dest.setMessage(destMsg, name);
     }
     
-    private static class NormalizedMessageImpl implements NormalizedMessage, Serializable {
+    public static class NormalizedMessageImpl implements NormalizedMessage, Serializable {
 
         private static final long serialVersionUID = -5813947566001096708L;
         
@@ -130,6 +130,9 @@
         private Map properties = new HashMap();
         private Map attachments = new HashMap();
         
+        public NormalizedMessageImpl() {
+        }
+        
         public NormalizedMessageImpl(NormalizedMessage message) throws Exception {
             String str = new SourceTransformer().contentToString(message);
             if (str != null) {
@@ -201,9 +204,12 @@
         
     }
     
-    private static class FaultImpl extends NormalizedMessageImpl implements Fault {
+    public static class FaultImpl extends NormalizedMessageImpl implements Fault {
         private static final long serialVersionUID = -6076815664102825860L;
 
+        public FaultImpl() {
+        }
+        
         public FaultImpl(Fault fault) throws Exception {
             super(fault);
         }