Skip to content

Commit

Permalink
correct error
Browse files Browse the repository at this point in the history
  • Loading branch information
hexiaofeng committed May 9, 2024
1 parent 6184e4f commit e7dab2f
Show file tree
Hide file tree
Showing 2 changed files with 32 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ public <T extends ServiceRequest.OutboundRequest> void filter(OutboundInvocation
}
backends = backends == endpoints ? new ArrayList<>(endpoints) : backends;
backends.remove(backend);
} while (!endpoints.isEmpty());
} while (!backends.isEmpty());
return null;
});
}
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,31 @@
package com.alipay.sofa.rpc.client;

import com.alipay.sofa.rpc.filter.FilterChain;

public class LiveCluster {

private final AbstractCluster cluster;

public LiveCluster(AbstractCluster cluster) {
this.cluster = cluster;
}

public FilterChain getFilterChain() {
return cluster.getFilterChain();
}

public String getStickyId() {
// 粘滞连接,当前连接可用
if (cluster.consumerConfig.isSticky()) {
// if (lastProviderInfo != null) {
// ProviderInfo providerInfo = lastProviderInfo;
// ClientTransport lastTransport = connectionHolder.getAvailableClientTransport(providerInfo);
// if (lastTransport != null && lastTransport.isAvailable()) {
// checkAlias(providerInfo, message);
// return providerInfo;
// }
// }
}
return null;
}
}

0 comments on commit e7dab2f

Please sign in to comment.