公开(公告)号：EP3099027A1

公开(公告)日：2016-11-30

申请号：EP15169119.3

申请日：2015-05-26

Applicant: Urban Software Institute GmbH

Inventor： Borgert, Stephan

IPC: H04L12/891 ,  H04L12/801 ,  H04L12/58

CPC classification number: H04L41/046 ,  H04L47/10 ,  H04L47/41 ,  H04L51/14 ,  H04L51/34 ,  H04L67/34

Abstract: A first agent device (100), computer-implemented method and computer program product for message routing with content passing and reference passing for a distributed system (500) with a plurality of interacting agent devices (100, 201, 202, 203, 300) wherein the interaction between the interacting agent devices occurs through exchange of messages, an exchanged message including a content portion (CP) and a reference identifier (RI) associated with a particular agent device. The reference identifier (RI) enables any other agent device to establish a communication with the particular agent device. The content portion (CP) has a type which is either a content type or a message-set type. The first agent device (100) includes a first interface component (110) configured to load a first agent class specification (152) defining a first finite state machine (FSM1) which is configured to control the function of the first agent device (100) when executed by a process execution engine (121). Further, a second interface component (120) is configured to retrieve at least a subset of a plurality of messages (M2_1, M2_2, M2_3) from a message buffer (151), the plurality of buffered messages (M2_1, M2_2, M2_3) originating from a plurality of multi-agent devices (201, 202, 203) linked to a second agent class specification defining a second finite state machine (FSM2). The first finite state machine (FSM1) and the second finite state machine (FSM2) enable the interaction of the first agent device (100) with the plurality of multi-agent devices (201, 202, 203). Further, the first agent device has at least one processor component (130) configured to run the process execution engine (121) and, in accordance with the first finite state machine (FSM1), to process retrieved messages (M2_1, M2_2, M2_3), to generate an aggregate message (M3) including at least a subset of the buffered messages (M2_1, M2_2, M2_3) in the content portion (CP) of the aggregate message (M3), and to provide the aggregate message (M3) for further processing.

Abstract translation: 第一代理设备（100），用于具有多个交互代理设备（100,201,202,203,300）的分布式系统（500）的内容传递和参考传递的消息路由的计算机实现的方法和计算机程序产品， 其中所述交互代理设备之间的交互通过消息的交换发生，包括与特定代理设备相关联的内容部分（CP）和参考标识符（RI）的交换的消息。 参考标识符（RI）使得任何其他代理设备能够建立与特定代理设备的通信。 内容部分（CP）具有内容类型或消息集类型的类型。 第一代理设备（100）包括被配置为加载定义第一有限状态机（FSM1）的第一代理类规范（152）的第一接口组件（110），其被配置为控制第一代理设备（100）的功能， 当由处理执行引擎（121）执行时。 此外，第二接口组件（120）被配置为从消息缓冲器（151）检索多个消息（M2_1，M2_2，M2_3）的至少一个子集，所述多个缓冲消息（M2_1，M2_2，M2_3）发起 从多个多代理设备（201,202,203）中链接到定义第二有限状态机（FSM2）的第二代理类规范。 第一有限状态机（FSM1）和第二有限状态机（FSM2）能够使第一代理设备（100）与多个多代理设备（201,202,203）的交互。 此外，第一代理设备具有被配置为运行处理执行引擎（121）的至少一个处理器组件（130），并且根据第一有限状态机（FSM1）处理检索到的消息（M2_1，M2_2，M2_3） ，以产生包括聚合消息（M3）的内容部分（CP）中的缓冲消息（M2_1，M2_2，M2_3）的至少一个子集的聚合消息（M3），并且为聚合消息（M3）提供聚合消息 进一步处理。

公开(公告)号：EP3099027B1

公开(公告)日：2017-09-13

申请号：EP15169119.3

申请日：2015-05-26

Applicant: Urban Software Institute GmbH

Inventor： Borgert, Stephan

IPC: H04L12/891 ,  H04L12/801 ,  H04L12/58

CPC classification number: H04L41/046 ,  H04L47/10 ,  H04L47/41 ,  H04L51/14 ,  H04L51/34 ,  H04L67/34

Abstract: A first agent device (100), computer-implemented method and computer program product for message routing with content passing and reference passing for a distributed system (500) with a plurality of interacting agent devices (100, 201, 202, 203, 300) wherein the interaction between the interacting agent devices occurs through exchange of messages, an exchanged message including a content portion (CP) and a reference identifier (RI) associated with a particular agent device. The reference identifier (RI) enables any other agent device to establish a communication with the particular agent device. The content portion (CP) has a type which is either a content type or a message-set type. The first agent device (100) includes a first interface component (110) configured to load a first agent class specification (152) defining a first finite state machine (FSM1) which is configured to control the function of the first agent device (100) when executed by a process execution engine (121). Further, a second interface component (120) is configured to retrieve at least a subset of a plurality of messages (M2_1, M2_2, M2_3) from a message buffer (151), the plurality of buffered messages (M2_1, M2_2, M2_3) originating from a plurality of multi-agent devices (201, 202, 203) linked to a second agent class specification defining a second finite state machine (FSM2). The first finite state machine (FSM1) and the second finite state machine (FSM2) enable the interaction of the first agent device (100) with the plurality of multi-agent devices (201, 202, 203). Further, the first agent device has at least one processor component (130) configured to run the process execution engine (121) and, in accordance with the first finite state machine (FSM1), to process retrieved messages (M2_1, M2_2, M2_3), to generate an aggregate message (M3) including at least a subset of the buffered messages (M2_1, M2_2, M2_3) in the content portion (CP) of the aggregate message (M3), and to provide the aggregate message (M3) for further processing.

Abstract translation: 用于具有多个交互代理设备（100,201,202,203，300）的分布式系统（500）的内容传递和参考传递的消息路由的第一代理设备（100），计算机实现的方法和计算机程序产品， 其中交互代理设备之间的交互通过消息的交换发生，所交换的消息包括与特定代理设备相关联的内容部分（CP）和参考标识符（RI）。 参考标识符（RI）使任何其他代理设备能够建立与特定代理设备的通信。 内容部分（CP）具有内容类型或消息集类型。 第一代理设备（100）包括被配置为加载定义第一有限状态机（FSM1）的第一代理类规范（152）的第一接口组件（150），该第一有限状态机被配置为控制第一代理设备（100）的功能， 当由过程执行引擎（121）执行时。 此外，第二接口组件（120）被配置为从消息缓冲器（151）中检索多个消息（M2_1，M2_2，M2_3）的至少一个子集，所述多个缓冲消息（M2_1，M2_2，M2_3） 从链接到定义第二有限状态机（FSM2）的第二代理类规范的多个多代理设备（201,202,203）中选择一个。 第一有限状态机（FSM1）和第二有限状态机（FSM2）实现第一代理设备（100）与多个多代理设备（201,202,203）的交互。 此外，第一代理设备具有至少一个处理器组件（130），其被配置为运行处理执行引擎（121），并且根据第一有限状态机（FSM1）处理检索到的消息（M2_1，M2_2，M2_3） 以生成包括聚合消息（M3）的内容部分（CP）中的缓冲消息（M2_1，M2_2，M2_3）的至少一个子集的聚合消息（M3），并且提供用于聚合消息 进一步处理。