You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by he...@apache.org on 2005/06/06 05:53:12 UTC
svn commit: r180205 [1/2] - in /webservices/axis/trunk/java: ./
modules/core/src/org/apache/axis/ modules/core/src/org/apache/axis/clientapi/
modules/core/src/org/apache/axis/deployment/
modules/core/src/org/apache/axis/engine/
modules/core/src/org/apache/axis/transport/
modules/core/src/org/apache/axis/transport/http/
modules/core/src/org/apache/axis/transport/tcp/
modules/core/src/org/apache/axis/util/ modules/samples/
modules/samples/test/org/apache/axis/engine/
modules/samples/test/org/apache/axis/mail/
modules/samples/test/org/apache/axis/rest/
modules/samples/test/org/apache/axis/tcp/ xdocs/ xdocs/images/archi-guide/
Author: hemapani
Date: Sun Jun 5 20:53:09 2005
New Revision: 180205
URL: http://svn.apache.org/viewcvs?rev=180205&view=rev
Log:
adding test cases, cleanups
Added:
webservices/axis/trunk/java/modules/core/src/org/apache/axis/util/URL.java
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/MailOneWayRawXMLTest.java
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/mail-enabled-client.xml
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/mail-enabled-server.xml
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/rest/
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/rest/RESTBasedEchoRawXMLTest.java
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/tcp/
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/tcp/TCPEchoRawXMLTest.java
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/tcp/TCPTwoChannelEchoRawXMLTest.java
webservices/axis/trunk/java/release-notes1-M2.html
webservices/axis/trunk/java/xdocs/images/archi-guide/big-picture.gif (with props)
webservices/axis/trunk/java/xdocs/images/archi-guide/soap-processing.gif (with props)
webservices/axis/trunk/java/xdocs/images/archi-guide/soap.gif (with props)
Removed:
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/engine/RESTBasedEchoRawXMLTest.java
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/engine/TCPEchoRawXMLTest.java
Modified:
webservices/axis/trunk/java/modules/core/src/org/apache/axis/Constants.java
webservices/axis/trunk/java/modules/core/src/org/apache/axis/clientapi/InOnlyMEPClient.java
webservices/axis/trunk/java/modules/core/src/org/apache/axis/deployment/client.xml
webservices/axis/trunk/java/modules/core/src/org/apache/axis/deployment/server.xml
webservices/axis/trunk/java/modules/core/src/org/apache/axis/engine/AxisEngine.java
webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/AbstractTransportSender.java
webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/AxisServlet.java
webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/HTTPConstants.java
webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/HTTPTransportReceiver.java
webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/SimpleHTTPServer.java
webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/tcp/TCPServer.java
webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/tcp/TCPTransportSender.java
webservices/axis/trunk/java/modules/samples/project.xml
webservices/axis/trunk/java/modules/samples/test/org/apache/axis/engine/OneWayRawXMLTest.java
webservices/axis/trunk/java/xdocs/Axis2ArchitectureGuide.html
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/Constants.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/Constants.java?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/Constants.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/Constants.java Sun Jun 5 20:53:09 2005
@@ -176,6 +176,7 @@
public static final String VALUE_TRUE = "true";
public static final String VALUE_FALSE = "false";
public static final String CONTAINER_MANAGED = "ContainerManaged";
+ public static final String RESPONSE_WRITTEN = "CONTENT_WRITTEN";
public static final String TESTING_REPOSITORY = "target/test-resources/samples";
//public static final String TESTING_REPOSITORY = "modules/samples/target/test-resources/samples";
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/clientapi/InOnlyMEPClient.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/clientapi/InOnlyMEPClient.java?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/clientapi/InOnlyMEPClient.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/clientapi/InOnlyMEPClient.java Sun Jun 5 20:53:09 2005
@@ -82,7 +82,7 @@
HTTPTransportReceiver receiver = new HTTPTransportReceiver();
receiver.checkForMessage(response, sysContext);
SOAPEnvelope resenvelope = response.getEnvelope();
- if (response!= null && resenvelope.getBody().hasFault()) {
+ if (resenvelope!= null && resenvelope.getBody().hasFault()) {
throw new AxisFault(resenvelope.getBody().getFault().getException());
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/deployment/client.xml
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/deployment/client.xml?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/deployment/client.xml (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/deployment/client.xml Sun Jun 5 20:53:09 2005
@@ -1,60 +1,63 @@
<client name="AxisJava2.0">
+ <!-- ================================================= -->
+ <!-- Parameters -->
+ <!-- ================================================= -->
<parameter name="hotdeployment" locked="xsd:false">true</parameter>
<parameter name="hotupdate" locked="xsd:false">true</parameter>
-
+ <!-- Uncomment this to enable REST support -->
+ <parameter name="eanbleREST" locked="xsd:false">true</parameter>
<parameter name="userName" locked="xsd:false">Axis2admin</parameter>
<parameter name="password" locked="xsd:false">changeMe</parameter>
-
+ <!-- ================================================= -->
+ <!-- Message Receivers -->
+ <!-- ================================================= -->
+ <!-- This is the Deafult Message Receiver for the Request Response style Operations -->
<messageReceiver mep="INOUT" class="org.apache.axis.receivers.RawXMLINOutMessageRecevier"/>
+ <!-- ================================================= -->
+ <!-- Transport Ins -->
+ <!-- ================================================= -->
<transportReceiver name="http" class="org.apache.axis.transport.http.SimpleHTTPServer">
<parameter name="port" locked="xsd:false">6060</parameter>
</transportReceiver>
- <transportSender name="http" class="org.apache.axis.transport.http.HTTPTransportSender">
- </transportSender>
-
- <transportReceiver name="tcp" class="org.apache.axis.transport.http.SimpleHTTPServer">
- <parameter name="port" locked="xsd:false">6060</parameter>
- </transportReceiver>
- <transportSender name="tcp" class="org.apache.axis.transport.tcp.TCPTransportSender"/>
-
- <transportReceiver name="local">
- <parameter name="port" locked="xsd:false">6060</parameter>
- </transportReceiver>
- <transportSender name="local" class="org.apache.axis.transport.local.LocalTransportSender"/>
-
-<!--
- <transportReceiver name="mail" class="org.apache.axis.transport.mail.SimpleMailListener">
- <parameter name="transport.mail.pop3.host" locked="xsd:false">mail.itambalama.com</parameter>
- <parameter name="transport.mail.pop3.user" locked="xsd:false">axis2.mail.test@itambalama.com</parameter>
- <parameter name="transport.mail.pop3.password" locked="xsd:false">2sixa.mail</parameter>
- <parameter name="transport.mail.pop3.port" locked="xsd:false">110</parameter>
- <parameter name="transport.mail.replyToAddress" locked="xsd:false">axis2.mail.test@itambalama.com</parameter>
- </transportReceiver>
- <transportSender name="mail" class="org.apache.axis.transport.mail.MailTransportSender">
- <parameter name="transport.mail.smtp.host" locked="xsd:false">mail.itambalama.com</parameter>
- <parameter name="transport.mail.smtp.user" locked="xsd:false">axis2.mail.test</parameter>
- <parameter name="transport.mail.smtp.password" locked="xsd:false">2sixa.mail</parameter>
- <parameter name="transport.mail.smtp.port" locked="xsd:false">25</parameter>
- </transportSender>
-
-
-<transportReceiver name="mail" class="org.apache.axis.transport.mail.SimpleMailListener">
+ <!-- Uncomment this one with the appropriate papameters to enable the SMTP transport Receiver
+ <transportReceiver name="mail" class="org.apache.axis.transport.mail.SimpleMailListener">
<parameter name="transport.mail.pop3.host" locked="xsd:false">127.0.0.1</parameter>
<parameter name="transport.mail.pop3.user" locked="xsd:false">axis2</parameter>
<parameter name="transport.mail.pop3.password" locked="xsd:false">axis2</parameter>
<parameter name="transport.mail.pop3.port" locked="xsd:false">110</parameter>
<parameter name="transport.mail.replyToAddress" locked="xsd:false">axis2@127.0.0.1</parameter>
+ </transportReceiver> -->
+
+ <transportReceiver name="tcp" class="org.apache.axis.transport.tcp.TCPServer">
+ <parameter name="port" locked="xsd:false">6060</parameter>
</transportReceiver>
+ <transportReceiver name="local"/>
+
+ <!-- ================================================= -->
+ <!-- Transport Outs -->
+ <!-- ================================================= -->
+
+ <transportSender name="http" class="org.apache.axis.transport.http.HTTPTransportSender"/>
+ <transportSender name="tcp" class="org.apache.axis.transport.tcp.TCPTransportSender"/>
+ <transportSender name="local" class="org.apache.axis.transport.local.LocalTransportSender"/>
+
+ <!-- Uncomment this one with the appropriate papameters to enable the SMTP transport Receiver
<transportSender name="mail" class="org.apache.axis.transport.mail.MailTransportSender">
<parameter name="transport.mail.smtp.host" locked="xsd:false">127.0.0.1</parameter>
<parameter name="transport.mail.smtp.user" locked="xsd:false">axis2</parameter>
<parameter name="transport.mail.smtp.password" locked="xsd:false">axis2</parameter>
<parameter name="transport.mail.smtp.port" locked="xsd:false">25</parameter>
</transportSender>
--->
+ -->
+
+ <!-- ================================================= -->
+ <!-- Global Modules -->
+ <!-- ================================================= -->
+ <!-- Uncomment this to enable Addressing
+ <module ref="addressing"/> -->
</client>
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/deployment/server.xml
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/deployment/server.xml?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/deployment/server.xml (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/deployment/server.xml Sun Jun 5 20:53:09 2005
@@ -1,60 +1,66 @@
<server name="AxisJava2.0">
+ <!-- ================================================= -->
+ <!-- Parameters -->
+ <!-- ================================================= -->
<parameter name="hotdeployment" locked="xsd:false">true</parameter>
<parameter name="hotupdate" locked="xsd:false">true</parameter>
-
-
+ <!-- Uncomment this to enable REST support -->
+ <parameter name="eanbleREST" locked="xsd:false">true</parameter>
<parameter name="userName" locked="xsd:false">Axis2admin</parameter>
<parameter name="password" locked="xsd:false">changeMe</parameter>
-
+ <!-- ================================================= -->
+ <!-- Message Receivers -->
+ <!-- ================================================= -->
+ <!-- This is the Deafult Message Receiver for the Request Response style Operations -->
<messageReceiver mep="INOUT" class="org.apache.axis.receivers.RawXMLINOutMessageRecevier"/>
+ <!-- ================================================= -->
+ <!-- Transport Ins -->
+ <!-- ================================================= -->
<transportReceiver name="http" class="org.apache.axis.transport.http.SimpleHTTPServer">
<parameter name="port" locked="xsd:false">6060</parameter>
</transportReceiver>
- <transportSender name="http" class="org.apache.axis.transport.http.HTTPTransportSender">
- </transportSender>
-
- <transportReceiver name="tcp" class="org.apache.axis.transport.http.SimpleHTTPServer">
- <parameter name="port" locked="xsd:false">6060</parameter>
- </transportReceiver>
-
- <transportSender name="tcp" class="org.apache.axis.transport.tcp.TCPTransportSender"/>
-<!--
- <transportReceiver name="mail" class="org.apache.axis.transport.mail.SimpleMailListener">
- <parameter name="transport.mail.pop3.host" locked="xsd:false">mail.itambalama.com</parameter>
- <parameter name="transport.mail.pop3.user" locked="xsd:false">axis2.mail.test@itambalama.com</parameter>
- <parameter name="transport.mail.pop3.password" locked="xsd:false">2sixa.mail</parameter>
- <parameter name="transport.mail.pop3.port" locked="xsd:false">110</parameter>
- <parameter name="transport.mail.replyToAddress" locked="xsd:false">axis2.mail.test@itambalama.com</parameter>
- </transportReceiver>
- <transportSender name="mail" class="org.apache.axis.transport.mail.MailTransportSender">
- <parameter name="transport.mail.smtp.host" locked="xsd:false">mail.itambalama.com</parameter>
- <parameter name="transport.mail.smtp.user" locked="xsd:false">axis2.mail.test</parameter>
- <parameter name="transport.mail.smtp.password" locked="xsd:false">2sixa.mail</parameter>
- <parameter name="transport.mail.smtp.port" locked="xsd:false">25</parameter>
- </transportSender>
-
-
+ <!-- Uncomment this one with the appropriate papameters to enable the SMTP transport Receiver
<transportReceiver name="mail" class="org.apache.axis.transport.mail.SimpleMailListener">
<parameter name="transport.mail.pop3.host" locked="xsd:false">127.0.0.1</parameter>
<parameter name="transport.mail.pop3.user" locked="xsd:false">axis2</parameter>
<parameter name="transport.mail.pop3.password" locked="xsd:false">axis2</parameter>
<parameter name="transport.mail.pop3.port" locked="xsd:false">110</parameter>
<parameter name="transport.mail.replyToAddress" locked="xsd:false">axis2@127.0.0.1</parameter>
+ </transportReceiver> -->
+
+ <transportReceiver name="tcp" class="org.apache.axis.transport.tcp.TCPServer">
+ <parameter name="port" locked="xsd:false">6060</parameter>
</transportReceiver>
+
+ <!-- ================================================= -->
+ <!-- Transport Outs -->
+ <!-- ================================================= -->
+
+ <transportSender name="http" class="org.apache.axis.transport.http.HTTPTransportSender"/>
+ <transportSender name="tcp" class="org.apache.axis.transport.tcp.TCPTransportSender"/>
+ <transportSender name="local" class="org.apache.axis.transport.local.LocalTransportSender"/>
+
+ <!-- Uncomment this one with the appropriate papameters to enable the SMTP transport Receiver
<transportSender name="mail" class="org.apache.axis.transport.mail.MailTransportSender">
<parameter name="transport.mail.smtp.host" locked="xsd:false">127.0.0.1</parameter>
<parameter name="transport.mail.smtp.user" locked="xsd:false">axis2</parameter>
<parameter name="transport.mail.smtp.password" locked="xsd:false">axis2</parameter>
<parameter name="transport.mail.smtp.port" locked="xsd:false">25</parameter>
</transportSender>
-
-->
-
- <!-- <module ref="addressing"/> -->
+ <!-- ================================================= -->
+ <!-- Global Modules -->
+ <!-- ================================================= -->
+ <!-- Uncomment this to enable Addressing
+ <module ref="addressing"/> -->
+
+ <!-- ================================================= -->
+ <!-- Phases -->
+ <!-- ================================================= -->
<phaseOrder type="inflow">
<!-- System pre defined phases -->
<phase name="TransportIn"/>
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/engine/AxisEngine.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/engine/AxisEngine.java?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/engine/AxisEngine.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/engine/AxisEngine.java Sun Jun 5 20:53:09 2005
@@ -119,8 +119,7 @@
}
if (msgContext.isServerSide()) {
// add invoke Phase
- MessageReceiver reciver =
- msgContext.getOperationContext().getAxisOperation().getMessageReciever();
+ MessageReceiver reciver = operationDescription.getMessageReciever();
reciver.recieve(msgContext);
}
} catch (Throwable e) {
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/AbstractTransportSender.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/AbstractTransportSender.java?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/AbstractTransportSender.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/AbstractTransportSender.java Sun Jun 5 20:53:09 2005
@@ -95,6 +95,7 @@
throw new AxisFault("Both the TO and Property MessageContext.TRANSPORT_WRITER is Null, No where to send");
}
}
+ msgContext.getOperationContext().setProperty(Constants.RESPONSE_WRITTEN,Constants.VALUE_TRUE);
}
public void writeMessage(MessageContext msgContext, Writer out) throws AxisFault {
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/AxisServlet.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/AxisServlet.java?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/AxisServlet.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/AxisServlet.java Sun Jun 5 20:53:09 2005
@@ -68,47 +68,32 @@
/**
* Field LIST_MULTIPLE_SERVICE_JSP_NAME
*/
- private static final String LIST_MULTIPLE_SERVICE_JSP_NAME =
- "listServices.jsp";
+ private static final String LIST_MULTIPLE_SERVICE_JSP_NAME = "listServices.jsp";
- private static final String LIST_SRVICES_JSP_NAME =
- "listService.jsp";
+ private static final String LIST_SRVICES_JSP_NAME = "listService.jsp";
- private static final String SELECT_SERVICE_JSP_NAME =
- "SelectService.jsp";
+ private static final String SELECT_SERVICE_JSP_NAME = "SelectService.jsp";
- private static final String ADMIN_JSP_NAME =
- "admin.jsp";
+ private static final String ADMIN_JSP_NAME = "admin.jsp";
+ private static final String LIST_AVAILABLE_MODULES_JSP_NAME = "listModules.jsp";
+ private static final String LIST_GLOABLLY_ENGAGED_MODULES_JSP_NAME = "globalModules.jsp";
- private static final String LIST_AVAILABLE_MODULES_JSP_NAME =
- "listModules.jsp";
+ private static final String LIST_PHASES_JSP_NAME = "viewphases.jsp";
- private static final String LIST_GLOABLLY_ENGAGED_MODULES_JSP_NAME =
- "globalModules.jsp";
+ private static final String ENGAGING_MODULE_GLOBALLY_JSP_NAME = "engagingglobally.jsp";
- private static final String LIST_PHASES_JSP_NAME =
- "viewphases.jsp";
-
- private static final String ENGAGING_MODULE_GLOBALLY_JSP_NAME =
- "engagingglobally.jsp";
-
- private static final String ENGAGING_MODULE_TO_SERVICE_JSP_NAME =
- "engagingtoaservice.jsp";
+ private static final String ENGAGING_MODULE_TO_SERVICE_JSP_NAME = "engagingtoaservice.jsp";
/**
* Field LIST_SINGLE_SERVICE_JSP_NAME
*/
- private static final String LIST_SINGLE_SERVICE_JSP_NAME =
- "listSingleService.jsp";
- private static final String VIEW_GLOBAL_HANDLERS_JSP_NAME =
- "ViewGlobalHandlers.jsp";
- private static final String VIEW_SERVICE_HANDLERS_JSP_NAME =
- "ViewServiceHandlers.jsp";
+ private static final String LIST_SINGLE_SERVICE_JSP_NAME = "listSingleService.jsp";
+ private static final String VIEW_GLOBAL_HANDLERS_JSP_NAME = "ViewGlobalHandlers.jsp";
+ private static final String VIEW_SERVICE_HANDLERS_JSP_NAME = "ViewServiceHandlers.jsp";
- private static final String ENGAGE_TO_OPERATION_JSP_NAME =
- "enaggingtoanopeartion.jsp";
+ private static final String ENGAGE_TO_OPERATION_JSP_NAME = "enaggingtoanopeartion.jsp";
/**
* Field allowListServices
@@ -130,10 +115,9 @@
try {
ServletContext context = config.getServletContext();
String repoDir = context.getRealPath("/WEB-INF");
- ConfigurationContextFactory erfac =
- new ConfigurationContextFactory();
+ ConfigurationContextFactory erfac = new ConfigurationContextFactory();
engineContext = erfac.buildEngineContext(repoDir);
- engineContext.setProperty(Constants.CONTAINER_MANAGED,Constants.VALUE_TRUE);
+ engineContext.setProperty(Constants.CONTAINER_MANAGED, Constants.VALUE_TRUE);
} catch (Exception e) {
throw new ServletException(e);
}
@@ -148,64 +132,52 @@
* @throws IOException
*/
protected void doGet(
- HttpServletRequest httpServletRequest,
- HttpServletResponse httpServletResponse)
- throws ServletException, IOException {
+ HttpServletRequest httpServletRequest,
+ HttpServletResponse httpServletResponse)
+ throws ServletException, IOException {
String filePart = httpServletRequest.getRequestURL().toString();
- if((filePart != null)
- && filePart.endsWith(Constants.ADMIN_LISTSERVICES)){
+ if ((filePart != null) && filePart.endsWith(Constants.ADMIN_LISTSERVICES)) {
listAdminServices(httpServletRequest, httpServletResponse);
return;
- } else if ((filePart != null)
- && filePart.endsWith(Constants.LIST_MODULES)){
+ } else if ((filePart != null) && filePart.endsWith(Constants.LIST_MODULES)) {
listModules(httpServletRequest, httpServletResponse);
return;
- } else if ((filePart != null)
- && filePart.endsWith(Constants.LIST_GLOABLLY_ENGAGED_MODULES)){
+ } else if (
+ (filePart != null) && filePart.endsWith(Constants.LIST_GLOABLLY_ENGAGED_MODULES)) {
listGloballyModules(httpServletRequest, httpServletResponse);
return;
- } else if ((filePart != null)
- && filePart.endsWith(Constants.LIST_PHASES)){
+ } else if ((filePart != null) && filePart.endsWith(Constants.LIST_PHASES)) {
listPhases(httpServletRequest, httpServletResponse);
return;
- }else if ((filePart != null)
- && filePart.endsWith(Constants.ENGAGE_GLOBAL_MODULE)){
+ } else if ((filePart != null) && filePart.endsWith(Constants.ENGAGE_GLOBAL_MODULE)) {
engageModulesGlobally(httpServletRequest, httpServletResponse);
return;
- }
- else if ((filePart != null)
- && filePart.endsWith(Constants.ENGAGE_MODULE_TO_SERVICE)){
+ } else if ((filePart != null) && filePart.endsWith(Constants.ENGAGE_MODULE_TO_SERVICE)) {
engageModulesToService(httpServletRequest, httpServletResponse);
return;
- } else if ((filePart != null)
- && filePart.endsWith(Constants.ADMIN_LOGGING)){
+ } else if ((filePart != null) && filePart.endsWith(Constants.ADMIN_LOGGING)) {
adminLogging(httpServletRequest, httpServletResponse);
return;
- } else if ((filePart != null)
- && filePart.endsWith(Constants.VIEW_GLOBAL_HANDLERS)){
+ } else if ((filePart != null) && filePart.endsWith(Constants.VIEW_GLOBAL_HANDLERS)) {
viewGlobalHandlers(httpServletRequest, httpServletResponse);
return;
- } else if ((filePart != null)
- && filePart.endsWith(Constants.SELECT_SERVICE)){
+ } else if ((filePart != null) && filePart.endsWith(Constants.SELECT_SERVICE)) {
selectService(httpServletRequest, httpServletResponse);
return;
- } else if ((filePart != null)
- && filePart.endsWith(Constants.VIEW_SERVICE_HANDLERS)){
+ } else if ((filePart != null) && filePart.endsWith(Constants.VIEW_SERVICE_HANDLERS)) {
viewServiceHandlers(httpServletRequest, httpServletResponse);
return;
- } else if ((filePart != null)
- && filePart.endsWith(Constants.LIST_SERVICE_FOR_MODULE_ENGAMNET)){
+ } else if (
+ (filePart != null) && filePart.endsWith(Constants.LIST_SERVICE_FOR_MODULE_ENGAMNET)) {
lsitServiceformodules(httpServletRequest, httpServletResponse);
return;
- } else if ((filePart != null)
- && filePart.endsWith(Constants.LIST_OPERATIONS_FOR_THE_SERVICE)){
+ } else if (
+ (filePart != null) && filePart.endsWith(Constants.LIST_OPERATIONS_FOR_THE_SERVICE)) {
engageModulesToOpeartion(httpServletRequest, httpServletResponse);
return;
}
- if (allowListServices
- && (filePart != null)
- && filePart.endsWith(Constants.LISTSERVICES)) {
+ if (allowListServices && (filePart != null) && filePart.endsWith(Constants.LISTSERVICES)) {
listServices(httpServletRequest, httpServletResponse);
return;
} else {
@@ -230,42 +202,39 @@
* @throws IOException
*/
protected void doPost(HttpServletRequest req, HttpServletResponse res)
- throws ServletException, IOException {
+ throws ServletException, IOException {
try {
res.setContentType("text/xml; charset=utf-8");
AxisEngine engine = new AxisEngine(engineContext);
Object sessionContext =
- req.getSession().getAttribute(
- Constants.SESSION_CONTEXT_PROPERTY);
+ req.getSession().getAttribute(Constants.SESSION_CONTEXT_PROPERTY);
if (sessionContext == null) {
sessionContext = new SessionContext(null);
- req.getSession().setAttribute(
- Constants.SESSION_CONTEXT_PROPERTY,
- sessionContext);
+ req.getSession().setAttribute(Constants.SESSION_CONTEXT_PROPERTY, sessionContext);
}
MessageContext msgContext =
- new MessageContext(engineContext,
- (SessionContext) sessionContext,
- engineContext.getAxisConfiguration().getTransportIn(
- new QName(Constants.TRANSPORT_HTTP)),
- engineContext.getAxisConfiguration().getTransportOut(
- new QName(Constants.TRANSPORT_HTTP)));
+ new MessageContext(
+ engineContext,
+ (SessionContext) sessionContext,
+ engineContext.getAxisConfiguration().getTransportIn(
+ new QName(Constants.TRANSPORT_HTTP)),
+ engineContext.getAxisConfiguration().getTransportOut(
+ new QName(Constants.TRANSPORT_HTTP)));
msgContext.setServerSide(true);
-
String filePart = req.getRequestURL().toString();
- msgContext.setTo(
- new EndpointReference(AddressingConstants.WSA_TO, filePart));
- String soapActionString =
- req.getHeader(HTTPConstants.HEADER_SOAP_ACTION);
+ msgContext.setTo(new EndpointReference(AddressingConstants.WSA_TO, filePart));
+ String soapActionString = req.getHeader(HTTPConstants.HEADER_SOAP_ACTION);
if (soapActionString != null) {
msgContext.setWSAAction(soapActionString);
}
XMLStreamReader reader =
- XMLInputFactory.newInstance().createXMLStreamReader(
- new BufferedReader(
- new InputStreamReader(req.getInputStream())));
- Utils.configureMessageContextForHTTP(req.getContentType(),soapActionString,msgContext);
+ XMLInputFactory.newInstance().createXMLStreamReader(
+ new BufferedReader(new InputStreamReader(req.getInputStream())));
+ Utils.configureMessageContextForHTTP(
+ req.getContentType(),
+ soapActionString,
+ msgContext);
//Check for the REST behaviour, if you desire rest beahaviour
//put a <parameter name="doREST" value="true"/> at the server.xml/client.xml file
@@ -286,9 +255,14 @@
msgContext.setEnvelope(envelope);
msgContext.setProperty(
- MessageContext.TRANSPORT_WRITER,
- new BufferedWriter(res.getWriter()));
+ MessageContext.TRANSPORT_WRITER,
+ new BufferedWriter(res.getWriter()));
engine.receive(msgContext);
+
+ Object contextWritten = msgContext.getProperty(Constants.RESPONSE_WRITTEN);
+ if (contextWritten == null || !Constants.VALUE_TRUE.equals(contextWritten)) {
+ res.setStatus(HttpServletResponse.SC_NO_CONTENT);
+ }
} catch (AxisFault e) {
throw new ServletException(e);
} catch (XMLStreamException e) {
@@ -305,13 +279,12 @@
* @param res
* @throws IOException
*/
- private void listServices(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
+ private void listServices(HttpServletRequest req, HttpServletResponse res) throws IOException {
HashMap services = engineContext.getAxisConfiguration().getServices();
req.getSession().setAttribute(Constants.SERVICE_MAP, services);
req.getSession().setAttribute(
- Constants.ERROR_SERVICE_MAP,
- engineContext.getAxisConfiguration().getFaulytServices());
+ Constants.ERROR_SERVICE_MAP,
+ engineContext.getAxisConfiguration().getFaulytServices());
res.sendRedirect(LIST_MULTIPLE_SERVICE_JSP_NAME);
}
@@ -322,35 +295,43 @@
* @throws IOException
*/
private void listAdminServices(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
+ throws IOException {
HashMap services = engineContext.getAxisConfiguration().getServices();
req.getSession().setAttribute(Constants.SERVICE_MAP, services);
req.getSession().setAttribute(
- Constants.ERROR_SERVICE_MAP,
- engineContext.getAxisConfiguration().getFaulytServices());
+ Constants.ERROR_SERVICE_MAP,
+ engineContext.getAxisConfiguration().getFaulytServices());
res.sendRedirect(LIST_SRVICES_JSP_NAME);
}
private void selectService(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
+ throws IOException {
HashMap services = engineContext.getAxisConfiguration().getServices();
req.getSession().setAttribute(Constants.SERVICE_MAP, services);
req.getSession().setAttribute(Constants.MODULE_ENGAMENT, null);
res.sendRedirect(SELECT_SERVICE_JSP_NAME);
}
- private void adminLogging(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
+ private void adminLogging(HttpServletRequest req, HttpServletResponse res) throws IOException {
String username = req.getParameter("userName");
String password = req.getParameter("password");
- if(username == null || password == null || username.trim().equals("") || password.trim().equals("")){
+ if (username == null
+ || password == null
+ || username.trim().equals("")
+ || password.trim().equals("")) {
throw new AxisFault("invalid user name");
}
- String adminUserName =(String)((AxisConfigurationImpl) engineContext.getAxisConfiguration())
- .getParameter(Constants.USER_NAME).getValue();
- String adminPassword =(String)((AxisConfigurationImpl) engineContext.getAxisConfiguration())
- .getParameter(Constants.PASSWORD).getValue();
- if(username!= null && password !=null && username.equals(adminUserName) &&
- password.equals(adminPassword)){
+ String adminUserName =
+ (String) ((AxisConfigurationImpl) engineContext.getAxisConfiguration())
+ .getParameter(Constants.USER_NAME)
+ .getValue();
+ String adminPassword =
+ (String) ((AxisConfigurationImpl) engineContext.getAxisConfiguration())
+ .getParameter(Constants.PASSWORD)
+ .getValue();
+ if (username != null
+ && password != null
+ && username.equals(adminUserName)
+ && password.equals(adminPassword)) {
req.getSession().setAttribute(Constants.LOGGED, "Yes");
res.sendRedirect(ADMIN_JSP_NAME);
} else {
@@ -358,126 +339,141 @@
}
}
- private void listModules(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
- HashMap modules =((AxisConfigurationImpl) engineContext.getAxisConfiguration()).getModules();
+ private void listModules(HttpServletRequest req, HttpServletResponse res) throws IOException {
+ HashMap modules =
+ ((AxisConfigurationImpl) engineContext.getAxisConfiguration()).getModules();
req.getSession().setAttribute(Constants.MODULE_MAP, modules);
res.sendRedirect(LIST_AVAILABLE_MODULES_JSP_NAME);
}
private void engageModulesGlobally(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
- HashMap modules =((AxisConfigurationImpl) engineContext.getAxisConfiguration()).getModules();
+ throws IOException {
+ HashMap modules =
+ ((AxisConfigurationImpl) engineContext.getAxisConfiguration()).getModules();
req.getSession().setAttribute(Constants.MODULE_MAP, modules);
- String moduleName =(String)req.getParameter("modules");
+ String moduleName = (String) req.getParameter("modules");
req.getSession().setAttribute(Constants.ENGAGE_STATUS, null);
- if(moduleName !=null){
+ if (moduleName != null) {
try {
engineContext.getAxisConfiguration().engageModule(new QName(moduleName));
- req.getSession().setAttribute(Constants.ENGAGE_STATUS, moduleName + " module engaged globally Successfully");
+ req.getSession().setAttribute(
+ Constants.ENGAGE_STATUS,
+ moduleName + " module engaged globally Successfully");
} catch (AxisFault axisFault) {
req.getSession().setAttribute(Constants.ENGAGE_STATUS, axisFault.getMessage());
}
}
- req.getSession().setAttribute("modules",null);
+ req.getSession().setAttribute("modules", null);
res.sendRedirect(ENGAGING_MODULE_GLOBALLY_JSP_NAME);
}
private void engageModulesToOpeartion(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
- HashMap modules =((AxisConfigurationImpl) engineContext.getAxisConfiguration()).getModules();
+ throws IOException {
+ HashMap modules =
+ ((AxisConfigurationImpl) engineContext.getAxisConfiguration()).getModules();
req.getSession().setAttribute(Constants.MODULE_MAP, modules);
- String moduleName =(String)req.getParameter("modules");
+ String moduleName = (String) req.getParameter("modules");
req.getSession().setAttribute(Constants.ENGAGE_STATUS, null);
- req.getSession().setAttribute("modules",null);
+ req.getSession().setAttribute("modules", null);
- String serviceName =(String)req.getParameter("service");
- if(serviceName != null){
- req.getSession().setAttribute("service",serviceName);
- } else {
- serviceName = (String)req.getSession().getAttribute("service");
+ String serviceName = (String) req.getParameter("service");
+ if (serviceName != null) {
+ req.getSession().setAttribute("service", serviceName);
+ } else {
+ serviceName = (String) req.getSession().getAttribute("service");
}
- req.getSession().setAttribute(Constants.OPEARTION_MAP,engineContext.getAxisConfiguration().
- getService(new QName(serviceName)).getOperations());
+ req.getSession().setAttribute(
+ Constants.OPEARTION_MAP,
+ engineContext
+ .getAxisConfiguration()
+ .getService(new QName(serviceName))
+ .getOperations());
req.getSession().setAttribute(Constants.ENGAGE_STATUS, null);
- String operationName =(String)req.getParameter("operation");
- if(serviceName !=null && moduleName !=null && operationName != null){
+ String operationName = (String) req.getParameter("operation");
+ if (serviceName != null && moduleName != null && operationName != null) {
try {
- OperationDescription od = engineContext.getAxisConfiguration().getService(
- new QName(serviceName)).getOperation(new QName(operationName));
- od.engageModule(engineContext.getAxisConfiguration().getModule(new QName(moduleName)));
- req.getSession().setAttribute(Constants.ENGAGE_STATUS, moduleName +
- " module engaged to the operation Successfully");
+ OperationDescription od =
+ engineContext.getAxisConfiguration().getService(
+ new QName(serviceName)).getOperation(
+ new QName(operationName));
+ od.engageModule(
+ engineContext.getAxisConfiguration().getModule(new QName(moduleName)));
+ req.getSession().setAttribute(
+ Constants.ENGAGE_STATUS,
+ moduleName + " module engaged to the operation Successfully");
} catch (AxisFault axisFault) {
req.getSession().setAttribute(Constants.ENGAGE_STATUS, axisFault.getMessage());
}
}
- req.getSession().setAttribute("operation",null);
+ req.getSession().setAttribute("operation", null);
res.sendRedirect(ENGAGE_TO_OPERATION_JSP_NAME);
}
private void engageModulesToService(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
- HashMap modules =((AxisConfigurationImpl) engineContext.getAxisConfiguration()).getModules();
+ throws IOException {
+ HashMap modules =
+ ((AxisConfigurationImpl) engineContext.getAxisConfiguration()).getModules();
req.getSession().setAttribute(Constants.MODULE_MAP, modules);
HashMap services = engineContext.getAxisConfiguration().getServices();
req.getSession().setAttribute(Constants.SERVICE_MAP, services);
- String moduleName =(String)req.getParameter("modules");
+ String moduleName = (String) req.getParameter("modules");
req.getSession().setAttribute(Constants.ENGAGE_STATUS, null);
- req.getSession().setAttribute("modules",null);
- String serviceName =(String)req.getParameter("service");
+ req.getSession().setAttribute("modules", null);
+ String serviceName = (String) req.getParameter("service");
req.getSession().setAttribute(Constants.ENGAGE_STATUS, null);
- if(serviceName !=null && moduleName !=null){
+ if (serviceName != null && moduleName != null) {
try {
- engineContext.getAxisConfiguration().getService(new QName(serviceName)).engageModule(
- engineContext.getAxisConfiguration().getModule(new QName(moduleName)));
- req.getSession().setAttribute(Constants.ENGAGE_STATUS, moduleName +
- " module engaged to the service Successfully");
+ engineContext.getAxisConfiguration().getService(
+ new QName(serviceName)).engageModule(
+ engineContext.getAxisConfiguration().getModule(new QName(moduleName)));
+ req.getSession().setAttribute(
+ Constants.ENGAGE_STATUS,
+ moduleName + " module engaged to the service Successfully");
} catch (AxisFault axisFault) {
req.getSession().setAttribute(Constants.ENGAGE_STATUS, axisFault.getMessage());
}
}
- req.getSession().setAttribute("service",null);
+ req.getSession().setAttribute("service", null);
res.sendRedirect(ENGAGING_MODULE_TO_SERVICE_JSP_NAME);
}
private void listGloballyModules(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
- Collection modules =((AxisConfigurationImpl) engineContext.getAxisConfiguration()).getEngadgedModules();
+ throws IOException {
+ Collection modules =
+ ((AxisConfigurationImpl) engineContext.getAxisConfiguration()).getEngadgedModules();
req.getSession().setAttribute(Constants.MODULE_MAP, modules);
res.sendRedirect(LIST_GLOABLLY_ENGAGED_MODULES_JSP_NAME);
}
private void lsitServiceformodules(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
+ throws IOException {
HashMap services = engineContext.getAxisConfiguration().getServices();
req.getSession().setAttribute(Constants.SERVICE_MAP, services);
req.getSession().setAttribute(Constants.MODULE_ENGAMENT, "Yes");
res.sendRedirect(SELECT_SERVICE_JSP_NAME);
}
-
private void viewGlobalHandlers(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
- req.getSession().setAttribute(Constants.GLOBAL_HANDLERS, engineContext.getAxisConfiguration());
+ throws IOException {
+ req.getSession().setAttribute(
+ Constants.GLOBAL_HANDLERS,
+ engineContext.getAxisConfiguration());
res.sendRedirect(VIEW_GLOBAL_HANDLERS_JSP_NAME);
}
private void viewServiceHandlers(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
- String service = (String)req.getParameter("service");
- if (service!= null) {
- req.getSession().setAttribute(Constants.SERVICE_HANDLERS,
- engineContext.getAxisConfiguration().getService(new QName(service)) );
+ throws IOException {
+ String service = (String) req.getParameter("service");
+ if (service != null) {
+ req.getSession().setAttribute(
+ Constants.SERVICE_HANDLERS,
+ engineContext.getAxisConfiguration().getService(new QName(service)));
}
res.sendRedirect(VIEW_SERVICE_HANDLERS_JSP_NAME);
}
-
-
- private void listPhases(HttpServletRequest req, HttpServletResponse res)
- throws IOException {
+ private void listPhases(HttpServletRequest req, HttpServletResponse res) throws IOException {
ArrayList phaselist = new ArrayList();
DeploymentData depdata = DeploymentData.getInstance();
phaselist.add(depdata.getINPhases());
@@ -494,7 +490,6 @@
res.sendRedirect(LIST_PHASES_JSP_NAME);
}
-
/**
* Method listService
*
@@ -503,22 +498,14 @@
* @param filePart
* @throws IOException
*/
- private void listService(
- HttpServletRequest req,
- HttpServletResponse res,
- String filePart)
- throws IOException {
- String serviceName =
- filePart.substring(
- filePart.lastIndexOf("/") + 1,
- filePart.length());
+ private void listService(HttpServletRequest req, HttpServletResponse res, String filePart)
+ throws IOException {
+ String serviceName = filePart.substring(filePart.lastIndexOf("/") + 1, filePart.length());
HashMap services = engineContext.getAxisConfiguration().getServices();
if ((services != null) && !services.isEmpty()) {
Object serviceObj = services.get(new QName(serviceName));
if (serviceObj != null) {
- req.getSession().setAttribute(
- Constants.SINGLE_SERVICE,
- serviceObj);
+ req.getSession().setAttribute(Constants.SINGLE_SERVICE, serviceObj);
}
}
String URI = req.getRequestURI();
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/HTTPConstants.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/HTTPConstants.java?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/HTTPConstants.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/HTTPConstants.java Sun Jun 5 20:53:09 2005
@@ -19,11 +19,7 @@
* HTTP protocol and message context constants.
*/
public class HTTPConstants {
- /**
- * The MessageContext transport ID of HTTP.
- * (Maybe this should be more specific, like "http_servlet",
- * whaddya think? - todo by Jacek)
- */
+
public static final String PROTOCOL_VERSION = "PROTOCOL";
/**
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/HTTPTransportReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/HTTPTransportReceiver.java?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/HTTPTransportReceiver.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/HTTPTransportReceiver.java Sun Jun 5 20:53:09 2005
@@ -98,48 +98,36 @@
throws AxisFault {
SOAPEnvelope soapEnvelope = null;
- Reader in =
- (Reader) msgContext.getProperty(MessageContext.TRANSPORT_READER);
+ Reader in = (Reader) msgContext.getProperty(MessageContext.TRANSPORT_READER);
if (in != null) {
boolean serverSide = msgContext.isServerSide();
Map map = parseTheHeaders(in, serverSide);
- if (serverSide) {
- msgContext.setWSAAction(
- (String) map.get(HTTPConstants.HEADER_SOAP_ACTION));
- Utils.configureMessageContextForHTTP((String)map.get(HTTPConstants.HEADER_CONTENT_TYPE),msgContext.getWSAAction(),msgContext);
-
- String requestURI = (String) map.get(HTTPConstants.REQUEST_URI);
- msgContext.setTo(
- new EndpointReference(
- AddressingConstants.WSA_TO,
- requestURI));
- //getServiceLookUp(requestURI)));
-
- // TODO see is it a Service request e.g. WSDL, list ....
- // TODO take care of the other HTTPHeaders
- } else {
- if (HTTPConstants
- .RESPONSE_ACK_CODE_VAL
- .equals(map.get(HTTPConstants.RESPONSE_CODE))) {
- msgContext.setProperty(
- MessageContext.TRANSPORT_SUCCEED,
- HTTPConstants.RESPONSE_ACK_CODE_VAL);
- return soapEnvelope;
- }
-
- // TODO take care of other HTTP Headers
+ if (HTTPConstants.RESPONSE_ACK_CODE_VAL.equals(map.get(HTTPConstants.RESPONSE_CODE))) {
+ msgContext.setProperty(
+ MessageContext.TRANSPORT_SUCCEED,
+ HTTPConstants.RESPONSE_ACK_CODE_VAL);
+ return soapEnvelope;
}
+ msgContext.setWSAAction((String) map.get(HTTPConstants.HEADER_SOAP_ACTION));
+ Utils.configureMessageContextForHTTP(
+ (String) map.get(HTTPConstants.HEADER_CONTENT_TYPE),
+ msgContext.getWSAAction(),
+ msgContext);
+
+ String requestURI = (String) map.get(HTTPConstants.REQUEST_URI);
+ msgContext.setTo(new EndpointReference(AddressingConstants.WSA_TO, requestURI));
+ //getServiceLookUp(requestURI)));
+ // TODO see is it a Service request e.g. WSDL, list ....
+ // TODO take care of the other HTTPHeaders
try {
//Check for the REST behaviour, if you desire rest beahaviour
//put a <parameter name="doREST" value="true"/> at the server.xml/client.xml file
Object doREST = msgContext.getProperty(Constants.Configuration.DO_REST);
- XMLStreamReader xmlreader =
- XMLInputFactory.newInstance().createXMLStreamReader(in);
+ XMLStreamReader xmlreader = XMLInputFactory.newInstance().createXMLStreamReader(in);
StAXBuilder builder = null;
SOAPEnvelope envelope = null;
- if (doREST != null
- && "true".equals(doREST)) {
+ if (doREST != null && "true".equals(doREST)) {
SOAPFactory soapFactory = new SOAP11Factory();
builder = new StAXOMBuilder(xmlreader);
builder.setOmbuilderFactory(soapFactory);
@@ -181,8 +169,7 @@
* @return
* @throws AxisFault
*/
- public HashMap parseTheHeaders(Reader reader, boolean serverSide)
- throws AxisFault {
+ public HashMap parseTheHeaders(Reader reader, boolean serverSide) throws AxisFault {
HashMap map = new HashMap();
try {
StringBuffer str = new StringBuffer();
@@ -192,10 +179,7 @@
int start = 0;
length = readLine(reader, buf);
if (serverSide) {
- if ((buf[0] == 'P')
- && (buf[1] == 'O')
- && (buf[2] == 'S')
- && (buf[3] == 'T')) {
+ if ((buf[0] == 'P') && (buf[1] == 'O') && (buf[2] == 'S') && (buf[3] == 'T')) {
index = 5;
value = readFirstLineArg(' ');
map.put(HTTPConstants.REQUEST_URI, value);
@@ -207,9 +191,14 @@
} else {
index = 0;
value = readFirstLineArg(' ');
- map.put(HTTPConstants.PROTOCOL_VERSION, value);
- value = readFirstLineArg(' ');
- map.put(HTTPConstants.RESPONSE_CODE, value);
+ if(value != null && value.indexOf("HTTP") >= 0){
+ map.put(HTTPConstants.PROTOCOL_VERSION, value);
+ value = readFirstLineArg(' ');
+ map.put(HTTPConstants.RESPONSE_CODE, value);
+ }else{
+ map.put(HTTPConstants.RESPONSE_CODE, value);
+ }
+
value = readFirstLineArg('\n');
map.put(HTTPConstants.RESPONSE_WORD, value);
}
@@ -256,8 +245,7 @@
// case END:
// break;
default :
- throw new AxisFault(
- "Error Occured Unknown state " + state);
+ throw new AxisFault("Error Occured Unknown state " + state);
}
}
state = BEFORE_SEPERATOR;
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/SimpleHTTPServer.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/SimpleHTTPServer.java?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/SimpleHTTPServer.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/http/SimpleHTTPServer.java Sun Jun 5 20:53:09 2005
@@ -163,12 +163,14 @@
AxisEngine engine = new AxisEngine(configurationContext);
engine.receive(msgContext);
- if (msgContext.getReplyTo() != null
- && !AddressingConstants.EPR_ANONYMOUS_URL.equals(
- msgContext.getReplyTo().getAddress())) {
+ Object contextWritten =
+ msgContext.getProperty(Constants.RESPONSE_WRITTEN);
+ if (contextWritten == null
+ || !Constants.VALUE_TRUE.equals(contextWritten)) {
out.write(new String(HTTPConstants.NOCONTENT).toCharArray());
out.close();
}
+
log.info("status written");
}
@@ -300,11 +302,12 @@
"http://127.0.0.1:" + (serverSocket.getLocalPort()) + "/axis/services/" + serviceName);
}
- public void init(ConfigurationContext axisConf, TransportInDescription transprtIn) throws AxisFault {
+ public void init(ConfigurationContext axisConf, TransportInDescription transprtIn)
+ throws AxisFault {
this.configurationContext = axisConf;
Parameter param = transprtIn.getParameter(PARAM_PORT);
- if(param!= null){
- int port = Integer.parseInt((String)param.getValue());
+ if (param != null) {
+ int port = Integer.parseInt((String) param.getValue());
serverSocket = ListenerManager.openSocket(port);
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/tcp/TCPServer.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/tcp/TCPServer.java?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/tcp/TCPServer.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/tcp/TCPServer.java Sun Jun 5 20:53:09 2005
@@ -58,6 +58,7 @@
private ConfigurationContext configContext;
protected Log log = LogFactory.getLog(SimpleHTTPServer.class.getName());
+ public TCPServer(){}
public TCPServer(int port, String dir) throws AxisFault {
try {
@@ -151,7 +152,7 @@
public EndpointReference replyToEPR(String serviceName) throws AxisFault {
return new EndpointReference(
AddressingConstants.WSA_REPLY_TO,
- "http://127.0.0.1:" + (serversocket.getLocalPort()) + "/axis/services/" + serviceName);
+ "tcp://127.0.0.1:" + (serversocket.getLocalPort()) + "/axis/services/" + serviceName);
}
/* (non-Javadoc)
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/tcp/TCPTransportSender.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/tcp/TCPTransportSender.java?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/tcp/TCPTransportSender.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/transport/tcp/TCPTransportSender.java Sun Jun 5 20:53:09 2005
@@ -19,6 +19,7 @@
import org.apache.axis.context.MessageContext;
import org.apache.axis.engine.AxisFault;
import org.apache.axis.transport.AbstractTransportSender;
+import org.apache.axis.util.URL;
import java.io.*;
import java.net.*;
Added: webservices/axis/trunk/java/modules/core/src/org/apache/axis/util/URL.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis/util/URL.java?rev=180205&view=auto
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis/util/URL.java (added)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis/util/URL.java Sun Jun 5 20:53:09 2005
@@ -0,0 +1,80 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.
+ *
+ * Runtime state of the engine
+ */
+package org.apache.axis.util;
+
+public class URL {
+ private String protocol;
+ private String host;
+ private int port = -1;
+ private String fileName;
+
+ public URL(String url){
+ int start = 0;
+ int end = 0;
+ end = url.indexOf("://");
+ if(end > 0){
+ protocol = url.substring(0,end);
+ start = end + 3;
+ }
+
+ end = url.indexOf('/',start);
+ if(end > 0){
+ String hostAndPort = url.substring(start,end);
+ fileName = url.substring(end);
+ int index = hostAndPort.indexOf(':');
+ if(index>0){
+ host = hostAndPort.substring(0,index);
+ port = Integer.parseInt(hostAndPort.substring(index+1));
+ }else{
+ host = hostAndPort;
+ }
+ }else{
+ host = url;
+ }
+
+
+ }
+ /**
+ * @return
+ */
+ public String getFileName() {
+ return fileName;
+ }
+
+ /**
+ * @return
+ */
+ public String getHost() {
+ return host;
+ }
+
+ /**
+ * @return
+ */
+ public int getPort() {
+ return port;
+ }
+
+ /**
+ * @return
+ */
+ public String getProtocol() {
+ return protocol;
+ }
+
+}
Modified: webservices/axis/trunk/java/modules/samples/project.xml
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/samples/project.xml?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/samples/project.xml (original)
+++ webservices/axis/trunk/java/modules/samples/project.xml Sun Jun 5 20:53:09 2005
@@ -124,7 +124,7 @@
<exclude>**/*Util*.java</exclude>
<exclude>**/*InteropStubTest.java</exclude>
<exclude>**/*MailEchoRawXMLTest.java</exclude>
- <exclude>**/*OneWayRawXMLTest.java</exclude>
+ <exclude>**/*MailOneWayRawXMLTest.java</exclude>
</excludes>
<includes>
Modified: webservices/axis/trunk/java/modules/samples/test/org/apache/axis/engine/OneWayRawXMLTest.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/samples/test/org/apache/axis/engine/OneWayRawXMLTest.java?rev=180205&r1=180204&r2=180205&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/samples/test/org/apache/axis/engine/OneWayRawXMLTest.java (original)
+++ webservices/axis/trunk/java/modules/samples/test/org/apache/axis/engine/OneWayRawXMLTest.java Sun Jun 5 20:53:09 2005
@@ -19,7 +19,6 @@
//todo
import javax.xml.namespace.QName;
-import javax.xml.stream.XMLOutputFactory;
import junit.framework.TestCase;
@@ -27,10 +26,7 @@
import org.apache.axis.addressing.AddressingConstants;
import org.apache.axis.addressing.EndpointReference;
import org.apache.axis.clientapi.MessageSender;
-import org.apache.axis.context.ConfigurationContext;
-import org.apache.axis.context.ConfigurationContextFactory;
import org.apache.axis.context.MessageContext;
-import org.apache.axis.context.ServiceContext;
import org.apache.axis.description.OperationDescription;
import org.apache.axis.description.ServiceDescription;
import org.apache.axis.integration.UtilServer;
@@ -40,16 +36,15 @@
import org.apache.axis.om.OMNamespace;
import org.apache.axis.soap.SOAPEnvelope;
import org.apache.axis.soap.SOAPFactory;
-import org.apache.axis.transport.mail.SimpleMailListener;
-import org.apache.axis.util.Utils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
public class OneWayRawXMLTest extends TestCase {
private EndpointReference targetEPR =
- new EndpointReference(
- AddressingConstants.WSA_TO,
- "axis2@127.0.0.1" + "/axis/services/EchoXMLService/echoOMElement");
+ new EndpointReference(AddressingConstants.WSA_TO,
+ "http://127.0.0.1:"
+ + (UtilServer.TESTING_PORT)
+ + "/axis/services/EchoXMLService/echoOMElement");
private Log log = LogFactory.getLog(getClass());
private QName serviceName = new QName("EchoXMLService");
private QName operationName = new QName("echoOMElement");
@@ -71,15 +66,7 @@
}
protected void setUp() throws Exception {
- SimpleMailListener ml = new SimpleMailListener();
- ConfigurationContextFactory builder = new ConfigurationContextFactory();
- ConfigurationContext configContext =
- builder.buildEngineContext(org.apache.axis.Constants.TESTING_REPOSITORY);
- ml.init(
- configContext,
- configContext.getAxisConfiguration().getTransportIn(
- new QName(Constants.TRANSPORT_MAIL)));
- ml.start();
+ UtilServer.start();
ServiceDescription service = new ServiceDescription(serviceName);
OperationDescription operation = new OperationDescription(operationName);
@@ -88,12 +75,14 @@
envelope = messgeCtx.getEnvelope();
}
});
+ service.addOperation(operation);
+ UtilServer.deployService(service);
+ }
- configContext.getAxisConfiguration().addService(service);
- Utils.resolvePhases(configContext.getAxisConfiguration(), service);
- }
-
+
protected void tearDown() throws Exception {
+ UtilServer.unDeployService(serviceName);
+ UtilServer.stop();
}
private OMElement createEnvelope() {
@@ -115,11 +104,16 @@
MessageSender sender = new MessageSender();
sender.setTo(targetEPR);
- sender.setSenderTransport(Constants.TRANSPORT_MAIL);
+ sender.setSenderTransport(Constants.TRANSPORT_HTTP);
sender.send(operationName.getLocalPart(), payload);
- while(envelope != null){
+ int index = 0;
+ while(envelope == null){
Thread.sleep(4000);
+ index ++;
+ if(index == 5){
+ throw new AxisFault("error Occured");
+ }
}
}
Added: webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/MailOneWayRawXMLTest.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/MailOneWayRawXMLTest.java?rev=180205&view=auto
==============================================================================
--- webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/MailOneWayRawXMLTest.java (added)
+++ webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/MailOneWayRawXMLTest.java Sun Jun 5 20:53:09 2005
@@ -0,0 +1,221 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.axis.mail;
+
+//todo
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLOutputFactory;
+import javax.xml.stream.XMLStreamException;
+
+import junit.framework.TestCase;
+
+import org.apache.axis.Constants;
+import org.apache.axis.addressing.AddressingConstants;
+import org.apache.axis.addressing.EndpointReference;
+import org.apache.axis.clientapi.AsyncResult;
+import org.apache.axis.clientapi.Callback;
+import org.apache.axis.clientapi.MessageSender;
+import org.apache.axis.context.ConfigurationContext;
+import org.apache.axis.context.ConfigurationContextFactory;
+import org.apache.axis.context.MessageContext;
+import org.apache.axis.context.ServiceContext;
+import org.apache.axis.deployment.DeploymentException;
+import org.apache.axis.description.OperationDescription;
+import org.apache.axis.description.Parameter;
+import org.apache.axis.description.ParameterImpl;
+import org.apache.axis.description.ServiceDescription;
+import org.apache.axis.description.TransportInDescription;
+import org.apache.axis.description.TransportOutDescription;
+import org.apache.axis.engine.AxisConfiguration;
+import org.apache.axis.engine.AxisFault;
+import org.apache.axis.engine.MessageReceiver;
+import org.apache.axis.om.OMAbstractFactory;
+import org.apache.axis.om.OMElement;
+import org.apache.axis.om.OMFactory;
+import org.apache.axis.om.OMNamespace;
+import org.apache.axis.soap.SOAPEnvelope;
+import org.apache.axis.soap.SOAPFactory;
+import org.apache.axis.transport.mail.MailTransportSender;
+import org.apache.axis.transport.mail.SimpleMailListener;
+import org.apache.axis.util.Utils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+public class MailOneWayRawXMLTest extends TestCase {
+ private EndpointReference targetEPR =
+ new EndpointReference(
+ AddressingConstants.WSA_TO,
+ "axis2@127.0.0.1" + "/axis/services/EchoXMLService/echoOMElement");
+ private Log log = LogFactory.getLog(getClass());
+ private QName serviceName = new QName("EchoXMLService");
+ private QName operationName = new QName("echoOMElement");
+ private QName transportName = new QName("http://localhost/my", "NullTransport");
+
+
+ private AxisConfiguration engineRegistry;
+ private MessageContext mc;
+
+ private SOAPEnvelope envelope;
+
+ private boolean finish = false;
+
+ public MailOneWayRawXMLTest() {
+ super(MailOneWayRawXMLTest.class.getName());
+ }
+
+ public MailOneWayRawXMLTest(String testName) {
+ super(testName);
+ }
+
+ protected void setUp() throws Exception {
+ SimpleMailListener ml = new SimpleMailListener();
+
+ ConfigurationContext configContext = createConfigurationContext();
+ ml.init(
+ configContext,
+ configContext.getAxisConfiguration().getTransportIn(
+ new QName(Constants.TRANSPORT_MAIL)));
+ ml.start();
+
+ ServiceDescription service = new ServiceDescription(serviceName);
+ OperationDescription operation = new OperationDescription(operationName);
+ operation.setMessageReciever(new MessageReceiver() {
+ public void recieve(MessageContext messgeCtx) throws AxisFault {
+ envelope = messgeCtx.getEnvelope();
+ }
+ });
+ service.addOperation(operation);
+ configContext.getAxisConfiguration().addService(service);
+ Utils.resolvePhases(configContext.getAxisConfiguration(), service);
+ ServiceContext serviceContext = configContext.createServiceContext(serviceName);
+ }
+
+ protected void tearDown() throws Exception {
+ }
+
+ private OMElement createEnvelope() {
+ OMFactory fac = OMAbstractFactory.getOMFactory();
+ OMNamespace omNs = fac.createOMNamespace("http://localhost/my", "my");
+ OMElement method = fac.createOMElement("echoOMElement", omNs);
+ OMElement value = fac.createOMElement("myValue", omNs);
+ value.addChild(fac.createText(value, "Isaac Assimov, the foundation Sega"));
+ method.addChild(value);
+
+ return method;
+ }
+
+ public void testOneWay() throws Exception {
+ ConfigurationContext configContext = createConfigurationContext();
+ ServiceDescription service = new ServiceDescription(serviceName);
+ OperationDescription operation = new OperationDescription(operationName);
+ operation.setMessageReciever(new MessageReceiver() {
+ public void recieve(MessageContext messgeCtx) throws AxisFault {
+ envelope = messgeCtx.getEnvelope();
+ }
+ });
+ service.addOperation(operation);
+ configContext.getAxisConfiguration().addService(service);
+ Utils.resolvePhases(configContext.getAxisConfiguration(), service);
+ ServiceContext serviceContext = configContext.createServiceContext(serviceName);
+
+ SOAPFactory fac = OMAbstractFactory.getSOAP11Factory();
+
+ OMElement payload = createEnvelope();
+
+ MessageSender sender = new MessageSender(serviceContext);
+
+ sender.setTo(targetEPR);
+ sender.setSenderTransport(Constants.TRANSPORT_MAIL);
+
+ sender.send(operationName.getLocalPart(), payload);
+ while (envelope == null) {
+ Thread.sleep(4000);
+ }
+ }
+
+ // public void testEchoXMLCompleteASync() throws Exception {
+ //
+ //
+ // org.apache.axis.clientapi.Call call = new org.apache.axis.clientapi.Call();
+ // call.engageModule(new QName(Constants.MODULE_ADDRESSING));
+ //
+ // try {
+ // call.setTo(targetEPR);
+ // call.setTransportInfo(Constants.TRANSPORT_MAIL, Constants.TRANSPORT_MAIL, true);
+ // Callback callback = new Callback() {
+ // public void onComplete(AsyncResult result) {
+ // try {
+ // result.getResponseEnvelope().serialize(
+ // XMLOutputFactory.newInstance().createXMLStreamWriter(System.out));
+ // } catch (XMLStreamException e) {
+ // reportError(e);
+ // } finally {
+ // finish = true;
+ // }
+ // }
+ //
+ // public void reportError(Exception e) {
+ // e.printStackTrace();
+ // finish = true;
+ // }
+ // };
+ //
+ // call.invokeNonBlocking(operationName.getLocalPart(), createEnvelope(), callback);
+ // int index = 0;
+ // while (!finish) {
+ // Thread.sleep(1000);
+ // index++;
+ // if (index > 10) {
+ // throw new AxisFault("Server is shutdown as the Async response take too longs time");
+ // }
+ // }
+ // } finally {
+ // call.close();
+ // }
+ //
+ // }
+ public ConfigurationContext createConfigurationContext() throws Exception {
+ ConfigurationContextFactory builder = new ConfigurationContextFactory();
+ ConfigurationContext configContext =
+ builder.buildEngineContext(org.apache.axis.Constants.TESTING_REPOSITORY);
+
+ TransportInDescription transportIn =
+ new TransportInDescription(new QName(Constants.TRANSPORT_MAIL));
+ transportIn.addParameter(new ParameterImpl("transport.mail.pop3.host", "127.0.0.1"));
+ transportIn.addParameter(new ParameterImpl("transport.mail.pop3.user", "axis2"));
+ transportIn.addParameter(new ParameterImpl("transport.mail.pop3.password", "axis2"));
+ transportIn.addParameter(new ParameterImpl("transport.mail.pop3.port", "110"));
+ transportIn.addParameter(
+ new ParameterImpl("transport.mail.replyToAddress", "axis2@127.0.0.1"));
+ transportIn.setReciver(new SimpleMailListener());
+
+ TransportOutDescription transportOut =
+ new TransportOutDescription(new QName(Constants.TRANSPORT_MAIL));
+
+ transportOut.addParameter(new ParameterImpl("transport.mail.smtp.host", "127.0.0.1"));
+ transportOut.addParameter(new ParameterImpl("transport.mail.smtp.user", "axis2"));
+ transportOut.addParameter(new ParameterImpl("transport.mail.smtp.password", "axis2"));
+ transportOut.addParameter(new ParameterImpl("transport.mail.smtp.port", "25"));
+ transportOut.setSender(new MailTransportSender());
+
+ configContext.getAxisConfiguration().addTransportIn(transportIn);
+ configContext.getAxisConfiguration().addTransportOut(transportOut);
+ return configContext;
+ }
+
+}
Added: webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/mail-enabled-client.xml
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/mail-enabled-client.xml?rev=180205&view=auto
==============================================================================
--- webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/mail-enabled-client.xml (added)
+++ webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/mail-enabled-client.xml Sun Jun 5 20:53:09 2005
@@ -0,0 +1,67 @@
+<client name="AxisJava2.0">
+ <!-- ================================================= -->
+ <!-- Parameters -->
+ <!-- ================================================= -->
+ <parameter name="hotdeployment" locked="xsd:false">true</parameter>
+ <parameter name="hotupdate" locked="xsd:false">true</parameter>
+ <!-- Uncomment this to enable REST support -->
+ <parameter name="eanbleREST" locked="xsd:false">true</parameter>
+ <parameter name="userName" locked="xsd:false">Axis2admin</parameter>
+ <parameter name="password" locked="xsd:false">changeMe</parameter>
+
+ <!-- ================================================= -->
+ <!-- Message Receivers -->
+ <!-- ================================================= -->
+ <!-- This is the Deafult Message Receiver for the Request Response style Operations -->
+ <messageReceiver mep="INOUT" class="org.apache.axis.receivers.RawXMLINOutMessageRecevier"/>
+
+ <transportReceiver name="http" class="org.apache.axis.transport.http.SimpleHTTPServer">
+ <parameter name="port" locked="xsd:false">6060</parameter>
+ </transportReceiver>
+
+ <transportSender name="http" class="org.apache.axis.transport.http.HTTPTransportSender">
+ </transportSender>
+
+ <transportReceiver name="tcp" class="org.apache.axis.transport.http.SimpleHTTPServer">
+ <parameter name="port" locked="xsd:false">6060</parameter>
+ </transportReceiver>
+ <transportSender name="tcp" class="org.apache.axis.transport.tcp.TCPTransportSender"/>
+
+ <transportReceiver name="local">
+ <parameter name="port" locked="xsd:false">6060</parameter>
+ </transportReceiver>
+ <transportSender name="local" class="org.apache.axis.transport.local.LocalTransportSender"/>
+
+<!--
+ <transportReceiver name="mail" class="org.apache.axis.transport.mail.SimpleMailListener">
+ <parameter name="transport.mail.pop3.host" locked="xsd:false">mail.itambalama.com</parameter>
+ <parameter name="transport.mail.pop3.user" locked="xsd:false">axis2.mail.test@itambalama.com</parameter>
+ <parameter name="transport.mail.pop3.password" locked="xsd:false">2sixa.mail</parameter>
+ <parameter name="transport.mail.pop3.port" locked="xsd:false">110</parameter>
+ <parameter name="transport.mail.replyToAddress" locked="xsd:false">axis2.mail.test@itambalama.com</parameter>
+ </transportReceiver>
+ <transportSender name="mail" class="org.apache.axis.transport.mail.MailTransportSender">
+ <parameter name="transport.mail.smtp.host" locked="xsd:false">mail.itambalama.com</parameter>
+ <parameter name="transport.mail.smtp.user" locked="xsd:false">axis2.mail.test</parameter>
+ <parameter name="transport.mail.smtp.password" locked="xsd:false">2sixa.mail</parameter>
+ <parameter name="transport.mail.smtp.port" locked="xsd:false">25</parameter>
+ </transportSender>
+-->
+
+<transportReceiver name="mail" class="org.apache.axis.transport.mail.SimpleMailListener">
+ <parameter name="transport.mail.pop3.host" locked="xsd:false">127.0.0.1</parameter>
+ <parameter name="transport.mail.pop3.user" locked="xsd:false">axis2</parameter>
+ <parameter name="transport.mail.pop3.password" locked="xsd:false">axis2</parameter>
+ <parameter name="transport.mail.pop3.port" locked="xsd:false">110</parameter>
+ <parameter name="transport.mail.replyToAddress" locked="xsd:false">axis2@127.0.0.1</parameter>
+ </transportReceiver>
+ <transportSender name="mail" class="org.apache.axis.transport.mail.MailTransportSender">
+ <parameter name="transport.mail.smtp.host" locked="xsd:false">127.0.0.1</parameter>
+ <parameter name="transport.mail.smtp.user" locked="xsd:false">axis2</parameter>
+ <parameter name="transport.mail.smtp.password" locked="xsd:false">axis2</parameter>
+ <parameter name="transport.mail.smtp.port" locked="xsd:false">25</parameter>
+ </transportSender>
+
+
+</client>
+
Added: webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/mail-enabled-server.xml
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/mail-enabled-server.xml?rev=180205&view=auto
==============================================================================
--- webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/mail-enabled-server.xml (added)
+++ webservices/axis/trunk/java/modules/samples/test/org/apache/axis/mail/mail-enabled-server.xml Sun Jun 5 20:53:09 2005
@@ -0,0 +1,89 @@
+<server name="AxisJava2.0">
+ <!-- ================================================= -->
+ <!-- Parameters -->
+ <!-- ================================================= -->
+ <parameter name="hotdeployment" locked="xsd:false">true</parameter>
+ <parameter name="hotupdate" locked="xsd:false">true</parameter>
+ <!-- Uncomment this to enable REST support -->
+ <parameter name="eanbleREST" locked="xsd:false">true</parameter>
+ <parameter name="userName" locked="xsd:false">Axis2admin</parameter>
+ <parameter name="password" locked="xsd:false">changeMe</parameter>
+
+ <!-- ================================================= -->
+ <!-- Message Receivers -->
+ <!-- ================================================= -->
+ <!-- This is the Deafult Message Receiver for the Request Response style Operations -->
+ <messageReceiver mep="INOUT" class="org.apache.axis.receivers.RawXMLINOutMessageRecevier"/>
+
+ <!-- ================================================= -->
+ <!-- Transport Ins -->
+ <!-- ================================================= -->
+ <transportReceiver name="http" class="org.apache.axis.transport.http.SimpleHTTPServer">
+ <parameter name="port" locked="xsd:false">6060</parameter>
+ </transportReceiver>
+
+ <!-- Uncomment this one with the appropriate papameters to enable the SMTP transport Receiver
+ <transportReceiver name="mail" class="org.apache.axis.transport.mail.SimpleMailListener">
+ <parameter name="transport.mail.pop3.host" locked="xsd:false">127.0.0.1</parameter>
+ <parameter name="transport.mail.pop3.user" locked="xsd:false">axis2</parameter>
+ <parameter name="transport.mail.pop3.password" locked="xsd:false">axis2</parameter>
+ <parameter name="transport.mail.pop3.port" locked="xsd:false">110</parameter>
+ <parameter name="transport.mail.replyToAddress" locked="xsd:false">axis2@127.0.0.1</parameter>
+ </transportReceiver> -->
+
+ <transportReceiver name="tcp" class="org.apache.axis.transport.tcp.TCPServer">
+ <parameter name="port" locked="xsd:false">6060</parameter>
+ </transportReceiver>
+
+ <!-- ================================================= -->
+ <!-- Transport Outs -->
+ <!-- ================================================= -->
+
+ <transportSender name="http" class="org.apache.axis.transport.http.HTTPTransportSender"/>
+ <transportSender name="tcp" class="org.apache.axis.transport.tcp.TCPTransportSender"/>
+ <transportSender name="local" class="org.apache.axis.transport.local.LocalTransportSender"/>
+
+ <!-- Uncomment this one with the appropriate papameters to enable the SMTP transport Receiver
+ <transportSender name="mail" class="org.apache.axis.transport.mail.MailTransportSender">
+ <parameter name="transport.mail.smtp.host" locked="xsd:false">127.0.0.1</parameter>
+ <parameter name="transport.mail.smtp.user" locked="xsd:false">axis2</parameter>
+ <parameter name="transport.mail.smtp.password" locked="xsd:false">axis2</parameter>
+ <parameter name="transport.mail.smtp.port" locked="xsd:false">25</parameter>
+ </transportSender>
+ -->
+
+ <!-- ================================================= -->
+ <!-- Global Modules -->
+ <!-- ================================================= -->
+ <!-- Uncomment this to enable Addressing
+ <module ref="addressing"/> -->
+
+ <!-- ================================================= -->
+ <!-- Phases -->
+ <!-- ================================================= -->
+ <phaseOrder type="inflow">
+ <!-- System pre defined phases -->
+ <phase name="TransportIn"/>
+ <phase name="PreDispatch"/>
+ <phase name="Dispatch"/>
+ <phase name="PostDispatch"/>
+ <!-- System pre defined phases -->
+ <!-- After Postdispatch phase module author or or service author can add any phase he want -->
+ <phase name="userphase1"/>
+ </phaseOrder>
+ <phaseOrder type="outflow">
+ <!-- user can add his own phases to this area -->
+ <phase name="userphase1"/>
+ <!-- This is temporray solution will be change soon-->
+ <phase name="addressing"/>
+ </phaseOrder>
+ <phaseOrder type="INfaultflow">
+ <!-- user can add his own phases to this area -->
+ <phase name="userphase1"/>
+ </phaseOrder>
+ <phaseOrder type="Outfaultflow">
+ <!-- user can add his own phases to this area -->
+ <phase name="userphase1"/>
+ </phaseOrder>
+</server>
+