cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From serg...@apache.org
Subject cxf git commit: [CXF-7285] Open up InvocationContext for subclasses of FailoverTargetSelector, patch from Hugo Trippaers applied, This closes #245
Date Wed, 15 Mar 2017 12:37:43 GMT
Repository: cxf
Updated Branches:
  refs/heads/master c49f7a0be -> 7fa67da19


[CXF-7285] Open up InvocationContext for subclasses of FailoverTargetSelector, patch from
Hugo Trippaers applied, This closes #245


Project: http://git-wip-us.apache.org/repos/asf/cxf/repo
Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/7fa67da1
Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/7fa67da1
Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/7fa67da1

Branch: refs/heads/master
Commit: 7fa67da1925e0a526730e6f83415a0826c72b1d4
Parents: c49f7a0
Author: Sergey Beryozkin <sberyozkin@gmail.com>
Authored: Wed Mar 15 12:37:27 2017 +0000
Committer: Sergey Beryozkin <sberyozkin@gmail.com>
Committed: Wed Mar 15 12:37:27 2017 +0000

----------------------------------------------------------------------
 .../cxf/clustering/FailoverTargetSelector.java  | 27 +++++++++++---------
 1 file changed, 15 insertions(+), 12 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cxf/blob/7fa67da1/rt/features/clustering/src/main/java/org/apache/cxf/clustering/FailoverTargetSelector.java
----------------------------------------------------------------------
diff --git a/rt/features/clustering/src/main/java/org/apache/cxf/clustering/FailoverTargetSelector.java
b/rt/features/clustering/src/main/java/org/apache/cxf/clustering/FailoverTargetSelector.java
index cf8d791..de8abf1 100644
--- a/rt/features/clustering/src/main/java/org/apache/cxf/clustering/FailoverTargetSelector.java
+++ b/rt/features/clustering/src/main/java/org/apache/cxf/clustering/FailoverTargetSelector.java
@@ -432,6 +432,10 @@ public class FailoverTargetSelector extends AbstractConduitSelector {
         this.clientBootstrapAddress = clientBootstrapAddress;
     }
 
+    protected InvocationKey getInvocationKey(Exchange e) {
+        return new InvocationKey(e);
+    }
+
     /**
      * Used to wrap an Exchange for usage as a Map key. The raw Exchange
      * is not a suitable key type, as the hashCode is computed from its
@@ -441,7 +445,7 @@ public class FailoverTargetSelector extends AbstractConduitSelector {
     protected static class InvocationKey {
         private Exchange exchange;
 
-        InvocationKey(Exchange ex) {
+        protected InvocationKey(Exchange ex) {
             exchange = ex;
         }
 
@@ -469,8 +473,7 @@ public class FailoverTargetSelector extends AbstractConduitSelector {
         private Map<String, Object> context;
         private List<Endpoint> alternateEndpoints;
         private List<String> alternateAddresses;
-
-        InvocationContext(Endpoint endpoint,
+        protected InvocationContext(Endpoint endpoint,
                           BindingOperationInfo boi,
                           Object[] prms,
                           Map<String, Object> ctx) {
@@ -481,7 +484,7 @@ public class FailoverTargetSelector extends AbstractConduitSelector {
             context = ctx;
         }
 
-        Endpoint retrieveOriginalEndpoint(Endpoint endpoint) {
+        public Endpoint retrieveOriginalEndpoint(Endpoint endpoint) {
             if (endpoint != null) {
                 if (endpoint != originalEndpoint) {
                     getLogger().log(Level.INFO,
@@ -498,35 +501,35 @@ public class FailoverTargetSelector extends AbstractConduitSelector
{
             return originalEndpoint;
         }
 
-        BindingOperationInfo getBindingOperationInfo() {
+        public BindingOperationInfo getBindingOperationInfo() {
             return bindingOperationInfo;
         }
 
-        Object[] getParams() {
+        public Object[] getParams() {
             return params;
         }
 
-        Map<String, Object> getContext() {
+        public Map<String, Object> getContext() {
             return context;
         }
 
-        List<Endpoint> getAlternateEndpoints() {
+        public List<Endpoint> getAlternateEndpoints() {
             return alternateEndpoints;
         }
 
-        List<String> getAlternateAddresses() {
+        public List<String> getAlternateAddresses() {
             return alternateAddresses;
         }
 
-        void setAlternateEndpoints(List<Endpoint> alternates) {
+        protected void setAlternateEndpoints(List<Endpoint> alternates) {
             alternateEndpoints = alternates;
         }
 
-        void setAlternateAddresses(List<String> alternates) {
+        protected void setAlternateAddresses(List<String> alternates) {
             alternateAddresses = alternates;
         }
 
-        boolean hasAlternates() {
+        public boolean hasAlternates() {
             return !(alternateEndpoints == null && alternateAddresses == null);
         }
     }


Mime
View raw message