Real-time message-based information generation

A method for real-time message-based information generation for providing real-time merchandise offer to a customer in a store, the method being performed by one or more hardware processors that support multiple-thread processing, the method comprising:

• receiving a plurality of input data files from a plurality of source systems in a plurality of data formats, each input data file comprising a plurality of records;
• extracting, from each input data file, the plurality of records on a record-by record basis;
• transforming each extracted record from among the plurality of records to a transformed data record that complies with a messaging format;
• constructing a message for each transformed data record according to the messaging format by mapping each field of the transformed data record to a field of the message, the message comprising a header and a body;
• determining expiration time that indicates a time window within which the message is to be transferred to a second system, based on physical size of the store, association of a customer identifier with location information of the store, time information indicating time at which the location information is acquired, shopping preference of the customer, and rate at which the customer is travelling in the store;
• and
• prioritizing transfer of the message to the second system by queuing the message based on the expiration time, wherein the message enables the second system to generate a merchandise offer information based on the transformed data record.

A non-transitory computer readable storage medium storing a program that, when executed by one or more hardware processors that support multiple-thread processing, causes the one or more hardware processors to perform a method for real-time message-based information generation for providing real-time merchandise offer to a customer in a store, the method comprising:

• receiving a plurality of input data files from a plurality of source systems in a plurality of data formats, each input data file comprising a plurality of records;
• extracting, from each input data file, the plurality of records on a record-by-record basis;
• transforming each extracted record from among the plurality of records to a transformed data record that complies with a messaging, format;
• constructing a message for each transformed data record according to the messaging format by mapping each field of the transformed data record to a field of the message, the message comprising a header and body;
• determining expiration time that indicates a time window within which the message is to be transferred to a second system, based on physical size of the store, association of a customer identifier with location information of the store, time information indicating time at which the location information is acquired, shopping preference of the customer, and rate at which the customer is travelling in the store;
• and
• prioritizing transfer of the message to the second system by queuing the message based on the expiration time, wherein the message enables the second system to generate merchandise offer information based on the transformed data record.