com.teraspaces.qwfix
Class FIXRemoteReplicatorApplication

java.lang.Object
  com.teraspaces.qwfix.FIXApplication
      com.teraspaces.qwfix.FIXRemoteReplicatorApplication

public final class FIXRemoteReplicatorApplication
extends FIXApplication

Provides methods and properties to synchronize FIX message communication from a remote process with an instance of FIXStandaloneApplication, and replaying the messages to reconstruct the business logic in those processes.

Constructor Summary

FIXRemoteReplicatorApplication(com.teraspaces.qwfix.repository.FIXRepository repository)
Instantiates a new fIX remote replicator application.

FIXRemoteReplicatorApplication(com.teraspaces.qwframework.io.SecureUri repositoryUri)
Instantiates a new fIX remote replicator application.

FIXRemoteReplicatorApplication(String repositoryUriString, String repositoryLoginName, String repositoryLoginPassword)
Instantiates a new fIX remote replicator application.

Method Summary

void	exit() pause() + FIXApplication.close()
com.teraspaces.qwframework.logging.FileApplicationLog	getEngineApplicationLog(String engineName) Gets the remote FIX engine application log.
void	pause() Pauses remote synchronization process.
void	registerFIXEngines(FIXRemoteReplicatorEngine[] engines) Register FIX engines.
void	resume() Resumes remote synchronization process (see pause()).
void	run(boolean initApplicationLogs) Start the remote synchronization process.
void	unload() Dispose the FIX engines and FIX messages associated with current application to free up resources such as memory.

Methods inherited from class com.teraspaces.qwfix.FIXApplication

getEngineSettingsLoader, getRepositoryUri, getSchedulerLoader, getSchemaLoader, getSessionSettingsLoader, getVisualLambdaLoader

Methods inherited from class java.lang.Object

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

Constructor Detail

FIXRemoteReplicatorApplication

public FIXRemoteReplicatorApplication(com.teraspaces.qwfix.repository.FIXRepository repository)

Instantiates a new fIX remote replicator application.

Parameters:

repository - the repository

FIXRemoteReplicatorApplication

public FIXRemoteReplicatorApplication(com.teraspaces.qwframework.io.SecureUri repositoryUri)

Instantiates a new fIX remote replicator application.

Parameters:

repositoryUri - the repository uri

FIXRemoteReplicatorApplication

public FIXRemoteReplicatorApplication(String repositoryUriString,
                                      String repositoryLoginName,
                                      String repositoryLoginPassword)

Instantiates a new fIX remote replicator application.

Parameters:

repositoryUriString - the repository uri string

repositoryLoginName - the repository login name

repositoryLoginPassword - the repository login password

Method Detail

registerFIXEngines

public void registerFIXEngines(FIXRemoteReplicatorEngine[] engines)

Register FIX engines.

More than one remote processes can be synchronized simulteniously.

Parameters:

engines - the engines

getEngineApplicationLog

public com.teraspaces.qwframework.logging.FileApplicationLog getEngineApplicationLog(String engineName)

Gets the remote FIX engine application log.

Parameters:

engineName - the FIX engine name

Returns:

the engine application log

run

public void run(boolean initApplicationLogs)

Start the remote synchronization process.

If initApplicationLogs is false, getEngineApplicationLog(String) will always return null.

Parameters:

initApplicationLogs - A value indicating whether the remote application log (alert/event log) is also synchronized.

pause

public void pause()

Pauses remote synchronization process.

resume() can be called to resume the syhcnronization process.

resume

public void resume()

Resumes remote synchronization process (see pause()).

exit

public void exit()

pause() + FIXApplication.close()

unload

public void unload()

Dispose the FIX engines and FIX messages associated with current application to free up resources such as memory.

exit() must be called before this method is called.