You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by hi...@apache.org on 2010/05/04 10:36:15 UTC
svn commit: r940770 -
/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/LoadbalanceFailoverClient.java
Author: hiranya
Date: Tue May 4 08:36:15 2010
New Revision: 940770
URL: http://svn.apache.org/viewvc?rev=940770&view=rev
Log:
Fixing SYNAPSE-637 (Sample client fixed)
Modified:
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/LoadbalanceFailoverClient.java
Modified: synapse/trunk/java/modules/samples/src/main/java/samples/userguide/LoadbalanceFailoverClient.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/LoadbalanceFailoverClient.java?rev=940770&r1=940769&r2=940770&view=diff
==============================================================================
--- synapse/trunk/java/modules/samples/src/main/java/samples/userguide/LoadbalanceFailoverClient.java (original)
+++ synapse/trunk/java/modules/samples/src/main/java/samples/userguide/LoadbalanceFailoverClient.java Tue May 4 08:36:15 2010
@@ -51,6 +51,8 @@ public class LoadbalanceFailoverClient {
private final static String COOKIE = "Cookie";
private final static String SET_COOKIE = "Set-Cookie";
+ private final static String DEFAULT_CLIENT_REPO = "client_repo";
+
/**
* @param args 0: simple | session
* 1: port
@@ -127,15 +129,12 @@ public class LoadbalanceFailoverClient {
options.setAction("urn:sampleOperation");
- String repo = System.getProperty("repository");
- ConfigurationContext configContext;
- if (repo != null) {
- configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(
- repo, repo + File.separator + "conf" + File.separator + "axis2.xml");
- } else {
- configContext = ConfigurationContextFactory.
- createConfigurationContextFromFileSystem("client_repo", null);
- }
+ String repoLocationProperty = System.getProperty("repository");
+ String repo = repoLocationProperty != null ? repoLocationProperty : DEFAULT_CLIENT_REPO;
+ ConfigurationContext configContext =
+ ConfigurationContextFactory.createConfigurationContextFromFileSystem(
+ repo, repo + File.separator + "conf" + File.separator + "axis2.xml");
+
ServiceClient client = new ServiceClient(configContext, null);
long timeout = Integer.parseInt(getProperty("timeout", "10000000"));
System.out.println("timeout=" + timeout);
@@ -255,8 +254,12 @@ public class LoadbalanceFailoverClient {
SOAPEnvelope env3 = buildSoapEnvelope("c3", "v1");
SOAPEnvelope[] envelopes = {env1, env2, env3};
- ConfigurationContext configContext = ConfigurationContextFactory.
- createConfigurationContextFromFileSystem("client_repo", null);
+ String repoLocationProperty = System.getProperty("repository");
+ String repo = repoLocationProperty != null ? repoLocationProperty : DEFAULT_CLIENT_REPO;
+ ConfigurationContext configContext =
+ ConfigurationContextFactory.createConfigurationContextFromFileSystem(
+ repo, repo + File.separator + "conf" + File.separator + "axis2.xml");
+
ServiceClient client = new ServiceClient(configContext, null);
// set addressing, transport and proxy url