Package de.hybris.platform.sap.core.jco.monitor.event

Class JCoConnectionsSnapshotClusterHandler

java.lang.Object

de.hybris.platform.servicelayer.event.impl.AbstractEventListener<JCoConnectionsSnapshotClusterResultEvent>

de.hybris.platform.sap.core.jco.monitor.event.JCoConnectionsSnapshotClusterHandler

All Implemented Interfaces:

JCoConnectionMonitor, java.util.EventListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<JCoConnectionsSnapshotClusterResultEvent>

public class JCoConnectionsSnapshotClusterHandler
extends AbstractEventListener<JCoConnectionsSnapshotClusterResultEvent>
implements JCoConnectionMonitor

Initiates the snapshot of all cluster and collects the result if requested.

Constructor Summary

Constructors

Constructor	Description
JCoConnectionsSnapshotClusterHandler()

Method Summary

Modifier and Type	Method	Description
protected void	checkState()	Check current state of snapshot in buffer and refreshes it if lifetime is outdated.
protected java.lang.String	createClusterSnapshot(boolean withFile, boolean updateCache)	Initiates the creation of one jco connections snapshot file for all cluster.
java.lang.String	createSnapshotFile()	Create JCo connections snapshot file operation.
java.lang.String	createSnapshotXML()	Returns all current JCo connections as XML String.
protected void	finalizeSnapshot(java.lang.String snapshotUuid)	Finalize snapshot.
java.util.Date	getCacheExpirationTimestamp()	Returns the snapshot buffer valid to time stamp.
java.util.Date	getCacheTimestamp()	Returns the snapshot time stamp.
java.lang.Integer	getLongRunnerCount()	Returns the number of JCo connections whose lifetime exceed a specific threshold parameter.
java.lang.Integer	getNodesCount()	Returns the total number of nodes of the result.
java.lang.Integer	getNodesWithoutResultCount()	Returns the total number of nodes with result of the result.
java.lang.Integer	getPoolLimitReachedCount()	Returns number of RFC destinations whose pool size is reached.
java.lang.Integer	getTotalCount()	Returns the total number of JCo connections.
boolean	isSnapshotInProcess()	Returns an indicator whether a snapshot is currently in creation.
protected void	onEvent(JCoConnectionsSnapshotClusterResultEvent event)	This method is called by ApplicationListener.onApplicationEvent(ApplicationEvent) and processes the given event.
void	resetCache()	Resets the snapshot buffer.
void	setCacheLifetimeInSeconds(long cacheLifetimeInSeconds)	Injection setter for cache lifetime.
void	setCollectionTimeoutInSeconds(long collectionTimeoutInSeconds)	Injection setter for collection timeout.
void	setEventService(EventService eventService)	Injection setter for EventService.
void	setJCoConnectionMonitorClusterProvider(JCoConnectionMonitorClusterProvider jcoConnectionMonitorClusterProvider)	Injection setter for JCoConnectionMonitorClusterProvider.

Methods inherited from class de.hybris.platform.servicelayer.event.impl.AbstractEventListener

afterPropertiesSet, onApplicationEvent, setApplicationContext, setClusterService, setTenantService

Methods inherited from class java.lang.Object

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

Constructor Detail

JCoConnectionsSnapshotClusterHandler

public JCoConnectionsSnapshotClusterHandler()

Method Detail

setEventService

public void setEventService(EventService eventService)

Injection setter for EventService.

Parameters:

eventService - the eventService to set

setJCoConnectionMonitorClusterProvider

public void setJCoConnectionMonitorClusterProvider(JCoConnectionMonitorClusterProvider jcoConnectionMonitorClusterProvider)

Injection setter for JCoConnectionMonitorClusterProvider.

Parameters:

jcoConnectionMonitorClusterProvider - the jcoConnectionMonitorClusterProvider to set

setCollectionTimeoutInSeconds

public void setCollectionTimeoutInSeconds(long collectionTimeoutInSeconds)

Injection setter for collection timeout.

Parameters:

collectionTimeoutInSeconds - collection timeout in seconds

setCacheLifetimeInSeconds

public void setCacheLifetimeInSeconds(long cacheLifetimeInSeconds)

Injection setter for cache lifetime.

Parameters:

cacheLifetimeInSeconds - cache lifetime in seconds

createSnapshotFile

public java.lang.String createSnapshotFile()

Description copied from interface: JCoConnectionMonitor

Create JCo connections snapshot file operation.

Specified by:

createSnapshotFile in interface JCoConnectionMonitor

Returns:

result message

createSnapshotXML

public java.lang.String createSnapshotXML()

Description copied from interface: JCoConnectionMonitor

Returns all current JCo connections as XML String.

Specified by:

createSnapshotXML in interface JCoConnectionMonitor

Returns:

XML String

getTotalCount

public java.lang.Integer getTotalCount()

Description copied from interface: JCoConnectionMonitor

Returns the total number of JCo connections.

Specified by:

getTotalCount in interface JCoConnectionMonitor

Returns:

number of JCo connections

getLongRunnerCount

public java.lang.Integer getLongRunnerCount()

Description copied from interface: JCoConnectionMonitor

Returns the number of JCo connections whose lifetime exceed a specific threshold parameter. The threshold parameter is defined in the project.properties file. Its default value is the same as the value of the default session timeout (3600 seconds).

Specified by:

getLongRunnerCount in interface JCoConnectionMonitor

Returns:

number of JCo connections whose lifetime exceed the defined threshold

getPoolLimitReachedCount

public java.lang.Integer getPoolLimitReachedCount()

Description copied from interface: JCoConnectionMonitor

Returns number of RFC destinations whose pool size is reached.

Specified by:

getPoolLimitReachedCount in interface JCoConnectionMonitor

Returns:

number of RFC destinations whose pool size is reached

getNodesCount

public java.lang.Integer getNodesCount()

Returns the total number of nodes of the result.

Returns:

number of nodes

getNodesWithoutResultCount

public java.lang.Integer getNodesWithoutResultCount()

Returns the total number of nodes with result of the result.

Returns:

number of nodes without result

getCacheTimestamp

public java.util.Date getCacheTimestamp()

Returns the snapshot time stamp.

Returns:

snapshot time stamp

getCacheExpirationTimestamp

public java.util.Date getCacheExpirationTimestamp()

Returns the snapshot buffer valid to time stamp.

Returns:

snapshot valid to time stamp

resetCache

public void resetCache()

Resets the snapshot buffer.

isSnapshotInProcess

public boolean isSnapshotInProcess()

Returns an indicator whether a snapshot is currently in creation.

Returns:

snapshot in process indicator

checkState

protected void checkState()

Check current state of snapshot in buffer and refreshes it if lifetime is outdated.

createClusterSnapshot

protected java.lang.String createClusterSnapshot(boolean withFile,
                                                 boolean updateCache)

Initiates the creation of one jco connections snapshot file for all cluster.

Parameters:

withFile - create snapshot file

updateCache - update cache indicator

Returns:

status message

finalizeSnapshot

protected void finalizeSnapshot(java.lang.String snapshotUuid)
                         throws JCoMonitorException

Finalize snapshot.

Parameters:

snapshotUuid - snapshot uuid

Throws:

JCoMonitorException - JCoMonitorException

onEvent

protected void onEvent(JCoConnectionsSnapshotClusterResultEvent event)

Description copied from class: AbstractEventListener

This method is called by ApplicationListener.onApplicationEvent(ApplicationEvent) and processes the given event.

Specified by:

onEvent in class AbstractEventListener<JCoConnectionsSnapshotClusterResultEvent>

Parameters:

event - the event to be processed

See Also:

ApplicationListener.onApplicationEvent(ApplicationEvent)