摘要:
The invention relates to a message broker for managing subscription requests in a multicast messaging system. The messaging system comprises a plurality of publishers publishing information to the broker and a plurality of subscribers subscribing to information received from one or more publishers. The broker is able to receive a subscription request pointing to topic information in which the requesting subscriber is interested, the topic information defining a specific topic within a topic hierarchy. The broker is able to parse the request to determine if the request includes a wildcard and if the request does include a wildcard, the broker instructs the requesting subscriber to listen on a multicast address associated with the topic in the topic hierarchy which precedes the wildcard.
摘要:
The invention relates to a message broker for managing subscription requests in a multicast messaging system. The messaging system comprises a plurality of publishers publishing information to the broker and a plurality of subscribers subscribing to information received from one or more publishers. The broker is able to receive a subscription request pointing to topic information in which the requesting subscriber is interested, the topic information defining a specific topic within a topic hierarchy. The broker is able to parse the request to determine if the request includes a wildcard and if the request does include a wildcard, the broker instructs the requesting subscriber to listen on a multicast address associated with the topic in the topic hierarchy which precedes the wildcard.
摘要:
A computer forms a node in a network, consisting of computer nodes linked together into a minimum spanning tree topology. When a computer receives a message from a first node linked to it, it forwards the message to other nodes linked to that computer, as well as storing information about the message. As replies are received from the other computers, they are stored and collated together, to allow the computer to send just a single reply message back to the originating node based on the collated replies. This single reply is in turn collated at the next node. The message requests deletion of a particular node from the network. No node deletes the node from the network until replies have been received from all the nodes to which the message was forwarded.
摘要:
A system for managing inbound messages in a server complex including one or more message consumers. The system includes a server configured to receive the inbound messages from a first peripheral device and to transmit messages to one or more of the plurality of message consumers. The system also includes an inbound message queue coupled to the server, the inbound message queue configured to store inbound message until an age of any message stored on the inbound message queue exceeds a predetermined threshold.
摘要:
A method of performing message operations includes receiving a message operation request identifying a queue, retrieving a list of the subset of partitions associated with the alias received in the request, and selecting at least one of the partitions within the retrieved subset. According to the method, the queue includes a plurality of partitions, the request identifies the queue with an alias, and the alias having a subset of the plurality of partitions associated therewith.
摘要:
A system for managing inbound messages in a server complex including one or more message consumers. The system includes a server configured to receive the inbound messages from a first peripheral device and to transmit messages to one or more of the plurality of message consumers. The system also includes an inbound message queue coupled to the server, the inbound message queue configured to store inbound message and discard at least one message when an age of the message exceeds an expiration time.
摘要:
A method for preferential reply routing, the method includes: receiving a request-reply message from a requesting application; detecting there is a preferred partition of a reply queue managed locally to an application server to which the requesting application is connected; qualifying a name of a reply queue stored in the request-reply message so that the name refers to the local partition that is managed locally to the application server; determining whether the local partition is available; wherein in the event the local partition is available: storing a reply message in the local partition; and retrieving the reply message from the local partition in response to the requesting application.
摘要:
A method of performing message operations includes receiving a message operation request identifying a queue, retrieving a list of the subset of partitions associated with the alias received in the request, and selecting at least one of the partitions within the retrieved subset. According to the method, the queue includes a plurality of partitions, the request identifies the queue with an alias, and the alias having a subset of the plurality of partitions associated therewith.
摘要:
A system for managing inbound messages in a server complex including one or more message consumers. The system includes a server configured to receive the inbound messages from a first peripheral device and to transmit messages to one or more of the plurality of message consumers. The system also includes an inbound message queue coupled to the server, the inbound message queue configured to store inbound message until an age of any message stored on the inbound message queue exceeds a predetermined threshold.
摘要:
A computer workstation runs an application 12 which generates data for transmission over a network. The workstation includes a communications subsystem 14 which is responsible for actually sending data generated by the application onto the network. The application therefore passes data 22 for sending to the communications subsystem, along with the identification 24 of the channel over which that data is to be sent, and compression information 26. In a first embodiment the communications subsystem contains a variety of compression routines 40, and the compression information indicates which of these routines is most appropriate for the data in question. In a second embodiment, the compression information is a call-back function 92, whereby the communications subsystem can call back to the application program to perform the compression itself.