org.adroitlogic.x.core

Class ServerLimitManager

java.lang.Object

org.adroitlogic.x.core.ServerLimitManager

All Implemented Interfaces:

Initializable, XMessageCountSubscriber

public class ServerLimitManager
extends Object
implements Initializable, XMessageCountSubscriber

This class manages server runtime limitations such as uptime and message count

Since:

17.07.2

Author:

Udith Gunaratna

Constructor Summary

Constructors

Constructor and Description
ServerLimitManager()

Method Summary

Modifier and Type	Method and Description
void	destroy()
void	init(org.springframework.context.ApplicationContext context)
void	onTheFlyMessageCountChange(long count) Will be invoked when on-the-fly message count (i.e.
void	totalReceivedMessageCountChange(long count) Will be invoked when the total received message count (i.e.
ServerLimitManager	withMessageLimit(long maxMessageCount) Enforces a message limit for the instance
ServerLimitManager	withUpTimeLimit(TimeUnit timeUnit, int maxUptime, int firstWarningTime, int warningInterval) Enforces an uptime limit for the instance

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerLimitManager

public ServerLimitManager()

Method Detail

withUpTimeLimit

public ServerLimitManager withUpTimeLimit(TimeUnit timeUnit,
                                          int maxUptime,
                                          int firstWarningTime,
                                          int warningInterval)

Enforces an uptime limit for the instance

Parameters:

timeUnit - TimeUnit for the following three parameters

maxUptime - maximum allowed uptime in @param timeUnits

firstWarningTime - time to print the first warning in timeUnits

warningInterval - interval between two subsequent warnings in timeUnits

Returns:

current ServerLimitManager instance

withMessageLimit

public ServerLimitManager withMessageLimit(long maxMessageCount)

Enforces a message limit for the instance

Parameters:

maxMessageCount - maximum number of messages that can be received (through ingress connectors) in a single run of the instance

Returns:

current ServerLimitManager instance

init

public void init(org.springframework.context.ApplicationContext context)

Specified by:

init in interface Initializable

destroy

public void destroy()

Specified by:

destroy in interface Initializable

totalReceivedMessageCountChange

public void totalReceivedMessageCountChange(long count)

Description copied from interface: XMessageCountSubscriber

Will be invoked when the total received message count (i.e. the number of messages injected to the engine by ingress connectors) changed

Specified by:

totalReceivedMessageCountChange in interface XMessageCountSubscriber

Parameters:

count - the total received message count since the last start of the engine

onTheFlyMessageCountChange

public void onTheFlyMessageCountChange(long count)

Description copied from interface: XMessageCountSubscriber

Will be invoked when on-the-fly message count (i.e. the number of messages in processing) changed

Specified by:

onTheFlyMessageCountChange in interface XMessageCountSubscriber

Parameters:

count - the current on-the-fly message count