svn commit: r727351 - in /synapse/trunk/java/modules: core/src/main/java/org/apache/synapse/endpoints/ samples/src/main/java/samples/userguide/ transports/src/main/java/org/apache/synapse/transport/nhttp/

[hiranya]

Author: hiranya
Date: Wed Dec 17 03:55:27 2008
New Revision: 727351

URL: http://svn.apache.org/viewvc?rev=727351&view=rev
Log:
Made changes to the EPRs mentioned in the LoadbalanceFailoverClient. Chenged 
from http://host:port to http://host:port/services/LBService1.

Changed the DLB Endpoint code to init child endpoints before sending messages 
to them.

This commit fixes SYNAPSE-488



Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java
    
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/LoadbalanceFailoverClient.java
    
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java?rev=727351&r1=727350&r2=727351&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java
 Wed Dec 17 03:55:27 2008
@@ -54,6 +54,7 @@
                 algorithmContext = new AlgorithmContext(isClusteringEnabled, 
cc, getName());
             }
         }
+        log.info("Dynamic load balance endpoint initialized");
     }
 
     private LoadBalanceMembershipHandler lbMembershipHandler;
@@ -120,6 +121,8 @@
                 AddressEndpoint endpoint = new AddressEndpoint();
                 EndpointDefinition definition = new EndpointDefinition();
                 endpoint.setDefinition(definition);
+                endpoint.init(((Axis2MessageContext) 
synCtx).getAxis2MessageContext().
+                        getConfigurationContext());
                 endpoint.send(synCtx);
             } else {
                 log.error("Cannot load balance for non-HTTP/S transport " + 
transport);

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=727351&r1=727350&r2=727351&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
 Wed Dec 17 03:55:27 2008
@@ -123,7 +123,7 @@
         value.setText("Sample string");
 
         Options options = new Options();
-        options.setTo(new EndpointReference("http://localhost:"; + 
synapsePort));
+        options.setTo(new EndpointReference("http://localhost:"; + synapsePort 
+ "/services/LBService1"));
 
         options.setAction("urn:sampleOperation");
 
@@ -243,7 +243,7 @@
         }
 
         Options options = new Options();
-        options.setTo(new EndpointReference("http://localhost:"; + 
synapsePort));
+        options.setTo(new EndpointReference("http://localhost:"; + synapsePort 
+ "/services/LBService1"));
         options.setAction("urn:sampleOperation");
         options.setTimeOutInMilliSeconds(10000000);
 

Modified: 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java?rev=727351&r1=727350&r2=727351&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java
 (original)
+++ 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java
 Wed Dec 17 03:55:27 2008
@@ -607,6 +607,10 @@
 
                 return;
             }
+            case HttpStatus.SC_BAD_REQUEST : {
+                log.error("Received bad request: " + 
response.getStatusLine().getReasonPhrase());
+                return;
+            }
             case HttpStatus.SC_INTERNAL_SERVER_ERROR : {
                 Header contentType = response.getFirstHeader(CONTENT_TYPE);
                 if (contentType != null) {