ServiceRunner

java.lang.Object
- com.enremmeta.util.ServiceRunner

Direct Known Subclasses:

Bidder, ModUid
```
public abstract class ServiceRunner
extends Object
```
Implements some common services for classes that are intended to have main(), such as command-line parsing, etc.

Author:

Gregory Golberg (grisha@alum.mit.edu)
Copyright © Enremmeta LLC 2014. All Rights Reserved. This code is licensed under Affero GPL 3.0

Field Summary

Fields
Modifier and Type	Field and Description
`protected AdCache`	`adCache`
`protected org.apache.commons.cli.CommandLine`	`cl`
`static String`	`COLLECTIONS_DB_SERVICE`
`protected Lot49Config`	`config`
`private String`	`configFilename`
`private AtomicLong`	`counter`
`private Map<String,DbService>`	`dbServices`
`private ExecutorService`	`executor`
`private HazelcastService`	`hazelcastService`
`private IntegralService`	`integralService`
`private long`	`lastRolloverEnforcerRan`
`private MaxMindFacade`	`maxMind`
`protected org.apache.commons.cli.Options`	`opts`
`private Orchestrator`	`orchestrator`
`private Map<String,Provider>`	`providers`
`protected static ServiceRunner`	`runner`
`protected SandboxSecurityManager`	`sandboxSecurityManager`
`private ScheduledExecutorService`	`scheduledExecutor`
`private SegmentToOwnerCodec`	`segmentToOwnerCodec`
`private DaoMapOfUserAttributes`	`userAttributesCacheService`
`private DaoMapOfUserSegments`	`userSegmentsCacheService`

Constructor Summary

Constructors
Modifier Constructor and Description

protected ServiceRunner()

Constructors
Modifier	Constructor and Description
`protected`	`ServiceRunner()`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`AdCache`	`getAdCache()`
`org.apache.commons.cli.CommandLine`	`getCl()`
`Lot49Config`	`getConfig()`
`protected String`	`getConfigFilename()`
`DbService`	`getDbServiceByName(String name)`
`ExecutorService`	`getExecutor()`
`HazelcastService`	`getHazelcastService()`
`static ServiceRunner`	`getInstance()`
`IntegralService`	`getIntegralService()`
`MaxMindFacade`	`getMaxMind()`
`String`	`getNextId()`
`org.apache.commons.cli.Options`	`getOpts()`
`Orchestrator`	`getOrchestrator()`
`Map<String,Provider>`	`getProviders()`
`private static String`	`getRolloverEnforcerId()`
`SandboxSecurityManager`	`getSandboxSecurityManager()`
`ScheduledExecutorService`	`getScheduledExecutor()`
`SegmentToOwnerCodec`	`getSegmentToOwnerCodec()`
`DaoMapOfUserAttributes`	`getUserAttributesCacheService()`
`DaoMapOfUserSegments`	`getUserSegmentsCacheService()`
`void`	`initAdapters()`
`void`	`initCaches()`
`void`	`initCodecs()`
`void`	`initDbServices()` Initialize a `DbService` for every item in `DbConfigs`, and throw an exception the first time an error happens.
`void`	`initExecutors()`
`void`	`initGeo()`
`void`	`initIntegral()`
`void`	`initLogging()`
`void`	`initOrchestrator()`
`void`	`initProviders()`
`void`	`initSecurityManager()`
`Lot49Config`	`loadConfig()`
`void`	`parseCommandLineArgs(String[] argv)`
`void`	`scheduleLogRolloverEnforcer()` We schedule a process to run every minute, that, when it detects that an hour is rolled over (the `minute of hour` is 0), writes an entry into every log with mostly NULLs.
`void`	`setCl(org.apache.commons.cli.CommandLine cl)`
`void`	`setConfig(Lot49Config config)` Intended for use in tests - this has no effect if loaded after initial startup.
`void`	`setOpts(org.apache.commons.cli.Options opts)`
`void`	`updateSubcriptionData()`
`protected void`	`usage()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

runner
```
protected static ServiceRunner runner
```

opts

protected org.apache.commons.cli.Options opts

cl

protected org.apache.commons.cli.CommandLine cl

hazelcastService

private HazelcastService hazelcastService

maxMind
```
private MaxMindFacade maxMind
```

orchestrator
```
private Orchestrator orchestrator
```

userAttributesCacheService

private DaoMapOfUserAttributes userAttributesCacheService

userSegmentsCacheService

private DaoMapOfUserSegments userSegmentsCacheService

sandboxSecurityManager

protected SandboxSecurityManager sandboxSecurityManager

adCache
```
protected AdCache adCache
```

config
```
protected Lot49Config config
```

configFilename
```
private String configFilename
```

scheduledExecutor

private ScheduledExecutorService scheduledExecutor

executor
```
private ExecutorService executor
```

integralService

private IntegralService integralService

providers

private final Map<String,Provider> providers

lastRolloverEnforcerRan
```
private long lastRolloverEnforcerRan
```

dbServices

private Map<String,DbService> dbServices

counter
```
private AtomicLong counter
```

segmentToOwnerCodec

private SegmentToOwnerCodec segmentToOwnerCodec

COLLECTIONS_DB_SERVICE

public static final String COLLECTIONS_DB_SERVICE

See Also:: Constant Field Values

Constructor Detail
- ServiceRunner
```
protected ServiceRunner()
```

Method Detail

getInstance

public static ServiceRunner getInstance()

getAdCache
```
public AdCache getAdCache()
```

getUserAttributesCacheService

public DaoMapOfUserAttributes getUserAttributesCacheService()

getUserSegmentsCacheService

public DaoMapOfUserSegments getUserSegmentsCacheService()

getScheduledExecutor

public ScheduledExecutorService getScheduledExecutor()

getExecutor
```
public ExecutorService getExecutor()
```

getConfigFilename
```
protected String getConfigFilename()
```

getSandboxSecurityManager

public SandboxSecurityManager getSandboxSecurityManager()

initExecutors
```
public void initExecutors()
```

getCl

public org.apache.commons.cli.CommandLine getCl()

initProviders

public void initProviders()
                   throws Lot49Exception

Throws:: Lot49Exception

getProviders

public Map<String,Provider> getProviders()

getMaxMind
```
public MaxMindFacade getMaxMind()
```

initGeo

public void initGeo()
             throws IOException

Throws:: IOException

initOrchestrator

public void initOrchestrator()
                      throws Lot49Exception

Throws:: Lot49Exception

initLogging

public void initLogging()
                 throws Lot49Exception

Throws:: Lot49Exception

getOpts

public org.apache.commons.cli.Options getOpts()

getOrchestrator
```
public Orchestrator getOrchestrator()
```

getRolloverEnforcerId

private static final String getRolloverEnforcerId()

scheduleLogRolloverEnforcer
```
public void scheduleLogRolloverEnforcer()
```
We schedule a process to run every minute, that, when it detects that an hour is rolled over (the minute of hour is 0), writes an entry into every log with mostly NULLs. This will force the roll over process to work.

See Also:

Remko Popma's comment on Stackoverflow

initAdapters

public void initAdapters()
                  throws Lot49Exception

Throws:: Lot49Exception

setCl

public void setCl(org.apache.commons.cli.CommandLine cl)

getHazelcastService

public HazelcastService getHazelcastService()

getNextId
```
public String getNextId()
```

getSegmentToOwnerCodec

public SegmentToOwnerCodec getSegmentToOwnerCodec()

initCodecs

public void initCodecs()
                throws Lot49Exception

Throws:: Lot49Exception

initDbServices
```
public void initDbServices()
                    throws Lot49Exception
```
Initialize a DbService for every item in DbConfigs, and throw an exception the first time an error happens.

Throws:

Lot49Exception

getDbServiceByName

public final DbService getDbServiceByName(String name)

initSecurityManager
```
public void initSecurityManager()
```

initCaches

public void initCaches()
                throws Lot49Exception

Throws:: Lot49Exception

setOpts

public void setOpts(org.apache.commons.cli.Options opts)

getConfig
```
public Lot49Config getConfig()
```

parseCommandLineArgs

public void parseCommandLineArgs(String[] argv)
                          throws Lot49Exception

Throws:: Lot49Exception

usage
```
protected void usage()
```

setConfig
```
public void setConfig(Lot49Config config)
```
Intended for use in tests - this has no effect if loaded after initial startup.

Parameters:

config - the configuration

loadConfig

public Lot49Config loadConfig()
                       throws Lot49Exception

Throws:: Lot49Exception

updateSubcriptionData
```
public void updateSubcriptionData()
```

getIntegralService

public IntegralService getIntegralService()

initIntegral
```
public void initIntegral()
```

Class ServiceRunner

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

runner

opts

cl

hazelcastService

maxMind

orchestrator

userAttributesCacheService

userSegmentsCacheService

sandboxSecurityManager

adCache

config

configFilename

scheduledExecutor

executor

integralService

providers

lastRolloverEnforcerRan

dbServices

counter

segmentToOwnerCodec

COLLECTIONS_DB_SERVICE

Constructor Detail

ServiceRunner

Method Detail

getInstance

getAdCache

getUserAttributesCacheService

getUserSegmentsCacheService

getScheduledExecutor

getExecutor

getConfigFilename

getSandboxSecurityManager

initExecutors

getCl

initProviders

getProviders

getMaxMind

initGeo

initOrchestrator

initLogging

getOpts

getOrchestrator

getRolloverEnforcerId

scheduleLogRolloverEnforcer

initAdapters

setCl

getHazelcastService

getNextId

getSegmentToOwnerCodec

initCodecs

initDbServices

getDbServiceByName

initSecurityManager

initCaches

setOpts

getConfig

parseCommandLineArgs

usage

setConfig

loadConfig

updateSubcriptionData

getIntegralService

initIntegral