Browse Prior Art Database

Utilisation of asynchronous messaging queue points to perform initial message processing

IP.com Disclosure Number: IPCOM000227615D
Publication Date: 2013-May-09
Document File: 3 page(s) / 62K

Publishing Venue

The IP.com Prior Art Database

Abstract

The invention proposes the identification of situations where messages build up on message queue points, there are spare CPU cycles available and there is an opportunity to perform operations on the queued messages that would provide increased operational benefit than if the messages were processed only by the consuming application.

This text was extracted from a PDF file.
This is the abbreviated version, containing approximately 52% of the total text.

Page 01 of 3

Utilisation of asynchronous messaging queue points to perform initial message processing

Message oriented middle-ware provides implementations of queueing systems, in support of industry standard specifications such as Java Messaging Service (JMS) for instance. There are many situations when messages build up on message queue points when there are often spare Central Processing Unit (CPU) cycles available and the opportunity to perform operations on the queued messages. This is particularly relevant in situations where messages are not processed concurrently


(i.e. when there is a need to preserve message ordering, throttling is enforced, or message consumer is unavailable). In these situations performing any processing of the message outside of any single threaded processing can provided distinct performance advantages.

    The invention proposes the identification and utilisation of these situations to perform operations that would provide operational benefit: utilising available CPU cycles to perform up-front message processing, validation or analytics.

    Utilisation of metrics such as CPU utilisation, queue depth, average wait time, etc would be used as input to determine whether it is viable to perform any operations in the time the message would otherwise be in a "waiting" state. The system would store information on the time it took to perform the defined operation against the environment metrics to better aid a determination of whether performing the operation would be a viable option in the future for given input parameters.

    Handlers could be provided for specific queue points such that specific operations could be performed, for instance if the message is bound for an application requiring strict message ordering then it is likely the application would be single threaded and there would be a queue of messages building to be processed at any time. After analysing the available heuristic data an intelligent decision can be made whether to perform message processing whilst the message is waiting on the queue point.

Operations could involve:
Ex...