Method and apparatus for stream descriptor binding in a streaming environment

An apparatus comprising at least one processor and at least one memory including computer program code for one or more programs, the at least one memory and the computer program code configured to, with the at least one processor, cause the apparatus at least to:

• receive at a stream registry a stream register message associated with a stream from a streaming entity, wherein the stream register message includes a binding descriptor and a routing descriptor, wherein the binding descriptor is operable for querying one or more streams in instances in which the streaming entity comprises a source, and wherein the routing descriptor is operable for querying the one or more streams in an instance in which the streaming entity comprises a sink;
• cause transmission from the stream registry of a create connection message to a stream broker;
• cause transmission from the stream registry of an endpoint message including a set of connection parameters of an endpoint to the streaming entity;
• receive at the stream registry a query for the stream from a stream processing node;
• and
• cause transmission from the stream registry of a response to the query to the stream processing node, wherein the response includes a set of connection parameters of the stream broker.

A computer program product comprises at least one non-transitory computer-readable storage medium having computer executable program code instructions stored therein, the computer executable program code instructions comprising program code instructions configured, upon execution, to:

• receive at a stream registry a stream register message associated with a stream from a streaming entity, wherein the stream register message includes a binding descriptor and a routing descriptor, wherein the binding descriptor is operable for querying one or more streams in instances in which the streaming entity comprises a source, and wherein the routing descriptor is operable for querying the one or more streams in an instance in which the streaming entity comprises a sink;
• cause transmission from the stream registry of a create connection message to a stream broker;
• cause transmission from the stream registry of an endpoint message including a set of connection parameters of an endpoint to the streaming entity;
• receive at the stream registry a query for the stream from a stream processing node;
• and
• cause transmission from the stream registry of a response to the query to the stream processing node, wherein the response includes a set of connection parameters of the stream broker.