pmon_service/handler/ServiceClient

ServiceClient

class ServiceClient(id: ProtoManId) : PmonHandler

Constructors

constructor(id: ProtoManId)

Properties

lateinit var broker: MessageBroker<ByteString, ProtoMessageWrapper>

isManagerNumberReceived

var isManagerNumberReceived: Boolean

var manId: ProtoManId

pendingResponses

val pendingResponses: ConcurrentHashMap<String, CompletableDeferred<ProtoMessageWrapper>>

var requestedIds: MutableMap<ByteString, ProtoManager.Builder>

var thisManager: ProtoManager.Builder

Functions

fun answer(msg: ProtoMessageWrapper, txt: String, topic: String)

open override fun controller(msg: ProtoMessageWrapper)

fun getRequested(id: ByteString): ProtoManager.Builder?

initFeatureHandler

fun initFeatureHandler()

fun installBroker(brokerProps: Map<String, Any>)

isBrokerConnected

fun isBrokerConnected(): Boolean

isBrokerInitialized

fun isBrokerInitialized(): Boolean

isPmonAvailable

fun isPmonAvailable(): Boolean

open override fun mgrInit()

fun mgrIsAlive()

requestManagerState

fun requestManagerState(id: ProtoManId.Builder)

requestNumAndStart

fun requestNumAndStart()

fun send(id: ByteString, inData: ProtoMessageWrapper, destTopic: String)

suspend fun sendAndReceive(msg: ProtoMessageWrapper, topicName: String, messageId: String, waitTime: Long): ProtoMessageWrapper

fun sendCmdToMgr(cmd: ProtoCmdType, mgr: ProtoManager.Builder): ProtoMessageWrapper

sendDelMgrInCfg

fun sendDelMgrInCfg(id: ProtoManId.Builder): String

sendManagerToPmon

fun sendManagerToPmon(manager: ProtoManager.Builder)

fun sendReduGetFw(): ProtoMessageWrapper

fun sendStopToMgr(mgr: ProtoManager.Builder)

fun sendUpMgrInCfg(mgr: ProtoManager.Builder): Boolean

fun start(topicName: String)

fun stopManager(incomingUUID: ByteString)

fun subscribe(topicName: String)

subscribeToService

fun subscribeToService()

unsubscribeFromService

fun unsubscribeFromService()

open override fun updateState(msg: ProtoMessageWrapper)