This is an automated email from the ASF dual-hosted git repository.

isjarana pushed a commit to branch baremetal
in repository https://gitbox.apache.org/repos/asf/airavata-custos.git


The following commit(s) were added to refs/heads/baremetal by this push:
     new 5ee89e223 fix for 311
     new d54587204 Merge pull request #319 from isururanawaka/baremetal
5ee89e223 is described below

commit 5ee89e223ff900ca0166901e3571f50a11e5a830
Author: Isuru Ranawaka <[email protected]>
AuthorDate: Fri Nov 4 15:29:33 2022 -0400

    fix for 311
---
 .../custos/integration/core/interceptor/ServiceInterceptor.java      | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/custos-integration-core/src/main/java/org/apache/custos/integration/core/interceptor/ServiceInterceptor.java
 
b/custos-integration-core/src/main/java/org/apache/custos/integration/core/interceptor/ServiceInterceptor.java
index d3c34fcce..474eb9ad0 100644
--- 
a/custos-integration-core/src/main/java/org/apache/custos/integration/core/interceptor/ServiceInterceptor.java
+++ 
b/custos-integration-core/src/main/java/org/apache/custos/integration/core/interceptor/ServiceInterceptor.java
@@ -64,7 +64,10 @@ public class ServiceInterceptor implements ServerInterceptor 
{
                     Iterator it = interceptorSet.iterator();
                     while (it.hasNext()) {
                         IntegrationServiceInterceptor interceptor = 
(IntegrationServiceInterceptor) it.next();
-                        resp = interceptor.intercept(methodName, metadata, 
(resp == null) ? message : resp);
+                        if (serviceName.split(".service")[0]
+                                
.equals(interceptor.toString().split(".interceptors")[0])) {
+                            resp = interceptor.intercept(methodName, metadata, 
(resp == null) ? message : resp);
+                        }
                     }
                     super.onMessage(resp);
                 } catch (UnAuthorizedException ex) {

Reply via email to