You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ve...@apache.org on 2010/05/24 00:14:15 UTC
svn commit: r947508 -
/synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java
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 {