US 9,003,062 B1Granted

Framework for exchanging large B2B transactional in-order messages using distributed file system (DFS) and associated method

AssigneeSoftware AG

InventorsAditya Babu Nampally, Vishal Byakod, Sriram Mohan Telagareddy

Life of this patent

Estimating the term…

Loading patent…

Abstract

Certain example embodiments relate to a framework that helps address dynamic scalability and in-order processing of payloads, e.g., pertaining to B2B and/or other transactions. A receiver and/or sender is/are able to dynamically and/or statically provide an executable to an intermediary entity (e.g., a central payload processor or CPP) to process and/or otherwise transform payloads, en-route. This arrangement advantageously provides a very efficient way of delivering ordered content, especially when the content is extremely large. Cloud processing and/or storage facilities may be implemented in certain example instances, parallel sending and/or receiving may be provided, etc., in addressing issues relating to how to send large amounts of data over large distances to possibly multiple recipients.

Claims29

Dependent claims

A method of processing at a central payload processor (CPP) payloads sent from a sending entity, the method comprising:

receiving, by the CPP from the sending entity over a network, a payload for processing for one or more receiving entities, wherein the one or more receiving entities does not include the sending entity;
determining, by the CPP for each of the one or more receiving entities, that an appropriate bundle of executable logic is currently unavailable at the CPP for processing the received payload for the respective receiving entity in a cache of the CPP;
for each said receiving entity, processing based on the determining, by the CPP, the payload, the processing comprising:
in response to a determination that there are no appropriate bundles of executable logic currently available at the CPP for processing the received payload for the respective receiving entity, attempting to retrieve a new bundle of executable logic from the one or more receiving entities and in response to retrieval of the new bundle of executable logic, perform the processing of the received payload using at least one processor of the CPP in connection with the retrieved new bundle of executable logic,
wherein, the CPP is configured to attempt to perform the processing of the received payload using at least one processor of the CPP in connection with a currently available bundle of executable logic when the appropriate bundle of executable logic is currently available at the CPP;
and
following processing of the received payload, transmitting results of the processing to the one or more receiving entities over the network or storing the results in a non-transitory computer readable storage medium of the CPP for retrieval by the one or more receiving entities over the network.

4 more elements

A central payload processor (CPP), comprising:

at least one processor and a memory;
a file system backed by non-transitory computer readable storage media;
a cache of executable programs;
and
a communication channel configured to receive at the CPP, from a sending entity over a network, a group of payloads for processing for at least one receiving entity, wherein the at least one receiving entity does not include the sending entity;
wherein, in response to a group of payloads being received over the communication channel, the at least one processor, for each said payload in the group, is configured to:
determine, for each said receiving entity, whether an executable program is currently available in the cache for processing the respective payload for the respective receiving entity,
for each said receiving entity:
(a) in response to a determination that there is an executable program currently available in the cache for processing the respective payload for the respective receiving entity, attempt to process the respective payload using the at least one processor of the CPP in connection with that currently available executable program, and (b) in response to a determination that there are no executable programs currently available in the cache for processing the respective payload for the respective receiving entity, retrieve a new executable program from the respective receiving entity and process the respective payload using the at least one processor of the CPP in connection with the new retrieved executable program, and
following processing of the respective payload, transmit results of the processing to the at least one respective receiving entity over a network.

7 more elements

A computer system, comprising:

at least one sending entity;
at least one receiving entity;
and
a payload processor including:
at least one processor and a memory,
a file system backed by non-transitory computer readable storage media,
a cache of executable programs, and
a communication channel configured to receive, from the at least one sending entity over a network, a group of payloads for processing for at least one receiving entity, wherein the at least one receiving entity does not include the at least one sending entity;
wherein, in response to a group of payloads being received over the communication channel, the at least one processor of the payload processor, for each said payload in the group, is configured to:
determine, for each said receiving entity, whether an executable program is currently available in the cache for processing the respective payload for the respective receiving entity,
for each said receiving entity:
(a) in response to a determination that there is an executable program currently available in the cache for processing the respective payload for the respective receiving entity, process the respective payload using the at least one processor of the payload processor in connection with that currently available executable program, and (b) in response to a determination that there are no executable programs currently available in the cache for processing the respective payload for the respective receiving entity, retrieve a new executable program from the respective receiving entity and process the respective payload using the at least one processor of the payload processor in connection with the newly retrieved executable program, and
following processing of the respective payload, transmit results of the processing to a respective receiving entity over a network.

10 more elements

Dependencies are inferred from the claim text.