datasourcex-util/com.caplin.integration.datasourcex.util/LifecycleDataSource

LifecycleDataSource

interface LifecycleDataSource : DataSource, AutoCloseable(source)

Types

Companion

object Companion

Properties

configuration

abstract val configuration: DataSourceConfiguration?

extraConfiguration

abstract val extraConfiguration: Configuration?

fieldManager

abstract val fieldManager: FieldManager?

logger

abstract val logger: Logger?

mBeanServer

abstract val mBeanServer: MBeanServer?

peers

abstract val peers: Set<Peer?>?

peersInOrder

abstract val peersInOrder: List<Peer?>?

peerStates

abstract val peerStates: SharedFlow<Map<Peer, PeerStatus>>

Functions

addChannelListener

abstract fun addChannelListener(p0: Namespace?, p1: ChannelListener?)

addConnectionListener

abstract fun addConnectionListener(p0: ConnectionListener?)

addGenericChannelListener

abstract fun addGenericChannelListener(p0: Namespace?, p1: ChannelListener?)

addJsonChannelListener

abstract fun addJsonChannelListener(p0: Namespace?, p1: JsonChannelListener?)

awaitConnected

abstract suspend fun awaitConnected()

abstract fun close()

createActiveJsonSubscription

abstract fun <T : Any?> createActiveJsonSubscription(p0: String?, p1: SubjectConsumer<T?>?, p2: Class<T?>?): ActiveSubscription?

createActivePublisher

abstract fun createActivePublisher(p0: Namespace?, p1: DataProvider?): ActivePublisher?

createActiveSubscription

abstract fun createActiveSubscription(p0: String?, p1: SubscriptionListener?): ActiveSubscription?

createBroadcastJsonSubscription

abstract fun <T : Any?> createBroadcastJsonSubscription(p0: Namespace?, p1: SubjectConsumer<T?>?, p2: Class<T?>?): BroadcastSubscription?

createBroadcastPublisher

abstract fun createBroadcastPublisher(p0: Namespace?): BroadcastPublisher?

createBroadcastSubscription

abstract fun createBroadcastSubscription(p0: Namespace?, p1: SubscriptionListener?): BroadcastSubscription?

createCachingPublisher

abstract fun createCachingPublisher(p0: Namespace?, p1: CachingDataProvider?): CachingPublisher?

abstract fun createCachingPublisher(p0: String?, p1: Namespace?, p2: CachingDataProvider?): CachingPublisher?

createCompatibilityPublisher

abstract fun createCompatibilityPublisher(p0: Namespace?, p1: DataProvider?): CompatibilityPublisher?

createService

abstract fun createService(@NotNull p0: @NotNull Service)

getCommandOption

abstract fun getCommandOption(p0: String?, vararg p1: String?): String?

removeConnectionListener

abstract fun removeConnectionListener(p0: ConnectionListener?)

setStatusDown

abstract fun setStatusDown()

setStatusUp

abstract fun setStatusUp()

start

abstract fun start()

stop

abstract fun stop()