Package org.apache.syncope.client.console.topology

Class TopologyWebSocketBehavior

java.lang.Object

org.apache.wicket.behavior.Behavior

org.apache.wicket.protocol.ws.api.BaseWebSocketBehavior

org.apache.wicket.protocol.ws.api.WebSocketBehavior

org.apache.syncope.client.console.topology.TopologyWebSocketBehavior

All Implemented Interfaces:

Serializable, IComponentAwareEventSink, IComponentAwareHeaderContributor, IClusterable

public class TopologyWebSocketBehavior
extends WebSocketBehavior

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	TopologyWebSocketBehavior.Checker
protected class	TopologyWebSocketBehavior.ConnectorChecker
protected class	TopologyWebSocketBehavior.ResourceChecker

Field Summary

Fields

Modifier and Type	Field	Description
protected ConfParamOps	confParamOps
protected static String	CONNECTOR_TEST_TIMEOUT_PARAMETER
protected ConnectorRestClient	connectorRestClient
protected Map<String,String>	connectors
protected Integer	connectorTestTimeout
protected String	coreAddress
protected String	domain
protected SimpleAsyncTaskExecutor	executor
protected String	jwt
protected static Logger	LOG
protected static JsonMapper	MAPPER
protected static String	RESOURCE_TEST_TIMEOUT_PARAMETER
protected ResourceRestClient	resourceRestClient
protected Map<String,String>	resources
protected Integer	resourceTestTimeout
protected Set<String>	runningConnCheck
protected Set<String>	runningResCheck
protected ServiceOps	serviceOps

Constructor Summary

Constructors

Constructor	Description
TopologyWebSocketBehavior()

Method Summary

Modifier and Type	Method	Description
boolean	connCheckDone(Collection<String> connectors)
protected void	onMessage(WebSocketRequestHandler handler, TextMessage message)
boolean	resCheckDone(Collection<String> resources)
protected void	timeoutHandlingConnectionChecker(TopologyWebSocketBehavior.Checker checker, Integer timeout, Map<String,String> responses, Set<String> running)

Methods inherited from class org.apache.wicket.protocol.ws.api.WebSocketBehavior

onAbort, onClose, onConnect, onError, onEvent, onMessage, onPush

Methods inherited from class org.apache.wicket.protocol.ws.api.BaseWebSocketBehavior

getBaseUrl, getContext, getContextPath, getFilterPrefix, getPort, getSecurePort, getSessionId, getStatelessHint, getWebSocketSetupScript, renderHead

Methods inherited from class org.apache.wicket.behavior.Behavior

afterRender, beforeRender, bind, canCallListener, detach, isEnabled, isTemporary, onAttribute, onComponentTag, onConfigure, onException, onRemove, onTag, unbind

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

protected static final Logger LOG

MAPPER

protected static final JsonMapper MAPPER

CONNECTOR_TEST_TIMEOUT_PARAMETER

protected static final String CONNECTOR_TEST_TIMEOUT_PARAMETER

See Also:

Constant Field Values

RESOURCE_TEST_TIMEOUT_PARAMETER

protected static final String RESOURCE_TEST_TIMEOUT_PARAMETER

See Also:

Constant Field Values

serviceOps

@SpringBean
protected ServiceOps serviceOps

confParamOps

@SpringBean
protected ConfParamOps confParamOps

connectorRestClient

@SpringBean
protected ConnectorRestClient connectorRestClient

resourceRestClient

@SpringBean
protected ResourceRestClient resourceRestClient

connectors

protected final Map<String,String> connectors

runningConnCheck

protected final Set<String> runningConnCheck

resources

protected final Map<String,String> resources

runningResCheck

protected final Set<String> runningResCheck

executor

protected final transient SimpleAsyncTaskExecutor executor

coreAddress

protected String coreAddress

domain

protected String domain

jwt

protected String jwt

connectorTestTimeout

protected Integer connectorTestTimeout

resourceTestTimeout

protected Integer resourceTestTimeout

Constructor Detail

TopologyWebSocketBehavior

public TopologyWebSocketBehavior()

Method Detail

timeoutHandlingConnectionChecker

protected void timeoutHandlingConnectionChecker(TopologyWebSocketBehavior.Checker checker,
                                                Integer timeout,
                                                Map<String,String> responses,
                                                Set<String> running)

onMessage

protected void onMessage(WebSocketRequestHandler handler,
                         TextMessage message)

Overrides:

onMessage in class WebSocketBehavior

connCheckDone

public boolean connCheckDone(Collection<String> connectors)

resCheckDone

public boolean resCheckDone(Collection<String> resources)