public class DeliveryService extends Object
Modifier and Type | Method and Description |
---|---|
static String |
addClusterIdPrefix(String id) |
EventBatchProcessor |
getEventBatchProcessor() |
static DeliveryService |
getInstance() |
List<DelivererStat> |
getStats() |
boolean |
isConfigLoaded() |
void |
processEventBatch(String config_file) |
void |
retryInitJMS() |
static void |
setClusterId(String clusterId)
This setter is invoked during startup of MWS
executing this setter will NOT change the clusterId value if it has already been set(which is done during startup)
|
void |
shutdown() |
void |
startLocalAsynchronousDelivery(String config_file) |
void |
startLocalSynchronousDelivery(String config_file) |
void |
startRemoteDelivery() |
void |
startRemoteDelivery(String config_file) |
void |
stopRemoteDelivery() |
public static DeliveryService getInstance()
public void startLocalSynchronousDelivery(String config_file)
public void processEventBatch(String config_file)
public void startLocalAsynchronousDelivery(String config_file)
public void startRemoteDelivery()
public boolean isConfigLoaded()
public void startRemoteDelivery(String config_file)
public void stopRemoteDelivery()
public void shutdown()
public List<DelivererStat> getStats()
public EventBatchProcessor getEventBatchProcessor()
public static void setClusterId(String clusterId)
clusterId
- public void retryInitJMS()