com.neeve.server.app

Interface ISrvAppWatcher

public interface ISrvAppWatcher

The interface through which application state changes can be watched.

Method Summary

Methods

Modifier and Type	Method and Description
void	onAppActive(SrvMonAppEngineActiveMessage message) Notifies that an application has gone active.
void	onAppBusBindingCreated(SrvMonAppBusBindingCreatedMessage message) Notifies that an application bus binding has been created.
void	onAppBusBindingDestroyed(SrvMonAppBusBindingDestroyedMessage message) Notifies that an application's bus binding has been destroyed (torn down).
void	onAppBusBindingFailed(SrvMonAppBusBindingDownMessage message) Notifies that an application's bus binding has failed.
void	onAppBusBindingOpened(SrvMonAppBusBindingOpenedMessage message) Notifies that an application bus binding is open and operational.
void	onAppBusBindingOpenFailed(SrvMonAppBusBindingOpenFailedMessage message) Notifies that an application's bus binding has failed.
void	onAppBusBindingOpening(SrvMonAppBusBindingOpeningMessage message) Notifies that an application bus binding is opening.
void	onAppChannelDown(SrvMonAppChannelDownMessage message) Notifies that an application's channel has been closed.
void	onAppChannelUp(SrvMonAppChannelUpMessage message) Notifies that an application's channel has been opened.
void	onAppClientConnected(String appName, String clientName) Notifies that an application's client has connected.
void	onAppClientDisconnected(String appName, String clientName) Notifies that an application's client has disconnected.
void	onAppFlowCreated(String appName, long timestamp, int flowid) Notifies that a new flow has been created for the application.
void	onAppInitialized(SrvAppLoader loader, long timestamp) Notifies that an application has been initialized.
void	onAppLoaded(SrvAppLoader loader) Notifies that an application has been loaded.
<E extends IRogMessage & IRogCopyableNode<? extends IRogMessage> & com.neeve.server.mon.common.ISrvMonEvent> void	onAppMonEvent(String appName, E monEvent) Invoked when a message backed event is emitted by an applications.
void	onAppStarted(SrvMonAppEngineStartedMessage message) Notifies that an application has been started.
void	onAppStopped(SrvMonAppEngineStoppedMessage message) Notifies that an application has been stopped.
void	onAppUnloaded(String name, long timestamp) Notifies that an application has been unloaded.

Method Detail

onAppLoaded

void onAppLoaded(SrvAppLoader loader)

Notifies that an application has been loaded.

Parameters:

loader - The loaded application's loader.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

onAppInitialized

void onAppInitialized(SrvAppLoader loader,
                    long timestamp)

Notifies that an application has been initialized.

Parameters:

loader - The initialized application's loader.

timestamp - The time at which the the application was initialzed.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

onAppStarted

void onAppStarted(SrvMonAppEngineStartedMessage message)

Notifies that an application has been started.

Parameters:

message - contains details about the application started event.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

This method is invoked when an application's AEP engine is started.

onAppActive

void onAppActive(SrvMonAppEngineActiveMessage message)

Notifies that an application has gone active.

Parameters:

message - the activation event details.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

This method is invoked when an application's AEP engine goes active i.e. when the application assumes the role of the primary application in its cluster.

onAppBusBindingCreated

void onAppBusBindingCreated(SrvMonAppBusBindingCreatedMessage message)

Notifies that an application bus binding has been created.

Parameters:

message - The event details.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

This method is invoked when an application's AEP engine establishes a bus binding on the application's behalf.

onAppBusBindingOpening

void onAppBusBindingOpening(SrvMonAppBusBindingOpeningMessage message)

Notifies that an application bus binding is opening.

Parameters:

message - contains details open the opening event.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

This method is invoked when an application's AEP engine commences opening a bus binding on the application's behalf.

onAppBusBindingOpened

void onAppBusBindingOpened(SrvMonAppBusBindingOpenedMessage message)

Notifies that an application bus binding is open and operational.

Parameters:

message - Contains details about the open event.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

This method is invoked when an application's AEP engine successfully opens a bus binding on the application's behalf.

onAppBusBindingOpenFailed

void onAppBusBindingOpenFailed(SrvMonAppBusBindingOpenFailedMessage message)

Notifies that an application's bus binding has failed.

Parameters:

message - contains details about the failure event.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

This method is invoked when an application's AEP engine detects a failure in an application's bus binding.

onAppBusBindingFailed

void onAppBusBindingFailed(SrvMonAppBusBindingDownMessage message)

Notifies that an application's bus binding has failed.

Parameters:

message - contains details about the failure event.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

This method is invoked when an application's AEP engine detects a failure in an application's bus binding.

onAppBusBindingDestroyed

void onAppBusBindingDestroyed(SrvMonAppBusBindingDestroyedMessage message)

Notifies that an application's bus binding has been destroyed (torn down).

Parameters:

message - the event details.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

This method is invoked when an application's AEP engine tears down a bus binding opened on the application's behalf.

onAppChannelUp

void onAppChannelUp(SrvMonAppChannelUpMessage message)

Notifies that an application's channel has been opened.

Parameters:

message - the event details.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

This method is invoked when an application's AEP engine successfully opens a bus channel on the application's behalf.

onAppChannelDown

void onAppChannelDown(SrvMonAppChannelDownMessage message)

Notifies that an application's channel has been closed.

Parameters:

message - the event details.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

This method is invoked when an application's AEP engine successfully closes a bus channel on the application's behalf.

onAppClientConnected

void onAppClientConnected(String appName,
                        String clientName)

Notifies that an application's client has connected.

Parameters:

appName - The application's name.

clientName - The name of the connected client.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

onAppClientDisconnected

void onAppClientDisconnected(String appName,
                           String clientName)

Notifies that an application's client has disconnected.

Parameters:

appName - The application's name.

clientName - The name of the disconnected client.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

onAppFlowCreated

void onAppFlowCreated(String appName,
                    long timestamp,
                    int flowid)

Notifies that a new flow has been created for the application.

Parameters:

appName - The application's name.

timestamp - The event timestamp.

flowid - The flow id.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

onAppStopped

void onAppStopped(SrvMonAppEngineStoppedMessage message)

Notifies that an application has been stopped.

Parameters:

message - contains details about the stopped application.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

This method is invoked when an application's AEP engine is stopped.

onAppUnloaded

void onAppUnloaded(String name,
                 long timestamp)

Notifies that an application has been unloaded.

Parameters:

name - The unloaded application's name.

timestamp - The timestamp at which the application was unloaded.

Threading:

This method can be invoked concurrently by multiple threads with itself and other methods in this interface.

onAppMonEvent

<E extends IRogMessage & IRogCopyableNode<? extends IRogMessage> & com.neeve.server.mon.common.ISrvMonEvent> void onAppMonEvent(String appName,
                                                                                                                            E monEvent)

Invoked when a message backed event is emitted by an applications.

Parameters:

monEvent - THe monitoring event