svn commit: r947508 - /synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java

[veithen]

Author: veithen
Date: Sun May 23 22:14:15 2010
New Revision: 947508

URL: http://svn.apache.org/viewvc?rev=947508&view=rev
Log:
Fixed the pipe transport.

Modified:
    
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java

Modified: 
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java?rev=947508&r1=947507&r2=947508&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java
 Sun May 23 22:14:15 2010
@@ -18,12 +18,9 @@
  */
 package org.apache.synapse.transport.pipe;
 
-import java.io.File;
 import java.io.IOException;
 
 import org.apache.axis2.AxisFault;
-import org.apache.axis2.context.ConfigurationContext;
-import org.apache.axis2.description.AxisService;
 import org.apache.axis2.description.TransportInDescription;
 import org.apache.axis2.transport.base.ManagementSupport;
 import org.apache.axis2.transport.base.ParamUtils;
@@ -58,8 +55,8 @@ public class PipeListener extends Abstra
     private Protocol protocol;
     
     @Override
-    public void init(ConfigurationContext cfgCtx, TransportInDescription 
transportIn) throws AxisFault {
-        super.init(cfgCtx, transportIn);
+    protected void doInit() throws AxisFault {
+        TransportInDescription transportIn = getTransportInDescription();
         String protocolClassName = ParamUtils.getRequiredParam(transportIn, 
"protocol");
         Class<? extends Protocol> protocolClass;
         try {