cgl.narada.wsinfra.wsr.impl
Class WsrSinkGroupMonitorFactoryImpl

java.lang.Object
  cgl.narada.wsinfra.wsr.impl.WsrSinkGroupMonitorFactoryImpl

All Implemented Interfaces:

WsrSinkGroupMonitorFactory

public class WsrSinkGroupMonitorFactoryImpl

extends Object

implements WsrSinkGroupMonitorFactory

This is a factory class which ensures that there is only instance of the GroupMonitorThread running for a given database. If there are multiple databases with multiple sources/sinks this factory class will still work fine.

Method Summary

static WsrSinkGroupMonitorFactory	getInstance()
WsrSinkGroupMonitor	getWsrSinkGroupMonitor(String configInfo, WsMessageFlow wsMessageFlow) Gets a Sink Group monitor for the specified configuration file.

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static WsrSinkGroupMonitorFactory getInstance()

getWsrSinkGroupMonitor

public WsrSinkGroupMonitor getWsrSinkGroupMonitor(String configInfo,
                                                  WsMessageFlow wsMessageFlow)
                                           throws WsrStorageException,
                                                  DeploymentException

Gets a Sink Group monitor for the specified configuration file. For a given configuration file (based on the absolute path name) only one instance of the WsrSinkGroupMonitor will be running within a given JVM instance.

Specified by:

getWsrSinkGroupMonitor in interface WsrSinkGroupMonitorFactory

Throws:

WsrStorageException

DeploymentException