com.neeve.aep

Interface IAepWatcher

public interface IAepWatcher

The interface through which the AEP runtime dispatches events to the user.

Method Summary

Methods

Modifier and Type	Method and Description
void	onBusBindingCreated(String busName) Notifies that an AEP engine has bound to a messaging bus.
void	onBusBindingDestroyed(String busName) Notifies that an AEP engine's bus binding has been destroyed (torn down).
void	onBusBindingFailed(String busName, String cause) Notifies that an AEP engine's bus binding has failed.
void	onBusBindingOpened(String busName) Notifies that an AEP engine's bus binding is open and operational.
void	onBusBindingOpening(String busName) Notifies that an AEP engine is opening a bus binding.
void	onChannelClosed(String busName, String channelName) Notifies that a bus channel has been closed.
void	onChannelOpened(String busName, String channelName, boolean joined) Notifies that a bus channel has been opened.
void	onClientConnected(String clientName) Notifies that a 'server' client has connected.
void	onClientDisconnected(String clientName) Notifies that a 'server' client has disconnected.
void	onEngineActive() Notifies that the AEP engine has gone active.
void	onEngineStarted() Notifies that the AEP engine has been started.
void	onEngineStopped() Notifies that an AEP engine has been stopped.
void	onFlowCreated(int flowid) Notifies that the AEP engine has created a new flow.

Method Detail

onEngineStarted

void onEngineStarted()

Notifies that the AEP engine has been started.

onEngineActive

void onEngineActive()

Notifies that the AEP engine has gone active.

This method is invoked when an engine goes active i.e. is the primary engine in its cluster.

onBusBindingCreated

void onBusBindingCreated(String busName)

Notifies that an AEP engine has bound to a messaging bus.

Parameters:

busName - The name of the bus bound to.

onBusBindingOpening

void onBusBindingOpening(String busName)

Notifies that an AEP engine is opening a bus binding.

Parameters:

busName - The name of the bus bound to.

onBusBindingOpened

void onBusBindingOpened(String busName)

Notifies that an AEP engine's bus binding is open and operational.

Parameters:

busName - The name of the bus bound to.

onBusBindingFailed

void onBusBindingFailed(String busName,
                      String cause)

Notifies that an AEP engine's bus binding has failed.

Parameters:

busName - The name of the bus bound to.

cause - A string containing a description of the cause of failure.

onBusBindingDestroyed

void onBusBindingDestroyed(String busName)

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

Parameters:

busName - The name of the bus bound to.

Threading:

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

onChannelOpened

void onChannelOpened(String busName,
                   String channelName,
                   boolean joined)

Notifies that a bus channel has been opened.

Parameters:

busName - The name of the bus containing the channel.

channelName - The name of the channel.

joined - Indicates whether the channel was joined or not.

onChannelClosed

void onChannelClosed(String busName,
                   String channelName)

Notifies that a bus channel has been closed.

Parameters:

busName - The name of the bus containing the channel.

channelName - The name of the channel.

onClientConnected

void onClientConnected(String clientName)

Notifies that a 'server' client has connected.

Parameters:

clientName - The name of the connected client.

onClientDisconnected

void onClientDisconnected(String clientName)

Notifies that a 'server' client has disconnected.

Parameters:

clientName - The name of the disconnected client.

onFlowCreated

void onFlowCreated(int flowid)

Notifies that the AEP engine has created a new flow.

Parameters:

flowid - The flow id.

Threading:

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

onEngineStopped

void onEngineStopped()

Notifies that an AEP engine has been stopped.