448 results about "Message broker" patented technology

Subscribers connected to a publish/subscribe message broker receive messages on topic names to which they have subscribed. The messages are published with respective topic names within a sequence of topic names. The subscribers initially subscribe to at least one topic in the sequence, and then await receipt of a published message on the subscribed topic. On receipt of a published message, the subscriber unsubscribes from the subscribed topic and subscribes to a previously-unsubscribed next topic in the sequence.

A web services message broker architecture. In one embodiment, a system may include a server system and a plurality of applications, each configured to implement one or more enterprise functions and to execute on the server system. The system may further include a web services message broker configured to execute on the server system and to present a central web services interface to the plurality of applications, through which a given one of the plurality of applications is configured to communicate with a web service. In one specific implementation of the system, the web services message broker may be further configured to receive an incoming web service request and to convey the incoming web service request to one of the plurality of applications.

Systems and methods for silent message delivery are provided. One such embodiment includes a message receiver configured to receive a text message and convert it to a corresponding speech message. A message router is connected to the message receiver and configured to route the speech message dependent on information included in the speech message in accordance with a messaging directory. Preferably, a Voice Profile for Inter-system Messaging (VPIM) agent is connected to the message router and configured to convert the speech message to a corresponding VPIM message and deliver it to a voice mail system. Methods are also provided for delivery of a text message as speech message to a voice mail system without initiating a call to a telephonic device.

The subject invention provides reliable messaging with and within a control environment. The systems and methods utilize a message broker that facilitates message exchange. The message broker can be located within an industrial controller, as a dedicated entity within a control environment and/or an entity external to the control environment. Messages transmitted from an industrial controller and/or the external entity can be routed through the message broker prior to reaching a destination, wherein the message can be stored in the message broker and subsequently obtained by a recipient. The message broker decouples the message sender (e.g., an industrial controller, an external entity . . . ) from the message recipient (e.g., an industrial controller, an external entity . . . ) such that messages can be successfully transmitted (to the message broker) regardless of a state of the recipient, and messages can be retrieved (from the message broker) regardless of a state of the sender.

Disclosed is a method and system for communicating standardized telematic messages among a plurality of telematic devices. A telematic message is received by a message router from one of the telematic devices. The message router selects a destination device and transmits the message to the destination device, where the message is processed. In one embodiment, the message router determines whether the destination device is available to receive a message before transmitting the message. If the destination device is not available, the message is maintained in memory. In another embodiment, a time-to-live parameter is assigned to the message and the message is removed from memory of the time-to-live expires before the destination device becomes available. In a further embodiment, a priority parameter is assigned to the message and the processing of a prior message is interrupted if a new message is received that has a higher priority parameter than the previously received message.

The present invention provides a real-time means of automatically updating the content of a user pre-selected set of web pages without any activity required on the part of the user to initiate each web page updating procedure. This is achieved by incorporating into a browser of a user's computing device software code that is responsive to real-time web page content change notification messages to cause the browser to reload a URL identified in the change notification message. Alternatively, the software code may comprise a Java applet or the like embedded in a downloaded web page that is responsive to change notification messages to cause the browser to reload a web page whose URL is identified in the message or to reload a currently displayed web page. The change notification messages are generated by applications whose web page content has changed and the messages are relayed in real-time to push client agents comprising said software code by a message broker agent. The invention offers many advantages including reducing unnecessary web page reload operations and thus reducing network traffic.

An enterprise application system including a run-time transformation server, and a message broker for routing and transforming data in the form of messages between a source application and a target application, including a plug-in for preparing requests to the run-time transformation server and for processing responses from the run-time transformation server. A method is also described and claimed.

Via a thin client, a first user communicates with a presence server and establishes a communication channel with a second user through the presence server. The communication channel supports instant messaging in which the first user communicates via use of a first communication protocol and the second user communicates via use of a second communication protocol. When the thin client temporarily disconnects from the presence server, the presence server maintains an active “open” session for the thin client even though the thin client is disconnected from the presence server. The thin client can reconnect to the presence server and re-establish communications over the open session, enabling the first user to again instant message the second user.

A system and method for providing implementing proxy handling of instant messages and the like, wherein proxy recipients are designated by an original recipient, and one or more redirection rules are established indicating conditions under which said designated proxy recipients are to be sent redirected messages. When an instant message is received directed towards the original recipient, the redirection rules are evaluated and the message is redirect to a designated proxy recipient according to the redirection rules, with the display of the received message being suppressed or blocked on the intended original recipient's user interface.

A system and method are provided for provisioning component applications for retrieval by a device. The system includes an application gateway server, which includes a message broker for communicating between the system and the device. The application gateway server is configured for communication with a provisioning server and a discovery server. The provisioning server includes a provisioning service for servicing a provisioning request and a provisioning depot for storing packaged component applications. The discovery server stores and manages component application bundles. The system further includes a packaging application in communication with application gateway for retrieving a component application bundle, selecting elements from the component application bundle in accordance with the device for which the component application is being provisioned, creating a component application package using the selected elements, and making the packaged component application available to the device.

A method and apparatus pass messages between server and client applications using a fault tolerant storage system (FTSS). The interconnection fabric that couples the FTSS to the computer systems that host the client and server applications may also be used to carry messages. A networked system capable of hosting a distributed application includes a plurality of computer systems coupled to an FTSS via an FTSS interconnection fabric. The FTSS not only processes file-related I/O transactions, but also includes several message agents to facilitate message transfer in a reliable and fault tolerant manner. The message agents include a conversational communication agent, an event-based communication agent, a queue-based communication agent, a request/reply communication agent, and an unsolicited communication agent. The highly reliable and fault tolerant nature of the FTSS ensures that the FTSS can guarantee delivery of a message transmitted from a sending computer system to a destination computer system. As soon as a message is received by the FTSS from a sending computer system, the message is committed to a nonvolatile fault tolerant write cache. Thereafter, the message is written to a redundant array of independent disks (RAID) of the FTSS, and processed by one of the message agents.

A method, apparatus, and system for providing a standard, generic contract between an application server and a message provider which allows the message provider to deliver messages to message endpoints (each of which is associated with a corresponding message application) residing in the application server is disclosed. By generic, it is meant that the contract is independent of the specific messaging style, messaging semantics and messaging infrastructure used to deliver messages. In this way, the contract also serves as the standard message provider pluggability contract that allows any message provider to be plugged into any application server via an associated resource adapter.

The invention relates to a message push method and a message push device. The message push method includes sending a message token acquisition request, wherein the message token acquisition request comprises a mobile terminal device identification number, an application program name and user account identification information; receiving message tokens corresponding to the mobile terminal device identification number, the application program name and the user account identification information; sending message data searching requests carrying the message tokens; and receiving the message data matched with the message tokens and searched out according to the message tokens. Therefore, the message push method and the message push device are applicable to any mobile terminal and do not need maintenance of a keep-alive hand grip. Due to the fact that the message tokens, the software name, the mobile terminal device identification number and the user account identification information are bound together, a message can be transmitted to the mobile terminal accurately.

Unified management, automation and interoperability of business and device processes utilizing components of a metadata-driven computing system on any device and/or across difference devices. In an embodiment, a I/O processor on a device receives an input dataset, wherein the input dataset may be a messages dataset received from a message broker. The I/O processor accesses one or more instructions datasets nested within a state dataset to process each row in the input dataset. Processing of the input dataset by the I/O processor updates the state of the state dataset and may output one or more datasets, wherein an output dataset may be a messages dataset sent to a message broker to send to a computing system for processing. A messages dataset may comprise one or more messages, wherein a message may comprise one or more events, queries, or query results for processing by a computing system.

Embodiments of the invention relate to message queuing. In one embodiment, a request from an application for retrieving a message from a queue is received. The queue is stored across multiple nodes of a distributed storage system. A preference with respect to message order and message duplication associated with the queue is identified. A message sequence index associated with the queue is sampled based on the preference that has been identified. The message is selected in response to the sampling. The message that has been selected is made unavailable to other applications for a given interval of time, while maintaining the message in the queue. The message is sent to the application.

The invention discloses a framework system and implementation method of a middleware applied to a car networking, and relates to the technical field of an embedded middleware applied to the car networking. The framework system includes a middleware message bus module, a car networking application component module, a car networking middleware message broker module, a car networking security component, and a car networking communication protocol adaptation layer. The car networking middleware application component forms a standard function component; the car networking middleware message broker is used for analysis and classification of all kinds of messages in the car networking; a remote connection request is verified by a security component; if the remote connection request passed verification, a corresponding application component thread is searched in a car networking message bus; and through the message bus, a message channel is established between a remote terminal and a local application component or middleware message broker, and then communication is carried out. The car networking communication protocol adaptation layer is used to shield differences between a platform and an enterprise protocol, and to provide a unified communication call interface. According to the invention, the reusability of the code and the development efficiency of the application program are improved.

A distributed messaging system includes a gateway having an interface to receive client messages and having access to a gateway database and to a messaging host that supports multiple partitions that are executed on processors of a cluster of processors. Each of the partitions supports execution of at least one message broker. The gateway database includes a mapping between each of the message brokers and one of the multiple partitions. An admin agent may periodically scan the gateway database to check if the message brokers reach a capacity threshold. The admin agent may create new message brokers and add the new message brokers to a pool of message brokers to allow new queues to be associated with the new message brokers.

There is provided a route optimization method in a mobile Internet Protocol (IP) system using a mobile Internet Protocol. When a mobile host (MH) moves over the Internet and is assigned to a care-of-address (CoA) corresponding to a changed point of attachment to the Internet, it sends a registration request message containing the care-of address to a home agent (HA) via a foreign agent (FA). The home agent stores the care-of address in relation to a domain name of the mobile host in an internal domain name server database. Upon receipt of a query about the mobile host by domain name from a correspondent node (CN), the home agent sends the care-of address corresponding to the domain name of the mobile host together with caching prevention information to the correspondent node. The caching prevention information is set to prevent the correspondent node or another domain name server from caching the care-of address of the mobile host. The correspondent node communicates with the mobile host using the care-of address.