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 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