Package com.caplin.datasource.notification.impl

Class RuntimeImpl

java.lang.Object

com.caplin.datasource.notification.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, NotificationConfiguration 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)
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	publishListRowFieldsUpdate(String listSubject, String recordSubject, com.caplin.container.impl.updates.RecordUpdate update)
void	publishListUpdate(String subject, com.caplin.container.impl.updates.ContainerUpdate update, boolean image, boolean initial)
void	publishMappingMessage(String mapfrom, 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,
 NotificationConfiguration configuration,
 com.caplin.datasource.publisher.ActivePublisher containerPublisher,
 com.caplin.datasource.publisher.ActivePublisher recordPublisher)

Method Details

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

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

publishContainerStatusStale

public void publishContainerStatusStale(String subject,
 String message)

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

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

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

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

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

publishMappingMessage

public void publishMappingMessage(String mapfrom,
 String mapTo,
 boolean image)

Specified by:

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

getRandomUniqueId

public String getRandomUniqueId()

Specified by:

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

publishListUpdate

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

Specified by:

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

publishListRowFieldsUpdate

public void publishListRowFieldsUpdate(String listSubject,
 String recordSubject,
 com.caplin.container.impl.updates.RecordUpdate update)

Specified by:

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