@ThreadSafe public final class FabricCxfRegistrationHandler extends AbstractComponent implements org.apache.curator.framework.state.ConnectionStateListener
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CXF_API_ENDPOINT_MBEAN_NAME |
Constructor and Description |
---|
FabricCxfRegistrationHandler() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
booleanAttribute(javax.management.ObjectName oName,
java.lang.String name) |
static javax.management.ObjectName |
createObjectName(java.lang.String name) |
protected Container |
getCurrentContainer() |
protected java.lang.String |
getCxfServletPath(javax.management.ObjectName oName) |
protected java.lang.String |
getPath(Container container,
javax.management.ObjectName oName,
java.lang.String address,
boolean restApi) |
protected boolean |
isFullAddress(java.lang.String address) |
protected void |
onMBeanEvent(Container container,
javax.management.ObjectName oName,
java.lang.String type) |
protected void |
registerApiEndpoint(Container container,
javax.management.ObjectName oName,
java.lang.String address,
boolean started) |
protected void |
removeZkPath(java.lang.String path) |
protected void |
replay()
Replays again all events.
|
void |
stateChanged(org.apache.curator.framework.CuratorFramework client,
org.apache.curator.framework.state.ConnectionState newState) |
protected void |
unregisterApiEndpoint(Container container,
javax.management.ObjectName oName) |
activateComponent, assertValid, deactivateComponent, isValid
public static final java.lang.String CXF_API_ENDPOINT_MBEAN_NAME
public void stateChanged(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.state.ConnectionState newState)
stateChanged
in interface org.apache.curator.framework.state.ConnectionStateListener
protected void replay()
protected Container getCurrentContainer()
protected void onMBeanEvent(Container container, javax.management.ObjectName oName, java.lang.String type)
public static javax.management.ObjectName createObjectName(java.lang.String name)
protected void registerApiEndpoint(Container container, javax.management.ObjectName oName, java.lang.String address, boolean started)
protected boolean booleanAttribute(javax.management.ObjectName oName, java.lang.String name)
protected void unregisterApiEndpoint(Container container, javax.management.ObjectName oName)
protected void removeZkPath(java.lang.String path) throws java.lang.Exception
java.lang.Exception
protected java.lang.String getCxfServletPath(javax.management.ObjectName oName) throws java.io.IOException, java.net.URISyntaxException
java.io.IOException
java.net.URISyntaxException
protected boolean isFullAddress(java.lang.String address)
protected java.lang.String getPath(Container container, javax.management.ObjectName oName, java.lang.String address, boolean restApi)
Copyright © 2011-2014 Red Hat. All Rights Reserved.