Package org.mases.datadistributionmanager

Class SmartDataDistribution

java.lang.Object

org.mases.datadistributionmanager.SmartDataDistribution

All Implemented Interfaces:

ISmartDataDistribution

public class SmartDataDistribution
extends java.lang.Object
implements ISmartDataDistribution

Main class to activate Data Distribution Manager

Constructor Summary

Constructors

Constructor	Description
SmartDataDistribution()	Ctor

Method Summary

Modifier and Type	Method	Description
void	addListener(IChangedStateListener listener)	Adds a IChangedStateListener listener
void	addListener(IChangingStateListener listener)	Adds a IChangingStateListener listener
void	addListener(IClusterStateChangeListener listener)	Adds a IClusterStateChangeListener listener
void	addListener(ICompletelyDisconnectedListener listener)	Adds a ICompletelyDisconnectedListener listener
void	addListener(IConfigurationListener listener)	Adds a IConfigurationListener listener
void	addListener(IFirstStateChangeListener listener)	Adds a IFirstStateChangeListener listener
void	addListener(ILoggingListener listener)	Adds a ILoggingListener listener
void	addListener(IMultiplePrimaryListener listener)	Adds a IMultiplePrimaryListener listener
void	addListener(IRequestedStateListener listener)	Adds a IRequestedStateListener listener
void	addListener(IStateChangeListener listener)	Adds a IStateChangeListener listener
void	addListener(IStateReadyListener listener)	Adds a IStateReadyListener listener
void	ChangedState(long IDataDistribution_nativePtr, int newState)	Internal method
void	ChangingState(long IDataDistribution_nativePtr, int oldState, int newState)	Internal method
<T extends SmartDataDistributionChannel> T	CreateSmartChannel(java.lang.Class<T> clazz, java.lang.String channelName)
<T extends SmartDataDistributionChannel> T	CreateSmartChannel(java.lang.Class<T> clazz, java.lang.String channelName, DDM_CHANNEL_DIRECTION direction, java.lang.String[] arrayParams)
<T extends SmartDataDistributionChannel> T	CreateSmartChannel(java.lang.Class<T> clazz, java.lang.String channelName, IConfiguration configuration)
<T extends SmartDataDistributionChannel> T	CreateSmartChannel(java.lang.Class<T> clazz, java.lang.String channelName, IConfiguration configuration, DDM_CHANNEL_DIRECTION direction)
void	FirstStateChange(long IDataDistribution_nativePtr, int newState)	Internal method
java.lang.String	getMastershipLib()
ISmartDataDistributionMastership	getMastershipManager()
java.lang.String	GetParameter(java.lang.String paramName)	Get global parameter
java.lang.String	GetParameter(DDM_GENERAL_PARAMETER paramId)	Get global parameter
java.lang.String	getProtocol()
java.lang.String	getProtocolLib()
OPERATION_RESULT	Initialize(java.lang.String conf_file)	Initialize the instance using configuration file
OPERATION_RESULT	Initialize(java.lang.String[] arrayParams)	Initialize the instance using a set of key=value pairs
OPERATION_RESULT	Initialize(java.lang.String[] arrayParams, java.lang.String topicTrailer)	Initialize the instance using a set of key=value pairs
OPERATION_RESULT	Initialize(java.lang.String[] arrayParams, java.lang.String szMyAddress, java.lang.String topicTrailer)	Initialize the instance using a set of key=value pairs
OPERATION_RESULT	Initialize(java.lang.String conf_file, java.lang.String topicTrailer)	Initialize the instance using configuration file
OPERATION_RESULT	Initialize(java.lang.String conf_file, java.lang.String szMyAddress, java.lang.String topicTrailer)	Initialize the instance using configuration file
OPERATION_RESULT	Initialize(IConfiguration configuration)	Initialize the instance using a configuration instance
OPERATION_RESULT	Initialize(IConfiguration configuration, java.lang.String topicTrailer)	Initialize the instance using a configuration instance
OPERATION_RESULT	Initialize(IConfiguration configuration, java.lang.String szMyAddress, java.lang.String topicTrailer)	Initialize the instance using a configuration instance
void	OnChangedState(DDM_INSTANCE_STATE newState)	The state has changed
void	OnChangingState(DDM_INSTANCE_STATE oldState, DDM_INSTANCE_STATE newState)	The state is starting to change
void	OnClusterStateChange(long IDataDistribution_nativePtr, int change, long serverid)	Internal method
void	OnClusterStateChange(DDM_CLUSTEREVENT change, long serverid)	The cluster has changed its state
void	OnCompletelyDisconnected(long IDataDistribution_nativePtr, java.lang.String channelName, java.lang.String reason)	Internal method
void	OnCompletelyDisconnected(java.lang.String channelName, java.lang.String reason)
java.lang.String	OnConfiguration(long IDataDistribution_nativePtr, java.lang.String channelName, java.lang.String key, java.lang.String value)	Internal method
java.lang.String	OnConfiguration(java.lang.String channelName, java.lang.String key, java.lang.String value)
void	OnFirstStateChange(DDM_INSTANCE_STATE newState)	Called the first time there is state change
void	OnLogging(long IDataDistribution_nativePtr, int level, java.lang.String source, java.lang.String function, java.lang.String errStr)	Internal method
void	OnLogging(DDM_LOG_LEVEL level, java.lang.String source, java.lang.String function, java.lang.String logStr)
void	OnMultiplePrimary(long myId, long otherId)	There are multiple primary server in the cluster
void	OnMultiplePrimary(long IDataDistribution_nativePtr, long myId, long otherId)	Internal method
void	OnRequestedState(byte[] buffer)	Called when a state transfer was requested
void	OnRequestedState(long IDataDistribution_nativePtr, byte[] buffer)	Internal method
void	OnStateChange(long IDataDistribution_nativePtr, int newState, int oldState)	Internal method
void	OnStateChange(DDM_INSTANCE_STATE newState, DDM_INSTANCE_STATE oldState)	My state has changed
void	OnStateReady(byte[] buffer)	The state is ready to be used
void	OnStateReady(long IDataDistribution_nativePtr, byte[] buffer)	Internal method
void	removeListener(IChangedStateListener listener)	Removes a IChangedStateListener listener
void	removeListener(IChangingStateListener listener)	Removes a IChangingStateListener listener
void	removeListener(IClusterStateChangeListener listener)	Removes a IClusterStateChangeListener listener
void	removeListener(ICompletelyDisconnectedListener listener)	Removes a ICompletelyDisconnectedListener listener
void	removeListener(IConfigurationListener listener)	Removes a IConfigurationListener listener
void	removeListener(IFirstStateChangeListener listener)	Removes a IFirstStateChangeListener listener
void	removeListener(ILoggingListener listener)	Removes a ILoggingListener listener
void	removeListener(IMultiplePrimaryListener listener)	Removes a IMultiplePrimaryListener listener
void	removeListener(IRequestedStateListener listener)	Removes a IRequestedStateListener listener
void	removeListener(IStateChangeListener listener)	Removes a IStateChangeListener listener
void	removeListener(IStateReadyListener listener)	Removes a IStateReadyListener listener
OPERATION_RESULT	RequestMastershipManager()	Request to allocate mastership manager
OPERATION_RESULT	RequestMastershipManager(java.lang.String serverName)	Request to allocate mastership manager
OPERATION_RESULT	RequestMastershipManager(java.lang.String[] parameters)	Request to allocate mastership manager
OPERATION_RESULT	RequestMastershipManager(java.lang.String serverName, java.lang.String[] parameters)	Request to allocate mastership manager
OPERATION_RESULT	RequestMastershipManager(java.lang.String serverName, IConfiguration parameters)	Request to allocate mastership manager
OPERATION_RESULT	RequestMastershipManager(IConfiguration parameters)	Request to allocate mastership manager
void	SetParameter(java.lang.String paramName, java.lang.String paramValue)	Set global parameter
void	SetParameter(DDM_GENERAL_PARAMETER paramId, java.lang.String paramValue)	Set global parameter
OPERATION_RESULT	Start(int timeout)	Starts the manager
OPERATION_RESULT	Stop(int timeout)	Stops the manager

Methods inherited from class java.lang.Object

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

Constructor Detail

SmartDataDistribution

public SmartDataDistribution()

Ctor

Method Detail

Initialize

public OPERATION_RESULT Initialize(java.lang.String conf_file)

Description copied from interface: ISmartDataDistribution

Initialize the instance using configuration file

Specified by:

Initialize in interface ISmartDataDistribution

Parameters:

conf_file - Configuration file to use

Returns:

OPERATION_RESULT

Initialize

public OPERATION_RESULT Initialize(java.lang.String conf_file,
                                   java.lang.String topicTrailer)

Description copied from interface: ISmartDataDistribution

Initialize the instance using configuration file

Specified by:

Initialize in interface ISmartDataDistribution

Parameters:

conf_file - Configuration file to use

topicTrailer - Trailer string to append on channel names

Returns:

OPERATION_RESULT

Initialize

public OPERATION_RESULT Initialize(java.lang.String conf_file,
                                   java.lang.String szMyAddress,
                                   java.lang.String topicTrailer)

Description copied from interface: ISmartDataDistribution

Initialize the instance using configuration file

Specified by:

Initialize in interface ISmartDataDistribution

Parameters:

conf_file - Configuration file to use

szMyAddress - The name of the server hosting the process

topicTrailer - Trailer string to append on channel names

Returns:

OPERATION_RESULT

Initialize

public OPERATION_RESULT Initialize(IConfiguration configuration)
                            throws java.lang.IllegalArgumentException

Description copied from interface: ISmartDataDistribution

Initialize the instance using a configuration instance

Specified by:

Initialize in interface ISmartDataDistribution

Parameters:

configuration - The configuration coming from an instance of IConfiguration

Returns:

OPERATION_RESULT

Throws:

java.lang.IllegalArgumentException - @see IConfiguration

Initialize

public OPERATION_RESULT Initialize(IConfiguration configuration,
                                   java.lang.String topicTrailer)
                            throws java.lang.IllegalArgumentException

Description copied from interface: ISmartDataDistribution

Initialize the instance using a configuration instance

Specified by:

Initialize in interface ISmartDataDistribution

Parameters:

configuration - The configuration coming from an instance of IConfiguration

topicTrailer - Trailer string to append on channel names

Returns:

OPERATION_RESULT

Throws:

java.lang.IllegalArgumentException - @see IConfiguration

Initialize

public OPERATION_RESULT Initialize(IConfiguration configuration,
                                   java.lang.String szMyAddress,
                                   java.lang.String topicTrailer)
                            throws java.lang.IllegalArgumentException

Description copied from interface: ISmartDataDistribution

Initialize the instance using a configuration instance

Specified by:

Initialize in interface ISmartDataDistribution

Parameters:

configuration - The configuration coming from an instance of IConfiguration

szMyAddress - The name of the server hosting the process

topicTrailer - Trailer string to append on channel names

Returns:

OPERATION_RESULT

Throws:

java.lang.IllegalArgumentException - @see IConfiguration

Initialize

public OPERATION_RESULT Initialize(java.lang.String[] arrayParams)

Description copied from interface: ISmartDataDistribution

Initialize the instance using a set of key=value pairs

Specified by:

Initialize in interface ISmartDataDistribution

Parameters:

arrayParams - array of key=value parameters

Returns:

OPERATION_RESULT

Initialize

public OPERATION_RESULT Initialize(java.lang.String[] arrayParams,
                                   java.lang.String topicTrailer)

Description copied from interface: ISmartDataDistribution

Initialize the instance using a set of key=value pairs

Specified by:

Initialize in interface ISmartDataDistribution

Parameters:

arrayParams - array of key=value parameters

topicTrailer - Trailer string to append on channel names

Returns:

OPERATION_RESULT

Initialize

public OPERATION_RESULT Initialize(java.lang.String[] arrayParams,
                                   java.lang.String szMyAddress,
                                   java.lang.String topicTrailer)

Description copied from interface: ISmartDataDistribution

Initialize the instance using a set of key=value pairs

Specified by:

Initialize in interface ISmartDataDistribution

Parameters:

arrayParams - array of key=value parameters

szMyAddress - The name of the server hosting the process

topicTrailer - Trailer string to append on channel names

Returns:

OPERATION_RESULT

RequestMastershipManager

public OPERATION_RESULT RequestMastershipManager()

Description copied from interface: ISmartDataDistribution

Request to allocate mastership manager

Specified by:

RequestMastershipManager in interface ISmartDataDistribution

Returns:

OPERATION_RESULT

RequestMastershipManager

public OPERATION_RESULT RequestMastershipManager(java.lang.String[] parameters)

Description copied from interface: ISmartDataDistribution

Request to allocate mastership manager

Specified by:

RequestMastershipManager in interface ISmartDataDistribution

Parameters:

parameters - Paramaters to send to underlying layer

Returns:

OPERATION_RESULT

RequestMastershipManager

public OPERATION_RESULT RequestMastershipManager(IConfiguration parameters)

Description copied from interface: ISmartDataDistribution

Request to allocate mastership manager

Specified by:

RequestMastershipManager in interface ISmartDataDistribution

Parameters:

parameters - IConfiguration instance of parameters to send to underlying layer

Returns:

OPERATION_RESULT

RequestMastershipManager

public OPERATION_RESULT RequestMastershipManager(java.lang.String serverName)

Description copied from interface: ISmartDataDistribution

Request to allocate mastership manager

Specified by:

RequestMastershipManager in interface ISmartDataDistribution

Parameters:

serverName - The server name

Returns:

OPERATION_RESULT

RequestMastershipManager

public OPERATION_RESULT RequestMastershipManager(java.lang.String serverName,
                                                 IConfiguration parameters)

Description copied from interface: ISmartDataDistribution

Request to allocate mastership manager

Specified by:

RequestMastershipManager in interface ISmartDataDistribution

Parameters:

serverName - The server name

parameters - IConfiguration instance of parameters to send to underlying layer

Returns:

OPERATION_RESULT

RequestMastershipManager

public OPERATION_RESULT RequestMastershipManager(java.lang.String serverName,
                                                 java.lang.String[] parameters)

Description copied from interface: ISmartDataDistribution

Request to allocate mastership manager

Specified by:

RequestMastershipManager in interface ISmartDataDistribution

Parameters:

serverName - The server name

parameters - Paramaters to send to underlying layer

Returns:

OPERATION_RESULT

getMastershipManager

public ISmartDataDistributionMastership getMastershipManager()

Specified by:

getMastershipManager in interface ISmartDataDistribution

Returns:

Returns ISmartDataDistributionMastership

Start

public OPERATION_RESULT Start(int timeout)

Description copied from interface: ISmartDataDistribution

Starts the manager

Specified by:

Start in interface ISmartDataDistribution

Parameters:

timeout - Timeout in ms

Returns:

OPERATION_RESULT

Stop

public OPERATION_RESULT Stop(int timeout)

Description copied from interface: ISmartDataDistribution

Stops the manager

Specified by:

Stop in interface ISmartDataDistribution

Parameters:

timeout - Timeout in ms

Returns:

OPERATION_RESULT

getProtocol

public java.lang.String getProtocol()

Specified by:

getProtocol in interface ISmartDataDistribution

Returns:

Return the protocol in use

getProtocolLib

public java.lang.String getProtocolLib()

Specified by:

getProtocolLib in interface ISmartDataDistribution

Returns:

Return the protocol library in use

getMastershipLib

public java.lang.String getMastershipLib()

Specified by:

getMastershipLib in interface ISmartDataDistribution

Returns:

Return the mastership library in use

SetParameter

public void SetParameter(java.lang.String paramName,
                         java.lang.String paramValue)

Description copied from interface: ISmartDataDistribution

Set global parameter

Specified by:

SetParameter in interface ISmartDataDistribution

Parameters:

paramName - Parameter name to set

paramValue - Parameter value to set

SetParameter

public void SetParameter(DDM_GENERAL_PARAMETER paramId,
                         java.lang.String paramValue)

Description copied from interface: ISmartDataDistribution

Set global parameter

Specified by:

SetParameter in interface ISmartDataDistribution

Parameters:

paramId - Parameter DDM_GENERAL_PARAMETER to set

paramValue - Parameter value to set

GetParameter

public java.lang.String GetParameter(java.lang.String paramName)

Description copied from interface: ISmartDataDistribution

Get global parameter

Specified by:

GetParameter in interface ISmartDataDistribution

Parameters:

paramName - Parameter name to get

Returns:

Parameter value

GetParameter

public java.lang.String GetParameter(DDM_GENERAL_PARAMETER paramId)

Description copied from interface: ISmartDataDistribution

Get global parameter

Specified by:

GetParameter in interface ISmartDataDistribution

Parameters:

paramId - Parameter DDM_GENERAL_PARAMETER to get

Returns:

Parameter value

CreateSmartChannel

public <T extends SmartDataDistributionChannel> T CreateSmartChannel(java.lang.Class<T> clazz,
                                                                     java.lang.String channelName)
                                                              throws java.lang.Throwable

Specified by:

CreateSmartChannel in interface ISmartDataDistribution

Type Parameters:

T - The class extending SmartDataDistributionChannel

Parameters:

clazz - The class to be instantiated

channelName - The channel name

Returns:

The allocated instance

Throws:

java.lang.Throwable - generic exception for all errors (if subsystem was unable to create a channel the exception is a generic Exception)

CreateSmartChannel

public <T extends SmartDataDistributionChannel> T CreateSmartChannel(java.lang.Class<T> clazz,
                                                                     java.lang.String channelName,
                                                                     IConfiguration configuration)
                                                              throws java.lang.Throwable

Specified by:

CreateSmartChannel in interface ISmartDataDistribution

Type Parameters:

T - The class extending SmartDataDistributionChannel

Parameters:

clazz - The class to be instantiated

channelName - The channel name

configuration - The configuration coming from an instance of IConfiguration

Returns:

The allocated instance

Throws:

java.lang.Throwable - generic exception for all errors (if subsystem was unable to create a channel the exception is a generic Exception)

CreateSmartChannel

public <T extends SmartDataDistributionChannel> T CreateSmartChannel(java.lang.Class<T> clazz,
                                                                     java.lang.String channelName,
                                                                     IConfiguration configuration,
                                                                     DDM_CHANNEL_DIRECTION direction)
                                                              throws java.lang.Throwable

Specified by:

CreateSmartChannel in interface ISmartDataDistribution

Type Parameters:

T - The class extending SmartDataDistributionChannel

Parameters:

clazz - The class to be instantiated

channelName - The channel name

configuration - The configuration coming from an instance of IConfiguration

direction - The DDM_CHANNEL_DIRECTION of the channel

Returns:

The allocated instance

Throws:

java.lang.Throwable - generic exception for all errors (if subsystem was unable to create a channel the exception is a generic Exception)

CreateSmartChannel

public <T extends SmartDataDistributionChannel> T CreateSmartChannel(java.lang.Class<T> clazz,
                                                                     java.lang.String channelName,
                                                                     DDM_CHANNEL_DIRECTION direction,
                                                                     java.lang.String[] arrayParams)
                                                              throws java.lang.Throwable

Specified by:

CreateSmartChannel in interface ISmartDataDistribution

Type Parameters:

T - The class extending SmartDataDistributionChannel

Parameters:

clazz - The class to be instantiated

channelName - The channel name

direction - The DDM_CHANNEL_DIRECTION of the channel

arrayParams - Specific parameters which override main parameters

Returns:

The allocated instance

Throws:

java.lang.Throwable - generic exception for all errors (if subsystem was unable to create a channel the exception is a generic Exception)

addListener

public void addListener(IConfigurationListener listener)

Description copied from interface: ISmartDataDistribution

Adds a IConfigurationListener listener

Specified by:

addListener in interface ISmartDataDistribution

Parameters:

listener - IConfigurationListener listener to add

removeListener

public void removeListener(IConfigurationListener listener)

Description copied from interface: ISmartDataDistribution

Removes a IConfigurationListener listener

Specified by:

removeListener in interface ISmartDataDistribution

Parameters:

listener - IConfigurationListener listener to remove

OnConfiguration

public final java.lang.String OnConfiguration(long IDataDistribution_nativePtr,
                                              java.lang.String channelName,
                                              java.lang.String key,
                                              java.lang.String value)

Internal method

OnConfiguration

public java.lang.String OnConfiguration(java.lang.String channelName,
                                        java.lang.String key,
                                        java.lang.String value)

addListener

public void addListener(ILoggingListener listener)

Description copied from interface: ISmartDataDistribution

Adds a ILoggingListener listener

Specified by:

addListener in interface ISmartDataDistribution

Parameters:

listener - ILoggingListener listener to add

removeListener

public void removeListener(ILoggingListener listener)

Description copied from interface: ISmartDataDistribution

Removes a ILoggingListener listener

Specified by:

removeListener in interface ISmartDataDistribution

Parameters:

listener - ILoggingListener listener to remove

OnLogging

public final void OnLogging(long IDataDistribution_nativePtr,
                            int level,
                            java.lang.String source,
                            java.lang.String function,
                            java.lang.String errStr)

Internal method

OnLogging

public void OnLogging(DDM_LOG_LEVEL level,
                      java.lang.String source,
                      java.lang.String function,
                      java.lang.String logStr)

addListener

public void addListener(ICompletelyDisconnectedListener listener)

Description copied from interface: ISmartDataDistribution

Adds a ICompletelyDisconnectedListener listener

Specified by:

addListener in interface ISmartDataDistribution

Parameters:

listener - ICompletelyDisconnectedListener listener to add

removeListener

public void removeListener(ICompletelyDisconnectedListener listener)

Description copied from interface: ISmartDataDistribution

Removes a ICompletelyDisconnectedListener listener

Specified by:

removeListener in interface ISmartDataDistribution

Parameters:

listener - ICompletelyDisconnectedListener listener to remove

OnCompletelyDisconnected

public final void OnCompletelyDisconnected(long IDataDistribution_nativePtr,
                                           java.lang.String channelName,
                                           java.lang.String reason)

Internal method

OnCompletelyDisconnected

public void OnCompletelyDisconnected(java.lang.String channelName,
                                     java.lang.String reason)

addListener

public void addListener(IClusterStateChangeListener listener)

Description copied from interface: ISmartDataDistribution

Adds a IClusterStateChangeListener listener

Specified by:

addListener in interface ISmartDataDistribution

Parameters:

listener - IClusterStateChangeListener listener to add

removeListener

public void removeListener(IClusterStateChangeListener listener)

Description copied from interface: ISmartDataDistribution

Removes a IClusterStateChangeListener listener

Specified by:

removeListener in interface ISmartDataDistribution

Parameters:

listener - IClusterStateChangeListener listener to remove

OnClusterStateChange

public final void OnClusterStateChange(long IDataDistribution_nativePtr,
                                       int change,
                                       long serverid)

Internal method

OnClusterStateChange

public void OnClusterStateChange(DDM_CLUSTEREVENT change,
                                 long serverid)

Description copied from interface: ISmartDataDistribution

The cluster has changed its state

Specified by:

OnClusterStateChange in interface ISmartDataDistribution

Parameters:

change - New cluster event

serverid - Server has emitted event

addListener

public void addListener(IStateChangeListener listener)

Description copied from interface: ISmartDataDistribution

Adds a IStateChangeListener listener

Specified by:

addListener in interface ISmartDataDistribution

Parameters:

listener - IStateChangeListener listener to add

removeListener

public void removeListener(IStateChangeListener listener)

Description copied from interface: ISmartDataDistribution

Removes a IStateChangeListener listener

Specified by:

removeListener in interface ISmartDataDistribution

Parameters:

listener - IStateChangeListener listener to remove

OnStateChange

public final void OnStateChange(long IDataDistribution_nativePtr,
                                int newState,
                                int oldState)

Internal method

OnStateChange

public void OnStateChange(DDM_INSTANCE_STATE newState,
                          DDM_INSTANCE_STATE oldState)

Description copied from interface: ISmartDataDistribution

My state has changed

Specified by:

OnStateChange in interface ISmartDataDistribution

Parameters:

newState - New state

oldState - Old state

addListener

public void addListener(IStateReadyListener listener)

Description copied from interface: ISmartDataDistribution

Adds a IStateReadyListener listener

Specified by:

addListener in interface ISmartDataDistribution

Parameters:

listener - IStateReadyListener listener to add

removeListener

public void removeListener(IStateReadyListener listener)

Description copied from interface: ISmartDataDistribution

Removes a IStateReadyListener listener

Specified by:

removeListener in interface ISmartDataDistribution

Parameters:

listener - IStateReadyListener listener to remove

OnStateReady

public final void OnStateReady(long IDataDistribution_nativePtr,
                               byte[] buffer)

Internal method

OnStateReady

public void OnStateReady(byte[] buffer)

Description copied from interface: ISmartDataDistribution

The state is ready to be used

Specified by:

OnStateReady in interface ISmartDataDistribution

Parameters:

buffer - The buffer state receiver

addListener

public void addListener(IRequestedStateListener listener)

Description copied from interface: ISmartDataDistribution

Adds a IRequestedStateListener listener

Specified by:

addListener in interface ISmartDataDistribution

Parameters:

listener - IRequestedStateListener listener to add

removeListener

public void removeListener(IRequestedStateListener listener)

Description copied from interface: ISmartDataDistribution

Removes a IRequestedStateListener listener

Specified by:

removeListener in interface ISmartDataDistribution

Parameters:

listener - IRequestedStateListener listener to remove

OnRequestedState

public final void OnRequestedState(long IDataDistribution_nativePtr,
                                   byte[] buffer)

Internal method

OnRequestedState

public void OnRequestedState(byte[] buffer)

Description copied from interface: ISmartDataDistribution

Called when a state transfer was requested

Specified by:

OnRequestedState in interface ISmartDataDistribution

Parameters:

buffer - Pointer to the buffer

addListener

public void addListener(IMultiplePrimaryListener listener)

Description copied from interface: ISmartDataDistribution

Adds a IMultiplePrimaryListener listener

Specified by:

addListener in interface ISmartDataDistribution

Parameters:

listener - IMultiplePrimaryListener listener to add

removeListener

public void removeListener(IMultiplePrimaryListener listener)

Description copied from interface: ISmartDataDistribution

Removes a IMultiplePrimaryListener listener

Specified by:

removeListener in interface ISmartDataDistribution

Parameters:

listener - IMultiplePrimaryListener listener to remove

OnMultiplePrimary

public final void OnMultiplePrimary(long IDataDistribution_nativePtr,
                                    long myId,
                                    long otherId)

Internal method

OnMultiplePrimary

public void OnMultiplePrimary(long myId,
                              long otherId)

Description copied from interface: ISmartDataDistribution

There are multiple primary server in the cluster

Specified by:

OnMultiplePrimary in interface ISmartDataDistribution

Parameters:

myId - My identifier

otherId - Other identifier which is primary

addListener

public void addListener(IFirstStateChangeListener listener)

Description copied from interface: ISmartDataDistribution

Adds a IFirstStateChangeListener listener

Specified by:

addListener in interface ISmartDataDistribution

Parameters:

listener - IFirstStateChangeListener listener to add

removeListener

public void removeListener(IFirstStateChangeListener listener)

Description copied from interface: ISmartDataDistribution

Removes a IFirstStateChangeListener listener

Specified by:

removeListener in interface ISmartDataDistribution

Parameters:

listener - IFirstStateChangeListener listener to remove

FirstStateChange

public final void FirstStateChange(long IDataDistribution_nativePtr,
                                   int newState)

Internal method

OnFirstStateChange

public void OnFirstStateChange(DDM_INSTANCE_STATE newState)

Description copied from interface: ISmartDataDistribution

Called the first time there is state change

Specified by:

OnFirstStateChange in interface ISmartDataDistribution

Parameters:

newState - New state

addListener

public void addListener(IChangingStateListener listener)

Description copied from interface: ISmartDataDistribution

Adds a IChangingStateListener listener

Specified by:

addListener in interface ISmartDataDistribution

Parameters:

listener - IChangingStateListener listener to add

removeListener

public void removeListener(IChangingStateListener listener)

Description copied from interface: ISmartDataDistribution

Removes a IChangingStateListener listener

Specified by:

removeListener in interface ISmartDataDistribution

Parameters:

listener - IChangingStateListener listener to remove

ChangingState

public final void ChangingState(long IDataDistribution_nativePtr,
                                int oldState,
                                int newState)

Internal method

OnChangingState

public void OnChangingState(DDM_INSTANCE_STATE oldState,
                            DDM_INSTANCE_STATE newState)

Description copied from interface: ISmartDataDistribution

The state is starting to change

Specified by:

OnChangingState in interface ISmartDataDistribution

Parameters:

oldState - Old state

newState - New state

addListener

public void addListener(IChangedStateListener listener)

Description copied from interface: ISmartDataDistribution

Adds a IChangedStateListener listener

Specified by:

addListener in interface ISmartDataDistribution

Parameters:

listener - IChangedStateListener listener to add

removeListener

public void removeListener(IChangedStateListener listener)

Description copied from interface: ISmartDataDistribution

Removes a IChangedStateListener listener

Specified by:

removeListener in interface ISmartDataDistribution

Parameters:

listener - IChangedStateListener listener to remove

ChangedState

public final void ChangedState(long IDataDistribution_nativePtr,
                               int newState)

Internal method

OnChangedState

public void OnChangedState(DDM_INSTANCE_STATE newState)

Description copied from interface: ISmartDataDistribution

The state has changed

Specified by:

OnChangedState in interface ISmartDataDistribution

Parameters:

newState - New state