broker/implementations/PmonClient

PmonClient

open class PmonClient(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 = msg.getSource().toTopicName())

open override fun controller(msg: ProtoMessageWrapper)

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

fun installBroker(brokerProps: Map<String, Any> = mapOf( ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG to "false", "app.id" to thisManager.id.toGroupName() ))

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 = getUUID(), inData: ProtoMessageWrapper, destTopic: String = "")

suspend fun sendAndReceive(msg: ProtoMessageWrapper, topicName: String = Config.getPmonTopicName(), messageId: String = UUID.randomUUID().toString(), waitTime: Long = TIME_5S): ProtoMessageWrapper

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

sendDelMgrInCfg

fun sendDelMgrInCfg(id: ProtoManId.Builder): String

sendManagerToPmon

fun sendManagerToPmon(manager: ProtoManager.Builder = thisManager)

fun sendReduGetFw(): ProtoMessageWrapper

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)