注册阶段期间,代理发现可用的资源,以及可以为它们提供的 LIL。在此示例中,可用资源是节点。当执行组启动时该阶段开始。执行组启动时装入 LIL,并且代理将查询它们以找出它们可以提供的资源。
在注册阶段期间,当用户定义的节点调用 cniCreateNodeFactory 时,创建 CciFactory 结构。
当启动 mqsistart 命令或重新启动执行组进程时,或当部署与节点关联的消息流时,将创建用户定义的输入节点的实例。
在此阶段期间,创建 CciTerminal 结构。当调用 cniCreateTerminal 时,创建此结构。
当代理调用 cniRun 函数时开始处理阶段。代理使用 cniRun 函数来确定如何处理消息,包括确定定义消息的域,以及为该域调用相关的解析器。
需要来自消息流的线程池,并在输入节点的运行方法中开始的线程。该线程连接到代理的队列管理器,并为其生命期保留此连接。当线程已经分配时,当节点等待接收消息时,它进入消息处理循环。直到接收到消息,它才会跳出循环。如果消息流配置为使用多个线程,则激活线程分派。
现在可以下行传播消息。