From xmlrpc-user-return-1142-apmail-ws-xmlrpc-user-archive=ws.apache.org@ws.apache.org Wed Oct 13 07:05:26 2004
Return-Path: <xmlrpc-user-return-1142-apmail-ws-xmlrpc-user-archive=ws.apache.org@ws.apache.org>
Delivered-To: apmail-ws-xmlrpc-user-archive@www.apache.org
Received: (qmail 87352 invoked from network); 13 Oct 2004 07:05:25 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199)
  by minotaur-2.apache.org with SMTP; 13 Oct 2004 07:05:25 -0000
Received: (qmail 5761 invoked by uid 500); 13 Oct 2004 07:05:18 -0000
Delivered-To: apmail-ws-xmlrpc-user-archive@ws.apache.org
Received: (qmail 5730 invoked by uid 500); 13 Oct 2004 07:05:17 -0000
Mailing-List: contact xmlrpc-user-help@ws.apache.org; run by ezmlm
Precedence: bulk
list-help: <mailto:xmlrpc-user-help@ws.apache.org>
list-unsubscribe: <mailto:xmlrpc-user-unsubscribe@ws.apache.org>
list-post: <mailto:rpc-user@xml.apache.org>
Reply-To: xmlrpc-user@ws.apache.org
Delivered-To: mailing list xmlrpc-user@ws.apache.org
Received: (qmail 5703 invoked by uid 99); 13 Oct 2004 07:05:16 -0000
X-ASF-Spam-Status: No, hits=-0.0 required=10.0
	tests=SPF_HELO_PASS,SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (hermes.apache.org: domain of marcin@ish.com.au designates 218.214.52.22 as permitted sender)
Received: from [218.214.52.22] (HELO fish.ish.com.au) (218.214.52.22)
  by apache.org (qpsmtpd/0.28) with ESMTP; Wed, 13 Oct 2004 00:05:13 -0700
Received: from [203.29.62.9] (helo=neuro.net.au)
	by fish.ish.com.au with esmtp (Exim 4.30)
	id 1CHd9n-0006HI-QE
	for xmlrpc-user@ws.apache.org; Wed, 13 Oct 2004 17:02:43 +1000
Received: from [203.29.62.188] (HELO [203.29.62.188])
  by neuro.net.au (CommuniGate Pro SMTP 4.2.1)
  with ESMTP id 1371949 for xmlrpc-user@ws.apache.org; Wed, 13 Oct 2004 17:05:12 +1000
Mime-Version: 1.0 (Apple Message framework v619)
In-Reply-To: <200410130632.i9D6Wno03985@itree.com.au>
References: <200410130632.i9D6Wno03985@itree.com.au>
Content-Type: multipart/alternative; boundary=Apple-Mail-3--915179328
Message-Id: <357458B8-1CE6-11D9-B0E5-000D93399EF8@ish.com.au>
From: Marcin Skladaniec <marcin@ish.com.au>
Subject: Re: XmlRpc Client won't die ...  
Date: Wed, 13 Oct 2004 17:05:04 +1000
To: xmlrpc-user@ws.apache.org
X-Mailer: Apple Mail (2.619)
X-Scan-Signature: 5f3cae7fb67f54d2d8ae26c0abba589f
X-Virus-Checked: Checked
X-Spam-Rating: minotaur-2.apache.org 1.6.2 0/1000/N


--Apple-Mail-3--915179328
Content-Transfer-Encoding: quoted-printable
Content-Type: text/plain;
	charset=ISO-8859-1;
	delsp=yes;
	format=flowed

Thank you for this supersonic response. I will try it for sure.

Thanks again
Marcin Skladaniec


On 13/10/2004, at 4:32 PM, Jason Wyatt wrote:

> Hi Marcin,
> =A0
> I=A0had a similar problem with xmlrpc, no way to set the timeout, so I =
=20
> wrote a utility class to=A0add this. The other thing I wanted was for =20=

> any exceptions that were caught in the thread that actually performs =20=

> the xmlrpc.execute to be passed to the object that created the thread, =
=20
> and then rethrown. I don't know if there was an easier way to do this, =
=20
> but it seems to work OK.=A0I've been using=A0this in production on =
several =20
> projects with no major problems so far.
> =A0
> Code follows... forgive the lack of docco :)
> =A0
> Regards
> Jason
> =A0
> --
> Falun Gong: A peaceful meditation practice under persecution in China
> http://www.falundafa.org
>
>
> Truth - Compassion - Forbearance
> =A0
> =A0
> package common.util.xmlrpc;
> =A0
> /**
> =A0* <p>Title:=A0=A0TimedXmlRpcClient</p>
> =A0* <p>Description: This XmlRpcClient simply adds a connection =
timeout, =20
> after
> =A0*=A0 which if the XML-RPC call did not complete, an IOException is =20=

> thrown.</p>
> =A0* <p>Copyright: Copyright (c) 2002</p>
> =A0* <p>Company: </p>
> =A0* @author=A0=A0Jason Wyatt
> =A0* @version 1.0
> =A0*/
>
> import java.util.Vector;
> import java.io.IOException;
> import java.net.MalformedURLException;
> =A0
> import org.apache.xmlrpc.*;
> =A0
> public class TimedXmlRpcClient implements Runnable
> {
> =A0 private XmlRpcClient xmlRpcClient;
> =A0 private String hostname;
> =A0 private int ip;
> =A0 private int connectTimeout=3D30000; // 30 seconds default
> =A0 private String remoteFunction;
> =A0 private Vector params;
> =A0 private Object returnValue=3Dnull;
> =A0 private XmlRpcException xmlRpcException=3Dnull;
> =A0 private IOException ioException=3Dnull;
> =A0 private MalformedURLException malformedURLException=3Dnull;
> =A0
> =A0 TimedXmlRpcClient(String hostname, int ip, int connectTimeout, =20
> String remoteFunction, Vector params)
> =A0 {
> =A0=A0=A0 this.hostname=3Dhostname;
> =A0=A0=A0 this.ip=3Dip;
> =A0=A0=A0 this.connectTimeout=3DconnectTimeout;
> =A0=A0=A0 this.remoteFunction=3DremoteFunction;
> =A0=A0=A0 this.params=3Dparams;
> =A0 }
> =A0
> =A0
> =A0public static Object execute(String hostname, int ip, int =20
> connectTimeout, String remoteFunction, Vector params) throws =20
> XmlRpcException,
> =A0=A0=A0 IOException, MalformedURLException
> =A0 {
> =A0=A0=A0 TimedXmlRpcClient client=3Dnew =20
> TimedXmlRpcClient(hostname,ip,connectTimeout,remoteFunction,params);
> =A0
> =A0=A0=A0 Thread t =3D new Thread(client);
> =A0=A0=A0 t.start();
> =A0=A0=A0 try
> =A0=A0=A0 {
> =A0=A0=A0=A0=A0 t.join(connectTimeout); // exit the thread once it =20
> has=A0completed, or after timeout
> =A0=A0=A0 }
> =A0=A0=A0 catch (InterruptedException ex)
> =A0=A0=A0 {
> =A0=A0=A0 }
> =A0
> =A0=A0=A0 // if an exception occurred while executing the remote call, =
throw =20
> it again
> =A0=A0=A0 // from here
> =A0=A0=A0 IOException ex=3Dclient.getIOException();
> =A0=A0=A0 if(ex!=3Dnull)
> =A0=A0=A0=A0=A0 throw ex;
> =A0
> =A0=A0=A0 XmlRpcException ex2=3Dclient.getXmlRpcException();
> =A0=A0=A0 if(ex2!=3Dnull)
> =A0=A0=A0=A0=A0 throw ex2;
> =A0
> =A0=A0=A0 MalformedURLException ex3=3Dclient.getMalformedURLException();=

> =A0=A0=A0 if(ex3!=3Dnull)
> =A0=A0=A0=A0=A0 throw ex3;
> =A0
> =A0=A0=A0 Object returnVal=3Dclient.getReturnVal();
> =A0=A0=A0 if(returnVal=3D=3Dnull)
> =A0=A0=A0=A0 throw new IOException("Operation timed out");
> =A0
> =A0=A0=A0 return returnVal;
> =A0 }
> =A0
> =A0
> =A0 public void run()
> =A0 {
> =A0=A0=A0 try
> =A0=A0=A0 {
> =A0=A0=A0=A0=A0 xmlRpcClient=3Dnew XmlRpcClient(hostname, ip);
> =A0=A0=A0=A0=A0 returnValue=3DxmlRpcClient.execute(remoteFunction, =
params);
> =A0=A0=A0 }
> =A0=A0=A0 catch (MalformedURLException ex)
> =A0=A0=A0 {
> =A0=A0=A0=A0=A0 malformedURLException=3Dex;
> =A0=A0=A0 }
> =A0=A0=A0 catch (IOException ex2)
> =A0=A0=A0 {
> =A0=A0=A0=A0=A0 ioException=3Dex2;
> =A0=A0=A0 }
> =A0=A0=A0 catch(XmlRpcException ex3)
> =A0=A0=A0 {
> =A0=A0=A0=A0=A0 xmlRpcException=3Dex3;
> =A0=A0=A0 }
> =A0 }
> =A0
> =A0 public Object getReturnVal()
> =A0 {
> =A0=A0=A0 return returnValue;
> =A0 }
> =A0
> =A0 public XmlRpcException getXmlRpcException()
> =A0 {
> =A0=A0=A0 return xmlRpcException;
> =A0 }
> =A0
> =A0 public IOException getIOException()
> =A0 {
> =A0=A0=A0 return ioException;
> =A0 }
> =A0
> =A0 public MalformedURLException getMalformedURLException()
> =A0 {
> =A0=A0=A0 return malformedURLException;
> =A0 }
>
> =A0 public static void main(String[] args)
> =A0 {
> =A0=A0=A0 try
> =A0=A0=A0 {
> =A0=A0=A0=A0=A0 Vector params=3Dnew Vector();
> =A0=A0=A0=A0=A0 params.add( "select table_name from all_tables");
> =A0=A0=A0=A0=A0 =20
> =
TimedXmlRpcClient.execute("localhost",32000,5,"queryHandler.sqlQuery",p=20=

> arams);
> =A0=A0=A0 }
> =A0=A0=A0 catch (Exception ex)
> =A0=A0=A0 {
> =A0=A0=A0=A0=A0 System.err.println("Error=A0calling =
TimedXmlRpcClient:");
> =A0=A0=A0=A0=A0 ex.printStackTrace();
> =A0=A0=A0 }
> =A0 }
> }
> =A0
> =A0
> =A0
> =A0
>
>
> From: Marcin Skladaniec [mailto:marcin@ish.com.au]
>  Sent: Wednesday, 13 October 2004 4:02 PM
> To: xmlrpc-user@ws.apache.org
> Subject: XmlRpc Client won't die ...
>
> Hello !
> I have a XmlRpcClient executing an rpc method on very unreliable =20
> server. I have to force quit XmlRpcClient.execute() from time to time, =
=20
> but I can't. I have even created a separate Thread for it, and I'm =20
> quitting the Thread after timeout. It is working but not always, when =20=

> server receives xmlrpc request and freezes without any sign of life my =
=20
> thread is uninterruptible. Is my approach to this problem right or am =20=

> I missing something ? Does anyone created some other workaround for =20=

> missing timeout in XmlRpc framework ?
>
>
>  This is the impoortant part of my code:
>
>
> public SpacialThread(String pRemoteDatabaseURL, String pXmlRpcMethod, =20=

> Vector pXmlRpcParameters) {
> super();
>
> xmlRpcResponse =3D null;
>
> xmlRpcMethod =3D pXmlRpcMethod;
> xmlRpcParameters =3D pXmlRpcParameters;
> // See setResponse
> hasReceivedResponse =3D false;
> hasBeenInterrupted =3D false;
>
> try {
> client =3D new XmlRpcClient(pRemoteDatabaseURL);
> } catch (java.net.MalformedURLException e) {
> logger.error("(hash: " + hashCode() + "): =20
> java.net.MalformedURLException thrown:\n"
> + e);
> }
>
> start();
> }
>
>
> public void run() {
> try {
> // This is a blocking call...
> logger.debug("(hash: " + hashCode() + "): Attempting Xml Rpc =20
> transaction.");
> // Set response explicitly (this should be thread safe?)
> Object response =3D client.execute(xmlRpcMethod, xmlRpcParameters);
> setResponse(response);
>
> if (isInterrupted()) {
> hasBeenInterrupted =3D true;
> logger.error("(hash: " + hashCode() + "): Xml Rpc transaction =20
> interrupted explicitly. Exiting. (Communication with remote =20
> abandoned)");
> } else {
> logger.debug("(hash: " + hashCode() + "): Returned from Xml Rpc =20
> transaction.");
> }
>
> } catch (Exception e) {
> // Something else gone wrong... log the error and leave the exception =20=

> for reference.
> logger.error("(hash: " + hashCode() + "): Xml Rpc transaction =20
> interrupted abormally. Exiting. (Communication with remote =20
> abandoned)");
> setException(e);
> } finally {
> // Regardless of the situation, clean up and release the network =20
> resources (hopefully)
> logger.debug("(hash: " + hashCode() + "): Xml Rpc transaction =20
> finilizing - releasing resources.");
> client =3D null;
> }
> }
>
> Cheers
> Marcin Skladaniec
>

--Apple-Mail-3--915179328
Content-Transfer-Encoding: quoted-printable
Content-Type: text/enriched;
	charset=ISO-8859-1

Thank you for this supersonic response. I will try it for sure.


Thanks again

Marcin Skladaniec



On 13/10/2004, at 4:32 PM, Jason Wyatt wrote:


=
<excerpt><fontfamily><param>Arial</param><color><param>0000,0000,FFFF</par=
am><smaller>Hi
Marcin,</smaller></color></fontfamily>

=A0

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>I=A0had
a similar problem with xmlrpc, no way to set the timeout, so I wrote a
utility class to=A0add this. The other thing I wanted was for any
exceptions that were caught in the thread that actually performs the
xmlrpc.execute to be passed to the object that created the thread, and
then rethrown. I don't know if there was an easier way to do this, but
it seems to work OK.=A0I've been using=A0this in production on several
projects with no major problems so far.</smaller></color></fontfamily>

=A0

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>Code
follows... forgive the lack of docco :)</smaller></color></fontfamily>

=A0

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>Regards</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>Jason</smaller></color></fontfamily>

=A0

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>--</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>Falun
Gong: A peaceful meditation practice under persecution in =
China</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,EEEE</param><small=
er>http://www.falundafa.org</smaller></color></fontfamily>



=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>Truth
- Compassion - Forbearance</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>package
common.util.xmlrpc;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>/**</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0*
<<p>Title:=A0=A0TimedXmlRpcClient<</p></smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0*
<<p>Description: This XmlRpcClient simply adds a connection timeout,
after</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0*=A0
which if the XML-RPC call did not complete, an IOException is
thrown.<</p></smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0*
<<p>Copyright: Copyright (c) 2002<</p></smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0*
<<p>Company: <</p></smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0*
@author=A0=A0Jason Wyatt</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0*
@version 1.0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0*/</smaller></color></fontfamily>


=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>import
java.util.Vector;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>import
java.io.IOException;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>import
java.net.MalformedURLException;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>import
org.apache.xmlrpc.*;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>public
class TimedXmlRpcClient implements =
Runnable</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>{</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
private XmlRpcClient xmlRpcClient;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
private String hostname;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
private int ip;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
private int connectTimeout=3D30000; // 30 seconds =
default</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
private String remoteFunction;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
private Vector params;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
private Object returnValue=3Dnull;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
private XmlRpcException =
xmlRpcException=3Dnull;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
private IOException ioException=3Dnull;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
private MalformedURLException =
malformedURLException=3Dnull;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
TimedXmlRpcClient(String hostname, int ip, int connectTimeout, String
remoteFunction, Vector params)</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
this.hostname=3Dhostname;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
this.ip=3Dip;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
this.connectTimeout=3DconnectTimeout;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
this.remoteFunction=3DremoteFunction;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
this.params=3Dparams;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0public
static Object execute(String hostname, int ip, int connectTimeout,
String remoteFunction, Vector params) throws =
XmlRpcException,</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
IOException, MalformedURLException</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
TimedXmlRpcClient client=3Dnew
=
TimedXmlRpcClient(hostname,ip,connectTimeout,remoteFunction,params);</smal=
ler></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
Thread t =3D new Thread(client);</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
t.start();</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
try</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
t.join(connectTimeout); // exit the thread once it has=A0completed, or
after timeout</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
catch (InterruptedException ex)</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
// if an exception occurred while executing the remote call, throw it
again</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
// from here</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
IOException ex=3Dclient.getIOException();</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
if(ex!=3Dnull)</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
throw ex;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
XmlRpcException =
ex2=3Dclient.getXmlRpcException();</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
if(ex2!=3Dnull)</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
throw ex2;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
MalformedURLException =
ex3=3Dclient.getMalformedURLException();</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
if(ex3!=3Dnull)</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
throw ex3;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
Object returnVal=3Dclient.getReturnVal();</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
if(returnVal=3D=3Dnull)</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0
throw new IOException("Operation timed =
out");</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
return returnVal;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
public void run()</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
try</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
xmlRpcClient=3Dnew XmlRpcClient(hostname, =
ip);</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
returnValue=3DxmlRpcClient.execute(remoteFunction, =
params);</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
catch (MalformedURLException ex)</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
malformedURLException=3Dex;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
catch (IOException ex2)</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
ioException=3Dex2;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
catch(XmlRpcException ex3)</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
xmlRpcException=3Dex3;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
public Object getReturnVal()</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
return returnValue;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
public XmlRpcException =
getXmlRpcException()</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
return xmlRpcException;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
public IOException getIOException()</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
return ioException;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
public MalformedURLException =
getMalformedURLException()</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
return malformedURLException;</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 }</smaller></color></fontfamily>


=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0
public static void main(String[] args)</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
try</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
Vector params=3Dnew Vector();</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
params.add( "select table_name from =
all_tables");</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
=
TimedXmlRpcClient.execute("localhost",32000,5,"queryHandler.sqlQuery",para=
ms);</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0
catch (Exception ex)</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 {</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
System.err.println("Error=A0calling =
TimedXmlRpcClient:");</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0=A0=A0
ex.printStackTrace();</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0=A0=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0 }</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>}</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>=A0</smaller></color></fontfamily>



=
<bold><fontfamily><param>Tahoma</param><color><param>0000,0000,FFFF</param=
><smaller>From:</smaller></color></fontfamily></bold><fontfamily><param>Ta=
homa</param><color><param>0000,0000,FFFF</param><smaller>
Marcin Skladaniec =
[mailto:marcin@ish.com.au]</smaller></color></fontfamily>

=
<fontfamily><param>Tahoma</param><color><param>0000,0000,FFFF</param><smal=
ler>
<bold>Sent:</bold> Wednesday, 13 October 2004 4:02 =
PM</smaller></color></fontfamily>

=
<bold><fontfamily><param>Tahoma</param><color><param>0000,0000,FFFF</param=
><smaller>To:</smaller></color></fontfamily></bold><fontfamily><param>Taho=
ma</param><color><param>0000,0000,FFFF</param><smaller>
xmlrpc-user@ws.apache.org</smaller></color></fontfamily>

=
<bold><fontfamily><param>Tahoma</param><color><param>0000,0000,FFFF</param=
><smaller>Subject:</smaller></color></fontfamily></bold><fontfamily><param=
>Tahoma</param><color><param>0000,0000,FFFF</param><smaller>
XmlRpc Client won't die ... </smaller></color></fontfamily>


=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>Hello !</smaller></color></fontfamily>

=
<fontfamily><param>Arial</param><color><param>0000,0000,FFFF</param><small=
er>I
have a
=
</smaller></color></fontfamily><fixed><color><param>0000,0000,FFFF</param>=
<x-tad-smaller>XmlRpcClient</x-tad-smaller></color></fixed><fontfamily><pa=
ram>Arial</param><color><param>0000,0000,FFFF</param><smaller>
executing an rpc method on very unreliable server. I have to force
quit =
</smaller></color></fontfamily><fixed><color><param>0000,0000,FFFF</param>=
<x-tad-smaller>XmlRpcClient.execute()
from time to time, but I can't. I have even created a separate Thread
for it, and I'm quitting the Thread after timeout. It is working but
not always, when server receives xmlrpc request and freezes without
any sign of life my thread is uninterruptible. Is my approach to this
problem right or am I missing something ? Does anyone created some
other workaround for missing timeout in XmlRpc framework =
?</x-tad-smaller></color></fixed>



<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller> This is the
impoortant part of my code:</x-tad-smaller></color></fixed>



<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>public
SpacialThread(String pRemoteDatabaseURL, String pXmlRpcMethod, Vector
pXmlRpcParameters) {</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>super();</x-tad-=
smaller></color></fixed>


<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>xmlRpcResponse
=3D null;</x-tad-smaller></color></fixed>


<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>xmlRpcMethod
=3D pXmlRpcMethod;</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>xmlRpcParameters=

=3D pXmlRpcParameters;</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>// See
setResponse</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>hasReceivedRespo=
nse
=3D false;</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>hasBeenInterrupt=
ed
=3D false;</x-tad-smaller></color></fixed>


<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>try =
{</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>client =3D new
XmlRpcClient(pRemoteDatabaseURL);</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>} catch
(java.net.MalformedURLException e) {</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>logger.error("(h=
ash:
" + hashCode() + "): java.net.MalformedURLException thrown:\n" =
</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>+ =
e);</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>}</x-tad-smaller=
></color></fixed>


=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>start();</x-tad-=
smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>}</x-tad-smaller=
></color></fixed>



<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>public void
run() {</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>try =
{</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>// This is a
blocking call...</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>logger.debug("(h=
ash:
" + hashCode() + "): Attempting Xml Rpc =
transaction.");</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>// Set
response explicitly (this should be thread =
safe?)</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>Object
response =3D client.execute(xmlRpcMethod, =
xmlRpcParameters);</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>setResponse(resp=
onse);</x-tad-smaller></color></fixed>


<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>if
(isInterrupted()) {</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>hasBeenInterrupt=
ed
=3D true;</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>logger.error("(h=
ash:
" + hashCode() + "): Xml Rpc transaction interrupted explicitly.
Exiting. (Communication with remote =
abandoned)");</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>} else =
{</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>logger.debug("(h=
ash:
" + hashCode() + "): Returned from Xml Rpc =
transaction.");</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>}</x-tad-smaller=
></color></fixed>


<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>} catch
(Exception e) {</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>// Something
else gone wrong... log the error and leave the exception for =
reference.</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>logger.error("(h=
ash:
" + hashCode() + "): Xml Rpc transaction interrupted abormally.
Exiting. (Communication with remote =
abandoned)");</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>setException(e);=
</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>} finally =
{</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>//
Regardless of the situation, clean up and release the network
resources (hopefully)</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>logger.debug("(h=
ash:
" + hashCode() + "): Xml Rpc transaction finilizing - releasing
resources.");</x-tad-smaller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>client =3D
null;</x-tad-smaller></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>}</x-tad-smaller=
></color></fixed>

=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>}</x-tad-smaller=
></color></fixed>


=
<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>Cheers</x-tad-sm=
aller></color></fixed>

<fixed><color><param>0000,0000,FFFF</param><x-tad-smaller>Marcin
Skladaniec</x-tad-smaller></color></fixed>


</excerpt>=

--Apple-Mail-3--915179328--