Methods, systems and devices for pipeline processing
Methods, servers and systems for communicating signaling information in a telecommunications signaling network implement methods that include receiving a first message encoding signaling information from a source component and processing the message using a fixed pipeline having a plurality of modules, each module having at least one procedure for performing a specific set of tasks. Application level routing operations may be performed to identify a suitable destination component. Information contained in the first message may be used to generate a second message encoding signaling information, which is sent to the identified destination component.
1. A method of communicating signaling information in a telecommunications signaling network, comprising:
receiving, in a processor, a first message encoding signaling information from a source component;
decoding the received first message into an internal representation that stores the signaling information included in the received first message in two or more structured information fields;
processing the internal representation via a pipeline having a plurality of stages, each stage including one or more procedures for performing a specific set of tasks, wherein one of the tasks includes using a key included in the first message to augment the signaling information in one of the structured information fields;
performing application level routing operations using contextual information derived from processing the internal representation in one of the plurality of stages to identify a destination component;
encoding the signaling information contained in the two or more structured information fields of the internal representation into a second message; and
sending the second message encoding the signaling information to the identified destination component.
2. The method of claim 1 , wherein performing application level routing operations using contextual information derived from processing the internal representation in one of the plurality of stages to identify a destination component comprises:
using at least one pipeline stage to make a routing decision using a discrete number of configurable procedures.
3. The method of claim 1 , wherein processing the internal representation via the pipeline comprises processing the internal representation via one of:
a request handler pipeline;
a response handler pipeline;
a failover handler pipeline; and
a redirect handler pipeline.
4. The method of claim 1 , wherein processing the internal representation via the pipeline comprises processing the internal representation in one of:
a realm routing lookup stage;
a session lookup stage;
a gather data stage;
a routing core stage;
a prepare attribute value stream (AVS) stage;
a filter stage;
a dispatcher stage;
a session update stage; and
a redirect stage.
5. A server configured for use in a telecommunications signaling network, comprising:
a processor configured with processor-executable instructions to perform operations comprising:
receiving a first message encoding signaling information from a source component;
decoding the received first message into an internal representation that stores the signaling information included in the received first message in two or more structured information fields;
processing the internal representation via a pipeline having a plurality of stages, each stage including one or more procedures for performing a specific set of tasks, wherein one of the tasks includes using a key included in the first message to augment the signaling information in one of the structured information fields;
performing application level routing operations using contextual information derived from processing the internal representation in one of the plurality of stages to identify a destination component;
encoding the signaling information contained in the two or more structured information fields of the internal representation into a second message; and
sending the second message encoding the signaling information to the identified destination component.
6. The server of claim 5 , wherein the processor is configured with processor-executable instructions to perform operations such that performing application level routing operations using contextual information derived from processing the internal representation in one of the plurality of stages to identify a destination component comprises:
using at least one pipeline stage to make a routing decision using a discrete number of configurable procedures.
7. The server of claim 5 , wherein the processor is configured with processor-executable instructions to perform operations such that processing the internal representation comprises processing the internal representation via one of:
a request handler pipeline;
a response handler pipeline;
a failover handler pipeline; and
a redirect handler pipeline.
8. The server of claim 5 , wherein the processor is configured with processor-executable instructions to perform operations such that processing the internal representation comprises processing the internal representation in one of:
a realm routing lookup stage;
a session lookup stage;
a gather data stage;
a routing core stage;
a prepare attribute value stream (AVS) stage;
a filter stage;
a dispatcher stage;
a session update stage; and
a redirect stage.
9. A non-transitory server-readable storage medium having stored thereon server-executable instructions configured to cause a server to perform operations comprising:
receiving a first message encoding signaling information from a source component;
decoding the received first message into an internal representation that stores the signaling information included in the received first message in two or more structured information fields;
processing the internal representation via a pipeline having a plurality of stages, each stage including one or more procedures for performing a specific set of tasks, wherein one of the tasks includes using a key included in the first message to augment the signaling information in one of the structured information fields;
performing application level routing operations using contextual information derived from processing the internal representation in one of the plurality of stages to identify a destination component;
encoding the signaling information contained in the two or more structured information fields of the internal representation into a second message; and
sending the second message encoding the signaling information to the identified destination component.
10. The non-transitory server-readable storage medium of claim 9 , wherein the stored server-executable instructions are configured to cause a server to perform operations such that processing the internal representation and performing application level routing operations using contextual information derived from processing the internal representation in one of the plurality of stages to identify a destination component comprises:
using at least one pipeline stage to make a routing decision using a discrete number of configurable procedures.
11. The non-transitory server-readable storage medium of claim 9 , wherein the stored server-executable instructions are configured to cause a server to perform operations such that processing the internal representation comprises processing the internal representation via one of:
a request handler pipeline;
a response handler pipeline;
a failover handler pipeline; and
a redirect handler pipeline.
12. The non-transitory server-readable storage medium of claim 9 , wherein the stored server-executable instructions are configured to cause a server to perform operations such that processing the internal representation comprises processing the internal representation in one of:
a realm routing lookup stage;
a session lookup stage;
a gather data stage;
a routing core stage;
a prepare attribute value stream (AVS) stage;
a filter stage;
a dispatcher stage;
a session update stage; and
a redirect stage.