public class FabricLoadBalancerFeature
extends org.apache.cxf.feature.AbstractFeature
implements org.apache.cxf.buslifecycle.BusLifeCycleListener
Constructor and Description |
---|
FabricLoadBalancerFeature() |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
ServerAddressResolver |
getAddressResolver() |
org.apache.curator.framework.CuratorFramework |
getCurator() |
protected LoadBalanceStrategy |
getDefaultLoadBalanceStrategy() |
protected LoadBalanceTargetSelector |
getDefaultLoadBalanceTargetSelector() |
java.lang.String |
getFabricPath() |
Group |
getGroup() |
LoadBalanceStrategy |
getLoadBalanceStrategy() |
int |
getMaximumConnectionTimeout() |
java.lang.String |
getZooKeeperPassword() |
java.lang.String |
getZooKeeperUrl() |
void |
initComplete() |
void |
initialize(org.apache.cxf.Bus bus) |
void |
initialize(org.apache.cxf.endpoint.Client client,
org.apache.cxf.Bus bus) |
void |
initialize(org.apache.cxf.interceptor.InterceptorProvider interceptorProvider,
org.apache.cxf.Bus bus) |
boolean |
isShouldCloseZkClient() |
void |
postShutdown() |
void |
preShutdown() |
void |
setAddressResolver(ServerAddressResolver addressResolver) |
void |
setCurator(org.apache.curator.framework.CuratorFramework curator) |
void |
setFabricPath(java.lang.String fabricPath) |
void |
setLoadBalanceStrategy(LoadBalanceStrategy strategy) |
void |
setMaximumConnectionTimeout(int maximumConnectionTimeout) |
void |
setShouldCloseZkClient(boolean closeZkClient) |
protected void |
setupClientConduitSelector(org.apache.cxf.endpoint.Client client) |
void |
setZooKeeperPassword(java.lang.String zooKeeperPassword) |
void |
setZooKeeperUrl(java.lang.String zooKeeperUrl) |
public void initialize(org.apache.cxf.endpoint.Client client, org.apache.cxf.Bus bus)
initialize
in interface org.apache.cxf.feature.Feature
initialize
in class org.apache.cxf.feature.AbstractFeature
public void initialize(org.apache.cxf.interceptor.InterceptorProvider interceptorProvider, org.apache.cxf.Bus bus)
initialize
in interface org.apache.cxf.feature.Feature
initialize
in class org.apache.cxf.feature.AbstractFeature
public void initialize(org.apache.cxf.Bus bus)
initialize
in interface org.apache.cxf.feature.Feature
initialize
in class org.apache.cxf.feature.AbstractFeature
protected void setupClientConduitSelector(org.apache.cxf.endpoint.Client client)
protected LoadBalanceStrategy getDefaultLoadBalanceStrategy()
protected LoadBalanceTargetSelector getDefaultLoadBalanceTargetSelector()
public Group getGroup() throws java.lang.Exception
java.lang.Exception
public void destroy() throws java.lang.Exception
java.lang.Exception
public java.lang.String getFabricPath()
public void setFabricPath(java.lang.String fabricPath)
public org.apache.curator.framework.CuratorFramework getCurator() throws java.lang.Exception
java.lang.Exception
public void setCurator(org.apache.curator.framework.CuratorFramework curator)
public LoadBalanceStrategy getLoadBalanceStrategy() throws java.lang.Exception
java.lang.Exception
public void setLoadBalanceStrategy(LoadBalanceStrategy strategy)
public void setShouldCloseZkClient(boolean closeZkClient)
public boolean isShouldCloseZkClient()
public int getMaximumConnectionTimeout()
public void setMaximumConnectionTimeout(int maximumConnectionTimeout)
public ServerAddressResolver getAddressResolver()
public void setAddressResolver(ServerAddressResolver addressResolver)
public java.lang.String getZooKeeperUrl()
public void setZooKeeperUrl(java.lang.String zooKeeperUrl)
public java.lang.String getZooKeeperPassword()
public void setZooKeeperPassword(java.lang.String zooKeeperPassword)
public void initComplete()
initComplete
in interface org.apache.cxf.buslifecycle.BusLifeCycleListener
public void preShutdown()
preShutdown
in interface org.apache.cxf.buslifecycle.BusLifeCycleListener
public void postShutdown()
postShutdown
in interface org.apache.cxf.buslifecycle.BusLifeCycleListener
Copyright © 2011-2014 Red Hat. All Rights Reserved.