Computer data communications in a high speed, low latency data communications environment
First Claim
1. A method comprising:
- issuing a request, from an application of a contributing client device to a stream administration server, for authorization to contribute messages from the application to a feed adapter within a data communications environment via a message stream which bypasses the stream administration server, wherein,the feed adapter is coupled to a feed source via a feed adapter input stream and to at least one subscribing device via a feed adapter output stream,the feed source is separate from the contributing client device, andthe feed adapter input stream is separate from the message stream;
receiving, in response to the request and an authentication of the contributing client device, a set of constraints on messages to be transmitted from the contributing client device to the feed adapter, wherein the set of constraints specifies one or more topics of messages that the contributing client device is authorized to contribute to the feed adapter;
establishing the set of constraints in messaging middleware of the contributing client device;
receiving, in the messaging middleware of the contributing client device from the application of the contributing client device, a message for transmission to the feed adapter on the message stream;
determining, by the messaging middleware of the contributing client device, whether contents of the message satisfy the set of constraints, wherein the determining comprisescomparing a topic associated with the message with the one or more topics of messages that the contributing client device is authorized to contribute to the feed adapter; and
administering the message, by the messaging middleware of the contributing client device, in dependence upon whether the message satisfies the set of constraints, wherein said administering the message comprises;
authorizing transmission of the message on the message stream in dependence upon whether the message satisfies the set of constraints, and transmitting the message from the contributing client device to the feed adapter, bypassing the stream administration server, in response to an authorization of transmission of the message on the message stream;
orlogging the message in dependence upon whether the message satisfies the set of constraints.
1 Assignment
0 Petitions
Accused Products
Abstract
Methods, apparatus, and products are disclosed for computer data communications in a high speed, low latency data communications environment that include: brokering, by a stream administration server, establishment of a message stream from a contributing client device to a feed adapter, including authenticating the contributing client device, authorizing the contributing client device to send messages to the feed adapter on the message stream, and establishing in messaging middleware of the contributing client device a set of constraints on messages to be transmitted from the contributing client device to the feed adapter; receiving, in the messaging middleware of the contributing client device from an application of the contributing client device, a message for transmission to the feed adapter on the message stream; determining, by the messaging middleware, whether contents of the message satisfy the constraints; and administering the message, by the messaging middleware, in dependence upon whether the message satisfies the constraints.
103 Citations
12 Claims
-
1. A method comprising:
-
issuing a request, from an application of a contributing client device to a stream administration server, for authorization to contribute messages from the application to a feed adapter within a data communications environment via a message stream which bypasses the stream administration server, wherein, the feed adapter is coupled to a feed source via a feed adapter input stream and to at least one subscribing device via a feed adapter output stream, the feed source is separate from the contributing client device, and the feed adapter input stream is separate from the message stream; receiving, in response to the request and an authentication of the contributing client device, a set of constraints on messages to be transmitted from the contributing client device to the feed adapter, wherein the set of constraints specifies one or more topics of messages that the contributing client device is authorized to contribute to the feed adapter; establishing the set of constraints in messaging middleware of the contributing client device; receiving, in the messaging middleware of the contributing client device from the application of the contributing client device, a message for transmission to the feed adapter on the message stream; determining, by the messaging middleware of the contributing client device, whether contents of the message satisfy the set of constraints, wherein the determining comprises comparing a topic associated with the message with the one or more topics of messages that the contributing client device is authorized to contribute to the feed adapter; and administering the message, by the messaging middleware of the contributing client device, in dependence upon whether the message satisfies the set of constraints, wherein said administering the message comprises; authorizing transmission of the message on the message stream in dependence upon whether the message satisfies the set of constraints, and transmitting the message from the contributing client device to the feed adapter, bypassing the stream administration server, in response to an authorization of transmission of the message on the message stream;
orlogging the message in dependence upon whether the message satisfies the set of constraints. - View Dependent Claims (2, 3, 4, 5)
-
-
6. An apparatus for computer data communications in a data communications environment, the apparatus comprising one or more computer processors, one or more computer memories operatively coupled to the one or more computer processors, the computer memories having disposed within them computer program instructions capable of:
-
issuing a request, from an application of a contributing client device to a stream administration server, for authorization to contribute messages from the application to a feed adapter within the data communications environment via a message stream which bypasses the stream administration server, wherein, the feed adapter is coupled to a feed source via a feed adapter input stream and to at least one subscribing device via a feed adapter output stream, the feed source is separate from the contributing client device, and the feed adapter input stream is separate from the message stream; receiving, in response to the request and an authentication of the contributing client device, a set of constraints on messages to be transmitted from the contributing client device to the feed adapter, wherein the set of constraints specifies one or more topics of messages that the contributing client device is authorized to contribute to the feed adapter; establishing the set of constraints in messaging middleware of the contributing client device; receiving, in the messaging middleware of the contributing client device from the application of the contributing client device, a message for transmission to the feed adapter on the message stream; determining, by the messaging middleware of the contributing client device, whether contents of the message satisfy the set of constraints, wherein the determining comprises comparing a topic associated with the message with the one or more topics of messages that the contributing client device is authorized to contribute to the feed adapter; and administering the message, by the messaging middleware of the contributing client device, in dependence upon whether the message satisfies the set of constraints, wherein said administering the message comprises; authorizing transmission of the message on the message stream in dependence upon whether the message satisfies the set of constraints, and transmitting the message from the contributing client device to the feed adapter, bypassing the stream administration server, in response to an authorization of transmission of the message on the message stream;
orlogging the message in dependence upon whether the message satisfies the set of constraints. - View Dependent Claims (7, 8, 9)
-
-
10. A computer program product for computer data communications in a data communications environment, the computer program product disposed upon a non-transitory recordable medium, the computer program product comprising computer program instructions capable of:
-
issuing a request, from an application of a contributing client device to a stream administration server, for authorization to contribute messages from the application to a feed adapter within the data communications environment via a message stream which bypasses the stream administration server, wherein, the feed adapter is coupled to a feed source via a feed adapter input stream and to at least one subscribing device via a feed adapter output stream, the feed source is separate from the contributing client device, and the feed adapter input stream is separate from the message stream; receiving, in response to the request and an authentication of the contributing client device, a set of constraints on messages to be transmitted from the contributing client device to the feed adapter, wherein the set of constraints specifies one or more topics of messages that the contributing client device is authorized to contribute to the feed adapter; establishing the set of constraints in messaging middleware of the contributing client device; receiving, in the messaging middleware of the contributing client device from the application of the contributing client device, a message for transmission to the feed adapter on the message stream; determining, by the messaging middleware of the contributing client device, whether contents of the message satisfy the set of constraints, wherein the determining comprises comparing a topic associated with the message with the one or more topics of messages that the contributing client device is authorized to contribute to the feed adapter; and administering the message, by the messaging middleware of the contributing client device, in dependence upon whether the message satisfies the set of constraints, wherein said administering the message comprises; authorizing transmission of the message on the message stream in dependence upon whether the message satisfies the set of constraints, and transmitting the message from the contributing client device to the feed adapter, bypassing the stream administration server, in response to an authorization of transmission of the message on the message stream;
orlogging the message in dependence upon whether the message satisfies the set of constraints. - View Dependent Claims (11, 12)
-
Specification