Menu
▾
▴
[Jboss-svn-commits] JBL Code SVN: r4669 - in labs/jbosstm/trunk/XTS: WS-C/dev/dd WS-C/dev/src/com/arjuna/services/framework/admin WS-C/dev/src/com/arjuna/services/framework/task WS-C/dev/src/com/arjuna/webservices/transport/http coordinator/dd demo/dd/webmethods
|
From: <jbo...@li...> - 2006-06-08 10:39:42
|
Author: kev...@jb...
Date: 2006-06-08 05:42:29 -0400 (Thu, 08 Jun 2006)
New Revision: 4669
Added:
labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/services/framework/admin/TaskManagerInitialisation.java
Modified:
labs/jbosstm/trunk/XTS/WS-C/dev/dd/ws-c_web-app.xml
labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/services/framework/task/TaskManager.java
labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpClient.java
labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpClientInitialisation.java
labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpServiceMultiplexorServlet.java
labs/jbosstm/trunk/XTS/coordinator/dd/webMethods-web-app.xml
labs/jbosstm/trunk/XTS/demo/dd/webmethods/web-app.xml
Log:
Add task manager and packet logging configuration
Modified: labs/jbosstm/trunk/XTS/WS-C/dev/dd/ws-c_web-app.xml
===================================================================
--- labs/jbosstm/trunk/XTS/WS-C/dev/dd/ws-c_web-app.xml 2006-06-08 09:34:09 UTC (rev 4668)
+++ labs/jbosstm/trunk/XTS/WS-C/dev/dd/ws-c_web-app.xml 2006-06-08 09:42:29 UTC (rev 4669)
@@ -26,6 +26,19 @@
<description>Arjuna Web Services and WS-Coordination</description>
+ <!-- Initialise the Task Manager -->
+ <context-param>
+ <param-name>TaskManager.minWorkerCount</param-name>
+ <param-value>0</param-value>
+ </context-param>
+ <context-param>
+ <param-name>TaskManager.maxWorkerCount</param-name>
+ <param-value>10</param-value>
+ </context-param>
+ <listener>
+ <listener-class>com.arjuna.services.framework.admin.TaskManagerInitialisation</listener-class>
+ </listener>
+
<!-- Initialise WS-C services -->
<listener>
<listener-class>com.arjuna.webservices.wscoor.server.ActivationCoordinatorInitialisation</listener-class>
@@ -67,6 +80,10 @@
<param-name>BaseHttpsURI</param-name>
<param-value>https://@hostname@:@port@/xts/soap/</param-value>
</init-param>
+ <init-param>
+ <param-name>LogPackets</param-name>
+ <param-value>true</param-value>
+ </init-param>
-->
<load-on-startup>1</load-on-startup>
</servlet>
Added: labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/services/framework/admin/TaskManagerInitialisation.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/services/framework/admin/TaskManagerInitialisation.java 2006-06-08 09:34:09 UTC (rev 4668)
+++ labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/services/framework/admin/TaskManagerInitialisation.java 2006-06-08 09:42:29 UTC (rev 4669)
@@ -0,0 +1,85 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2006, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. All rights reserved.
+ * See the copyright.txt in the distribution for a full listing
+ * of individual contributors.
+ * This copyrighted material is made available to anyone wishing to use,
+ * modify, copy, or redistribute it subject to the terms and conditions
+ * of the GNU General Public License, v. 2.0.
+ * This program is distributed in the hope that it will be useful, but WITHOUT A
+ * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
+ * PARTICULAR PURPOSE. See the GNU General Public License for more details.
+ * You should have received a copy of the GNU General Public License,
+ * v. 2.0 along with this distribution; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
+ * MA 02110-1301, USA.
+ *
+ * (C) 2005-2006,
+ * @author JBoss Inc.
+ */
+package com.arjuna.services.framework.admin;
+
+import javax.servlet.ServletContext;
+import javax.servlet.ServletContextEvent;
+import javax.servlet.ServletContextListener;
+
+import com.arjuna.services.framework.task.TaskManager;
+import com.arjuna.webservices.logging.WSCLogger;
+
+/**
+ * Context listener used to initialise the Task Manager.
+ * @author kevin
+ */
+public class TaskManagerInitialisation implements ServletContextListener
+{
+ /**
+ * The context has been initialized.
+ * @param servletContextEvent The sevlet context event.
+ * @message com.arjuna.services.framework.admin.TaskManagerInitialisation_1 [com.arjuna.services.framework.admin.TaskManagerInitialisation_1] -
+ * Invalid minimum worker count.
+ * @message com.arjuna.services.framework.admin.TaskManagerInitialisation_2 [com.arjuna.services.framework.admin.TaskManagerInitialisation_2] -
+ * Invalid maximum worker count.
+ */
+ public void contextInitialized(final ServletContextEvent servletContextEvent)
+ {
+ final ServletContext servletContext = servletContextEvent.getServletContext() ;
+ final String minWorkerCountParam = servletContext.getInitParameter("TaskManager.minWorkerCount") ;
+ final String maxWorkerCountParam = servletContext.getInitParameter("TaskManager.maxWorkerCount") ;
+
+ final TaskManager taskManager = TaskManager.getManager() ;
+ if (minWorkerCountParam != null)
+ {
+ try
+ {
+ final int minWorkerCount = Integer.parseInt(minWorkerCountParam) ;
+ taskManager.setMinimumWorkerCount(minWorkerCount) ;
+ }
+ catch (final NumberFormatException nfe)
+ {
+ WSCLogger.arjLoggerI18N.debug("com.arjuna.services.framework.admin.TaskManagerInitialisation_1") ;
+ }
+ }
+ if (maxWorkerCountParam != null)
+ {
+ try
+ {
+ final int maxWorkerCount = Integer.parseInt(maxWorkerCountParam) ;
+ taskManager.setMaximumWorkerCount(maxWorkerCount) ;
+ }
+ catch (final NumberFormatException nfe)
+ {
+ WSCLogger.arjLoggerI18N.debug("com.arjuna.services.framework.admin.TaskManagerInitialisation_2") ;
+ }
+ }
+ }
+
+ /**
+ * The context is about to be destroyed.
+ * @param servletContextEvent The servlet context event.
+ */
+ public void contextDestroyed(final ServletContextEvent servletContextEvent)
+ {
+ TaskManager.getManager().shutdown() ;
+ }
+}
Modified: labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/services/framework/task/TaskManager.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/services/framework/task/TaskManager.java 2006-06-08 09:34:09 UTC (rev 4668)
+++ labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/services/framework/task/TaskManager.java 2006-06-08 09:42:29 UTC (rev 4669)
@@ -118,7 +118,7 @@
*/
public boolean queueTask(final Task task)
{
- final boolean debugEnabled = WSCLogger.arjLoggerI18N.debugAllowed() ;
+ final boolean debugEnabled = WSCLogger.arjLoggerI18N.isDebugEnabled() ;
synchronized(workerPool)
{
if (shutdown)
@@ -182,7 +182,7 @@
*/
public void setMinimumWorkerCount(final int minimumWorkerCount)
{
- final boolean debugEnabled = WSCLogger.arjLoggerI18N.debugAllowed() ;
+ final boolean debugEnabled = WSCLogger.arjLoggerI18N.isDebugEnabled() ;
synchronized(workerPool)
{
if (shutdown)
@@ -251,7 +251,7 @@
*/
public void setMaximumWorkerCount(final int maximumWorkerCount)
{
- final boolean debugEnabled = WSCLogger.arjLoggerI18N.debugAllowed() ;
+ final boolean debugEnabled = WSCLogger.arjLoggerI18N.isDebugEnabled() ;
synchronized(workerPool)
{
if (shutdown)
@@ -325,7 +325,7 @@
*/
public void shutdown()
{
- final boolean debugEnabled = WSCLogger.arjLoggerI18N.debugAllowed() ;
+ final boolean debugEnabled = WSCLogger.arjLoggerI18N.isDebugEnabled() ;
synchronized(workerPool)
{
@@ -403,7 +403,7 @@
*/
Task getTask()
{
- final boolean debugEnabled = WSCLogger.arjLoggerI18N.debugAllowed() ;
+ final boolean debugEnabled = WSCLogger.arjLoggerI18N.isDebugEnabled() ;
while(true)
{
Modified: labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpClient.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpClient.java 2006-06-08 09:34:09 UTC (rev 4668)
+++ labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpClient.java 2006-06-08 09:42:29 UTC (rev 4669)
@@ -22,6 +22,7 @@
import java.io.BufferedInputStream;
import java.io.IOException;
+import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
@@ -116,11 +117,17 @@
throw new SoapFault(SoapFaultType.FAULT_SENDER, WSCLogger.log_mesg.getString("com.arjuna.webservices.transport.http.HttpClient_2")) ;
}
- final String requestContents = serialiseRequest(request) ;
- if (SoapMessageLogging.isThreadLogEnabled())
+ final boolean threadLogEnabled = SoapMessageLogging.isThreadLogEnabled() ;
+ final String requestContents ;
+ if (threadLogEnabled)
{
+ requestContents = serialiseRequest(request) ;
SoapMessageLogging.appendThreadLog(requestContents) ;
}
+ else
+ {
+ requestContents = null ;
+ }
final HttpURLConnection httpURLConnection ;
try
@@ -132,105 +139,122 @@
throw new SoapFault(SoapFaultType.FAULT_SENDER, WSCLogger.log_mesg.getString("com.arjuna.webservices.transport.http.HttpClient_3")) ;
}
- try
+ httpURLConnection.setDoOutput(true) ;
+ httpURLConnection.setUseCaches(false) ;
+
+ final int numHeaders = HTTP_HEADERS.length ;
+ for(int count = 0 ; count < numHeaders ; count++)
{
- httpURLConnection.setDoOutput(true) ;
- httpURLConnection.setUseCaches(false) ;
-
- final int numHeaders = HTTP_HEADERS.length ;
- for(int count = 0 ; count < numHeaders ; count++)
- {
- final String[] header = HTTP_HEADERS[count] ;
- httpURLConnection.setRequestProperty(header[0], header[1]) ;
- }
-
- final SoapDetails soapDetails = request.getSoapDetails() ;
- final String contentType = HttpUtils.getContentType(soapDetails) ;
- httpURLConnection.setRequestProperty(HttpUtils.HTTP_CONTENT_TYPE_HEADER, contentType + HttpUtils.HTTP_DEFAULT_CHARSET_PARAMETER) ;
- httpURLConnection.setRequestProperty(HttpUtils.HTTP_ACCEPT_HEADER, contentType) ;
-
- final String requestAction = request.getAction() ;
- final String actionValue = (requestAction == null ? "" : requestAction) ;
-
- // KEV - fix action handling for different SOAP versions
- httpURLConnection.setRequestProperty(HttpUtils.SOAP_ACTION_HEADER, '"' + actionValue + '"') ;
-
+ final String[] header = HTTP_HEADERS[count] ;
+ httpURLConnection.setRequestProperty(header[0], header[1]) ;
+ }
+
+ final SoapDetails soapDetails = request.getSoapDetails() ;
+ final String contentType = HttpUtils.getContentType(soapDetails) ;
+ httpURLConnection.setRequestProperty(HttpUtils.HTTP_CONTENT_TYPE_HEADER, contentType + HttpUtils.HTTP_DEFAULT_CHARSET_PARAMETER) ;
+ httpURLConnection.setRequestProperty(HttpUtils.HTTP_ACCEPT_HEADER, contentType) ;
+
+ final String requestAction = request.getAction() ;
+ final String actionValue = (requestAction == null ? "" : requestAction) ;
+
+ // KEV - fix action handling for different SOAP versions
+ httpURLConnection.setRequestProperty(HttpUtils.SOAP_ACTION_HEADER, '"' + actionValue + '"') ;
+
+ if (requestContents != null)
+ {
httpURLConnection.setRequestProperty(HttpUtils.HTTP_CONTENT_LENGTH_HEADER,
Integer.toString(requestContents.length())) ;
-
- final int port = serviceURL.getPort() ;
- final String host = (port > 0 ? serviceURL.getHost() + ":" + port : serviceURL.getHost()) ;
- httpURLConnection.setRequestProperty(HttpUtils.HTTP_HOST_HEADER, host) ;
- httpURLConnection.setRequestProperty(HttpUtils.HTTP_CONNECTION_HEADER, "close") ;
- httpURLConnection.setRequestMethod("POST") ;
-
- httpURLConnection.connect() ;
- final OutputStream os = httpURLConnection.getOutputStream() ;
+ }
+
+ final int port = serviceURL.getPort() ;
+ final String host = (port > 0 ? serviceURL.getHost() + ":" + port : serviceURL.getHost()) ;
+ httpURLConnection.setRequestProperty(HttpUtils.HTTP_HOST_HEADER, host) ;
+ httpURLConnection.setRequestMethod("POST") ;
+
+ httpURLConnection.connect() ;
+ final OutputStream os = httpURLConnection.getOutputStream() ;
+ try
+ {
final PrintWriter writer = new PrintWriter(os) ;
- writer.print(requestContents) ;
- writer.flush() ;
-
- final int responseCode = httpURLConnection.getResponseCode() ;
-
- if ((responseCode != HttpURLConnection.HTTP_OK) &&
- (responseCode != HttpURLConnection.HTTP_ACCEPTED) &&
- (responseCode != HttpURLConnection.HTTP_INTERNAL_ERROR))
+ if (requestContents != null)
{
- final String pattern = WSCLogger.log_mesg.getString("com.arjuna.webservices.transport.http.HttpClient_4") ;
- final String message = MessageFormat.format(pattern, new Object[] {new Integer(responseCode)}) ;
- throw new SoapFault(SoapFaultType.FAULT_SENDER, message) ;
+ writer.print(requestContents) ;
}
-
- final String fullResponseContentType = httpURLConnection.getContentType() ;
-// final String responseContentType = HttpUtils.getContentType(fullResponseContentType) ;
- // Ignore responses that aren't the same version of SOAP
-// if ((contentType != null) && !contentType.equals(responseContentType))
+ else
+ {
+ request.output(writer) ;
+ }
+ writer.flush() ;
+ }
+ finally
+ {
+ os.close() ;
+ }
+
+ final int responseCode = httpURLConnection.getResponseCode() ;
+
+ if ((responseCode != HttpURLConnection.HTTP_OK) &&
+ (responseCode != HttpURLConnection.HTTP_ACCEPTED) &&
+ (responseCode != HttpURLConnection.HTTP_INTERNAL_ERROR))
+ {
+ final String pattern = WSCLogger.log_mesg.getString("com.arjuna.webservices.transport.http.HttpClient_4") ;
+ final String message = MessageFormat.format(pattern, new Object[] {new Integer(responseCode)}) ;
+ throw new SoapFault(SoapFaultType.FAULT_SENDER, message) ;
+ }
+
+ final String fullResponseContentType = httpURLConnection.getContentType() ;
+// final String responseContentType = HttpUtils.getContentType(fullResponseContentType) ;
+ // Ignore responses that aren't the same version of SOAP
+// if ((contentType != null) && !contentType.equals(responseContentType))
+// {
+// if (threadLogEnabled)
// {
-// if (SoapMessageLogging.isThreadLogEnabled())
-// {
-// SoapMessageLogging.appendThreadLog(null) ;
-// }
-// return null ;
+// SoapMessageLogging.appendThreadLog(null) ;
// }
-
- final int contentLength = httpURLConnection.getContentLength() ;
- if (contentLength == 0)
+// return null ;
+// }
+
+ final int contentLength = httpURLConnection.getContentLength() ;
+ if (contentLength == 0)
+ {
+ if (threadLogEnabled)
{
- if (SoapMessageLogging.isThreadLogEnabled())
- {
- SoapMessageLogging.appendThreadLog(null) ;
- }
- return null ;
+ SoapMessageLogging.appendThreadLog(null) ;
}
-
- final SoapService soapService = request.getSoapService() ;
- final String encoding = HttpUtils.getContentTypeEncoding(fullResponseContentType) ;
- final BufferedInputStream bis ;
- if (responseCode == HttpURLConnection.HTTP_INTERNAL_ERROR)
- {
- bis = new BufferedInputStream(httpURLConnection.getErrorStream()) ;
- }
- else
- {
- bis = new BufferedInputStream(httpURLConnection.getInputStream()) ;
- }
+ return null ;
+ }
+
+ final SoapService soapService = request.getSoapService() ;
+ final String encoding = HttpUtils.getContentTypeEncoding(fullResponseContentType) ;
+ final InputStream is ;
+ if (responseCode == HttpURLConnection.HTTP_INTERNAL_ERROR)
+ {
+ is = httpURLConnection.getErrorStream() ;
+ }
+ else
+ {
+ is = httpURLConnection.getInputStream() ;
+ }
+ try
+ {
+ final BufferedInputStream bis = new BufferedInputStream(is) ;
final InputStreamReader isr = (encoding == null ? new InputStreamReader(bis) : new InputStreamReader(bis, encoding)) ;
final Reader reader ;
- if ((contentLength <= 0) || SoapMessageLogging.isThreadLogEnabled())
+ if (threadLogEnabled || (contentLength <= 0))
{
final String responseContents = readStream(isr) ;
if (responseContents.length() == 0)
{
- if (SoapMessageLogging.isThreadLogEnabled())
+ if (threadLogEnabled)
{
SoapMessageLogging.appendThreadLog(null) ;
}
return null ;
}
- if (SoapMessageLogging.isThreadLogEnabled())
+ if (threadLogEnabled)
{
SoapMessageLogging.appendThreadLog(responseContents) ;
}
@@ -256,7 +280,7 @@
}
finally
{
- httpURLConnection.disconnect() ;
+ is.close() ;
}
}
@@ -283,30 +307,7 @@
break ;
}
}
- checkForXMLDecl(stringBuffer) ;
return stringBuffer.toString() ;
}
-
- private static void checkForXMLDecl(final StringBuffer buffer)
- {
- int count = 0 ;
- try
- {
- while(Character.isWhitespace(buffer.charAt(count))) count++ ;
- if (buffer.charAt(count) == '<')
- {
- if (buffer.charAt(count+1) == '?')
- {
- count+=2 ;
- while(buffer.charAt(count++) != '>') ;
- }
- }
- if (count > 0)
- {
- buffer.delete(0, count) ;
- }
- }
- catch (final StringIndexOutOfBoundsException sioobe) {}
- }
}
Modified: labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpClientInitialisation.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpClientInitialisation.java 2006-06-08 09:34:09 UTC (rev 4668)
+++ labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpClientInitialisation.java 2006-06-08 09:42:29 UTC (rev 4669)
@@ -50,5 +50,8 @@
*/
public void contextDestroyed(final ServletContextEvent servletContextEvent)
{
+ final SoapRegistry soapRegistry = SoapRegistry.getRegistry() ;
+ soapRegistry.removeSoapClient(HttpUtils.HTTPS_SCHEME) ;
+ soapRegistry.removeSoapClient(HttpUtils.HTTP_SCHEME) ;
}
}
Modified: labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpServiceMultiplexorServlet.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpServiceMultiplexorServlet.java 2006-06-08 09:34:09 UTC (rev 4668)
+++ labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/transport/http/HttpServiceMultiplexorServlet.java 2006-06-08 09:42:29 UTC (rev 4669)
@@ -90,7 +90,7 @@
/**
* Flag to log packets.
*/
- private boolean logPackets = true ;
+ private boolean logPackets ;
/**
* Initialise the servlet.
@@ -101,7 +101,6 @@
throws ServletException
{
config(servletConfig) ;
- // KEV configure the packet logging.
}
/**
@@ -141,17 +140,17 @@
final MessageContext messageContext = new MessageContext() ;
initialiseContext(messageContext, request) ;
final MessageContext messageResponseContext = new MessageContext() ;
+ final Reader input = request.getReader() ;
final Reader reader ;
- // KEV create a reader to remove the XML declaration.
if (logPackets)
{
- final String contents = readAll(request.getReader()) ;
+ final String contents = readAll(input) ;
SoapMessageLogging.appendThreadLog(contents) ;
reader = new StringReader(contents) ;
}
else
{
- reader = request.getReader() ;
+ reader = input ;
}
final SoapMessage soapResponse ;
try
@@ -388,6 +387,12 @@
baseHttpURI = processURI(servletConfig.getInitParameter("BaseHttpURI")) ;
baseHttpsURI = processURI(servletConfig.getInitParameter("BaseHttpsURI")) ;
+
+ final String logPacketValue = servletConfig.getInitParameter("LogPackets") ;
+ if (logPacketValue != null)
+ {
+ logPackets = Boolean.valueOf(logPacketValue).booleanValue() ;
+ }
}
/**
@@ -470,29 +475,6 @@
break ;
}
}
- checkForXMLDecl(contents) ;
return contents.toString() ;
}
-
- private static void checkForXMLDecl(final StringBuffer buffer)
- {
- int count = 0 ;
- try
- {
- while(Character.isWhitespace(buffer.charAt(count))) count++ ;
- if (buffer.charAt(count) == '<')
- {
- if (buffer.charAt(count+1) == '?')
- {
- count+=2 ;
- while(buffer.charAt(count++) != '>') ;
- }
- }
- if (count > 0)
- {
- buffer.delete(0, count) ;
- }
- }
- catch (final StringIndexOutOfBoundsException sioobe) {}
- }
}
Modified: labs/jbosstm/trunk/XTS/coordinator/dd/webMethods-web-app.xml
===================================================================
--- labs/jbosstm/trunk/XTS/coordinator/dd/webMethods-web-app.xml 2006-06-08 09:34:09 UTC (rev 4668)
+++ labs/jbosstm/trunk/XTS/coordinator/dd/webMethods-web-app.xml 2006-06-08 09:42:29 UTC (rev 4669)
@@ -63,7 +63,20 @@
<display-name>XML Transaction Coordinator</display-name>
<description>XML Transaction Coordinator</description>
-
+
+ <!-- Initialise the Task Manager -->
+ <context-param>
+ <param-name>TaskManager.minWorkerCount</param-name>
+ <param-value>0</param-value>
+ </context-param>
+ <context-param>
+ <param-name>TaskManager.maxWorkerCount</param-name>
+ <param-value>10</param-value>
+ </context-param>
+ <listener>
+ <listener-class>com.arjuna.services.framework.admin.TaskManagerInitialisation</listener-class>
+ </listener>
+
<!-- Initialise WS-C services -->
<listener>
<listener-class>com.arjuna.webservices.wscoor.server.ActivationCoordinatorInitialisation</listener-class>
@@ -154,8 +167,12 @@
<!--
<init-param>
<param-name>BaseHttpsURI</param-name>
- <param-value>https://@hostname@:@port@/arjuna/soap/</param-value>
+ <param-value>https://@hostname@:@port@/@urlstub@/soap/</param-value>
</init-param>
+ <init-param>
+ <param-name>LogPackets</param-name>
+ <param-value>true</param-value>
+ </init-param>
-->
<load-on-startup>1</load-on-startup>
</servlet>
Modified: labs/jbosstm/trunk/XTS/demo/dd/webmethods/web-app.xml
===================================================================
--- labs/jbosstm/trunk/XTS/demo/dd/webmethods/web-app.xml 2006-06-08 09:34:09 UTC (rev 4668)
+++ labs/jbosstm/trunk/XTS/demo/dd/webmethods/web-app.xml 2006-06-08 09:42:29 UTC (rev 4669)
@@ -64,6 +64,19 @@
<description>XML Transaction Service Demo Client</description>
+ <!-- Initialise the Task Manager -->
+ <context-param>
+ <param-name>TaskManager.minWorkerCount</param-name>
+ <param-value>0</param-value>
+ </context-param>
+ <context-param>
+ <param-name>TaskManager.maxWorkerCount</param-name>
+ <param-value>10</param-value>
+ </context-param>
+ <listener>
+ <listener-class>com.arjuna.services.framework.admin.TaskManagerInitialisation</listener-class>
+ </listener>
+
<!-- Initialise WS-C services -->
<listener>
<listener-class>com.arjuna.webservices.wscoor.server.ActivationCoordinatorInitialisation</listener-class>
@@ -209,8 +222,12 @@
<!--
<init-param>
<param-name>BaseHttpsURI</param-name>
- <param-value>https://@hostname@:@port@/arjuna/soap/</param-value>
+ <param-value>https://@hostname@:@port@/@urlstub@/soap/</param-value>
</init-param>
+ <init-param>
+ <param-name>LogPackets</param-name>
+ <param-value>true</param-value>
+ </init-param>
-->
<load-on-startup>1</load-on-startup>
</servlet>
|
