Duplex services residing in a messaging bus

• US 9,860,326 B2
• Filed: 02/27/2014
• Issued: 01/02/2018
• Est. Priority Date: 02/27/2014
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Eli{hacek over (s)}, Filip, Nguyen, Filip
• Primary Examiner(s): Lazaro, David
• Assistant Examiner(s): Ye, Zi
• Application Number:
  US14/192,735
• Publication Number:
  US 20150244511A1
• Time in Patent Office: 1,405 Days
• Field of Search: 709204, 709217-219, 709227-229, 700 20, 370276
• CPC Class Codes: H04L 65/1069 Session establishment or de-establishment
• CPC Class Codes: H04L 67/51 Discovery or management thereof, e.g. service location protocol [SLP] or web services

Abstract

An example method of integrating a plurality of heterogeneous peer-to-peer communication participants includes retrieving from a first input queue coupled to a duplex service a first message. The first message includes a message identifier and is from a sender. The method also includes applying a first operation on the first message, determining a first output of the first message based on the first operation, and sending the first output of the first message to a target. The method further includes retrieving from a second input queue coupled to the duplex service a second message. The second message includes the message identifier and is from a target. The method also includes applying a second operation on the second message, determining a second output of the second message based on the second operation, and sending the second output of the second message to the sender.

Claims

1. A method of integrating a plurality of heterogeneous peer-to-peer communication participants, comprising:

retrieving a first message from a first input queue coupled to a duplex service, the first message including a first message identifier that identifies the first message and being from a sender, and the duplex service residing in a messaging bus;

determining a state associated with the first message, the state based on applying a first operation on the first message;

saving in a memory the state and an association between the state and the first message identifier;

retrieving a second message from a second input queue coupled to the duplex service, the second message including a second message identifier;

determining whether the first message identifier matches the second message identifier;

in response to a determination that the first message identifier matches the second message, identifier;

retrieving, the saved state associated with the first message identifier from the memory;

applying, using the retrieved state, a second operation on the second message; and

determining, at the duplex service, an output of the second message based on applying, using the retrieved state, the second operation on the second message, wherein if the first message identifier matches the second message identifier, a response to the first message is based on the output of the second message; and

sending the output of the second message to the sender of the first message.

2. The method of claim 1, further comprising:

applying the first operation on an object, wherein saving the state and the association includes saving a state of the object in the memory;

retrieving the state of the object from the memory, wherein applying, using the state, the second operation includes using the retrieved state to apply the second operation on the object; and

sending the output of the second message to the sender of the first message.

3. The method of claim 1, wherein the first operation is an inverse operation of the second operation.

4. The method of claim 1, wherein the first operation is the same operation as the second operation.

5. The method of claim 1, further comprising:

in response to a determination that the first message identifier matches the second message identifier, determining that the first message is a request and that the second message is a response to the request.

6. The method of claim 1, wherein the message identifier is assigned to the first message.

7. The method of claim 1, further including:

determining that the first message identifier matches the second message identifier.

8. A system for integrating a plurality of heterogeneous peer-to-peer communication participants, comprising:

a duplex service residing in a messaging bus and coupled to a first input queue and a second queue,

wherein the duplex service retrieves, by one or more processors, a first message from the first input queue, and saves in a memory a state associated with the first message and an association between the state and a first message identifier that identifies the first message, wherein the first message is from a sender to a target and includes the first message identifier, and the state is based on applying a first operation on the first message; and

wherein the duplex service retrieves, by one or more processors, a second message from the second input queue and determines whether the first message identifier matches a second message identifier, wherein in response to a determination that the first message identifier matches the second message identifier, the duplex service;

(i) retrieves the saved state associated with the first message identifier from the memory, (ii) applies, using the retrieved state, a second operation on the second message, and (iii) determines an output of the second message based on applying, using the retrieved state, the second operation on the second message, and wherein the duplex service sends the output of the second message to the sender of the first message, wherein if the first message identifier matches the second message identifier, a response to the first message is based on the output of the second message, and wherein the second message includes the second message identifier.

9. The system of claim 8, wherein the duplex service applies the first operation on an object and saves in the memory the state of the object.

10. The system of claim 9, wherein the duplex service identifies the message identifier in the second message and retrieves, based on the identification, the state of the object from the memory and uses the state to apply the second operation on the object.

11. The system of claim 8, wherein the messaging bus is coupled to a first gateway and a second gateway, and wherein each gateway has a configuration file that indicates a name of the respective gateway, a type of protocol accepted by the respective gateway, a port on which the respective gateway listens, an output destination to where to send one or more messages received from a first internal duplex service residing in the messaging bus, and a second internal duplex service to where to send one or more messages from external users.

12. The system of claim 8, wherein the sender is a first gateway coupled to the messaging bus, and the first gateway converts a received message from the sender into the first message understood by the duplex service.

13. The system of claim 8, wherein the sender is a second duplex service residing in the messaging bus, and wherein the first duplex service places the output of the second message in an input queue coupled to the second duplex service, and the second duplex service processes one or more messages from the input queue coupled to the second duplex service.

14. The system of claim 8, wherein the target is a gateway coupled to the messaging bus.

15. The system of claim 8, wherein the target is a second service residing in the messaging bus.

16. The system of claim 8, wherein the first operation is an inverse operation of the second operation.

17. The system of claim 8, wherein the sender and the target are heterogeneous peer-to-peer communication participants.

18. A non-transitory machine-readahle medium comprising a plurality of machine-readable instructions that when executed by one or more processors is adapted to cause the one or more processors to perform a method comprising:

retrieving a first message from a first input queue coupled to a duplex service, the first message including a first message identifier that identifies the first message and being from a. sender, and the duplex service residing in a messaging bus;

determining a state associated with the first message, the state based on applying a first operation on the first message;

saving in a memory the state and an association between the state and the first message identifier;

retrieving a second message from a second input queue coupled to the duplex service a, the second message including a second message identifier;

determining whether the first message identifier matches the second message identifier;

in response to a determination that the first message identifier matches the second message identifier;

retrieving., the saved state associated with the first message identifier from the memory;

applying, using the retrieved state, a second operation on the second message; and

determining, at the duplex service, an output of the second message based on applying, using the retrieved state, the second operation on the second message, wherein if the first message identifier matches the second message identifier, a response to the first message is based on the output of the second message; and

sending the output of the second message to the sender of the first message.