Package com.caplin.datasource.blotter.impl

Class RuntimeImpl

java.lang.Object

com.caplin.datasource.blotter.impl.RuntimeImpl

All Implemented Interfaces:

com.caplin.container.impl.Runtime

public class RuntimeImpl
extends Object
implements com.caplin.container.impl.Runtime

Constructor Summary

Constructors

Constructor	Description
RuntimeImpl(com.caplin.datasource.DataSource dataSource, BlotterConfiguration configuration, com.caplin.datasource.publisher.ActivePublisher containerPublisher, com.caplin.datasource.publisher.ActivePublisher recordPublisher)

Method Summary

Modifier and Type	Method	Description
long	currentTimeMillis()
void	execute(Runnable runnable)
com.caplin.container.impl.logger.LogLevel	getLogLevel()
com.caplin.monitoring.impl.MonitoringService	getMonitoringService()
String	getRandomUniqueId()
void	log(com.caplin.container.impl.logger.LogLevel logLevel, String message)
void	log(com.caplin.container.impl.logger.LogLevel logLevel, String message, Throwable thrown)
String	longToString(long value)
void	publishContainerNotFound(String subject)
void	publishContainerStatusOk(String subject)
void	publishContainerStatusOk(String subject, String message)
void	publishContainerStatusStale(String subject)
void	publishContainerStatusStale(String subject, String message)
void	publishContainerUpdate(String subject, com.caplin.container.impl.updates.ContainerUpdate update, boolean image, boolean initial)
void	publishDeleteContainer(String subject)
void	publishDeleteRecord(String subject)
void	publishMappingMessage(String subject, String mapto, boolean image)
void	publishRecordNotFound(String subject)
void	publishRecordStatusOk(String subject)
void	publishRecordStatusStale(String subject)
void	publishRecordUpdate(String subject, com.caplin.container.impl.updates.RecordUpdate update, boolean image, boolean initial)
void	publishRemoveContainerElements(String subject, List<String> elements)
com.caplin.container.impl.utils.Future	schedule(Runnable runnable, long millis, Object context)
void	userCallback(Runnable runnable)

Methods inherited from class java.lang.Object

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

Constructor Details

RuntimeImpl

public RuntimeImpl(com.caplin.datasource.DataSource dataSource,
 BlotterConfiguration configuration,
 com.caplin.datasource.publisher.ActivePublisher containerPublisher,
 com.caplin.datasource.publisher.ActivePublisher recordPublisher)

Method Details

longToString

public String longToString(long value)

Specified by:

longToString in interface com.caplin.container.impl.Runtime

currentTimeMillis

public long currentTimeMillis()

Specified by:

currentTimeMillis in interface com.caplin.container.impl.Runtime

publishRemoveContainerElements

public void publishRemoveContainerElements(String subject,
 List<String> elements)

Specified by:

publishRemoveContainerElements in interface com.caplin.container.impl.Runtime

log

public void log(com.caplin.container.impl.logger.LogLevel logLevel,
 String message)

Specified by:

log in interface com.caplin.container.impl.Runtime

log

public void log(com.caplin.container.impl.logger.LogLevel logLevel,
 String message,
 Throwable thrown)

getLogLevel

public com.caplin.container.impl.logger.LogLevel getLogLevel()

Specified by:

getLogLevel in interface com.caplin.container.impl.Runtime

publishContainerNotFound

public void publishContainerNotFound(String subject)

Specified by:

publishContainerNotFound in interface com.caplin.container.impl.Runtime

publishDeleteContainer

public void publishDeleteContainer(String subject)

Specified by:

publishDeleteContainer in interface com.caplin.container.impl.Runtime

publishRecordNotFound

public void publishRecordNotFound(String subject)

Specified by:

publishRecordNotFound in interface com.caplin.container.impl.Runtime

publishDeleteRecord

public void publishDeleteRecord(String subject)

Specified by:

publishDeleteRecord in interface com.caplin.container.impl.Runtime

publishContainerStatusStale

public void publishContainerStatusStale(String subject)

Specified by:

publishContainerStatusStale in interface com.caplin.container.impl.Runtime

publishContainerStatusOk

public void publishContainerStatusOk(String subject)

Specified by:

publishContainerStatusOk in interface com.caplin.container.impl.Runtime

publishContainerStatusStale

public void publishContainerStatusStale(String subject,
 String message)

Specified by:

publishContainerStatusStale in interface com.caplin.container.impl.Runtime

publishContainerStatusOk

public void publishContainerStatusOk(String subject,
 String message)

Specified by:

publishContainerStatusOk in interface com.caplin.container.impl.Runtime

publishRecordStatusStale

public void publishRecordStatusStale(String subject)

Specified by:

publishRecordStatusStale in interface com.caplin.container.impl.Runtime

publishRecordStatusOk

public void publishRecordStatusOk(String subject)

Specified by:

publishRecordStatusOk in interface com.caplin.container.impl.Runtime

userCallback

public void userCallback(Runnable runnable)

Specified by:

userCallback in interface com.caplin.container.impl.Runtime

execute

public void execute(Runnable runnable)

Specified by:

execute in interface com.caplin.container.impl.Runtime

schedule

public com.caplin.container.impl.utils.Future schedule(Runnable runnable,
 long millis,
 Object context)

Specified by:

schedule in interface com.caplin.container.impl.Runtime

getMonitoringService

public com.caplin.monitoring.impl.MonitoringService getMonitoringService()

Specified by:

getMonitoringService in interface com.caplin.container.impl.Runtime

publishMappingMessage

public void publishMappingMessage(String subject,
 String mapto,
 boolean image)

Specified by:

publishMappingMessage in interface com.caplin.container.impl.Runtime

publishContainerUpdate

public void publishContainerUpdate(String subject,
 com.caplin.container.impl.updates.ContainerUpdate update,
 boolean image,
 boolean initial)

Specified by:

publishContainerUpdate in interface com.caplin.container.impl.Runtime

publishRecordUpdate

public void publishRecordUpdate(String subject,
 com.caplin.container.impl.updates.RecordUpdate update,
 boolean image,
 boolean initial)

Specified by:

publishRecordUpdate in interface com.caplin.container.impl.Runtime

getRandomUniqueId

public String getRandomUniqueId()

Specified by:

getRandomUniqueId in interface com.caplin.container.impl.Runtime