Clustering in unified communication and collaboration services
A method for telecommunications is disclosed herein including a first node receiving a plurality of events. A first state machine in the first node generates a current state of the first state machine by processing the plurality of events. The first node publishes the plurality of events to a persistent event log. A second node subscribes to the persistent event log. A second state machine in the second node generates the current state of the first state machine on the second state machine by processing the plurality of events from the persistent event log.
1. A method for telecommunications comprising:
receiving, by a first node, a plurality of events for a communications session associated with a particular user;
generating, by a first state machine in the first node, a current state of the first state machine for the communications session associated with the particular user by processing the plurality of events in the order the events are received;
publishing, by the first node, the plurality of events associated with the particular user and the order in which the events are received to a persistent event log;
receiving, by a second node, a message directing the second node to subscribe to the persistent event log;
subscribing, by the second node, to the persistent event log in response to the message; and
generating, by a second state machine in the second node, the current state of the first state machine on the second state machine by processing the plurality of events for the communications session associated with the particular user from the persistent event log by rerunning the plurality of events on the second state machine in the same order as by the first cluster node to recreate or rebuild the current state of the first state machine to continue the communication session associated with the particular user.
2. The method of claim 1 , wherein the plurality of events is for a communication service including at least one of an instant message, presence information, voice features, mobility features, audio features, web and video conferencing, calendaring, fixed-mobile convergence, desktop sharing, data sharing, call control, speech recognition, unified messaging, integrated voicemail, e-mail, SMS or fax.
3. The method of claim 1 , wherein the first node is associated with at least one customer.
4. The method of claim 3 , further comprising:
receiving, by a router, the plurality of events from the at least one customer, the plurality of events being associated with the at least one customer; and
transmitting, by the router, the plurality of events to the first node associated with the at least one customer.
5. The method of claim 1 , wherein the processing the plurality of events from the persistent event log is associated with a customer.
6. The method of claim 1 , wherein the first node and the second node are part of a cluster of nodes and communicate with a coordinator and an external message bus, the external message bus having the persistent event log.
7. The method of claim 1 , further comprising:
receiving, by the second node from a coordinator, the message directing the second node to subscribe to the persistent event log.
8. The method of claim 1 , wherein the second node subscribes to the persistent event log when the first node fails to communicate with a coordinator or when the first node reaches a set capacity.
9. The method of claim 1 , wherein the first node operates using a revision of software and the second node operates using a different revision of the same software, the first node and the second node operating at the same time.
10. A system for telecommunications comprising:
a router configured to receive a plurality of events for a communication session, the plurality of events being associated with a customer;
a plurality of cluster nodes, a first cluster node of the plurality of cluster nodes being associated with the customer, having a first state machine and an internal message bus, and being configured to:
i) receive the plurality of events from the router based on the customer;
ii) generate, by the first state machine, a current state of the first state machine for the communications session associated with the customer by processing the plurality of events in the order the events are received;
iii) publish, by the first cluster node, the plurality of events associated with the particular user and the order in which the events are received to a persistent event log;
an external message bus in communication with the plurality of cluster nodes and having the persistent event log; and
a coordinator in communication with the plurality of cluster nodes and configured to transmit a message to a second cluster node of the plurality of cluster nodes;
wherein when the second cluster node receives the message from the coordinator, the second cluster node subscribes to the persistent event log via the external message bus and generates the current state of the first state machine on a second state machine by processing the plurality of events for the communications session associated with the customer from the persistent event log by rerunning the plurality of events on the second state machine in the same order as by the first cluster node to recreate or rebuild the current state of the first state machine to continue the communications session associated with the particular user.
11. The system of claim 10 , wherein the plurality of events is for a communication service including at least one of an instant message, presence information, voice features, mobility features, audio features, web and video conferencing, calendaring, fixed-mobile convergence, desktop sharing, data sharing, call control, speech recognition, unified messaging, integrated voicemail, e-mail, SMS or fax.
12. The system of claim 10 , wherein the first node of the cluster of nodes operates using a revision of software and the second node of the cluster of nodes operates using a different revision of the same software, the first node and the second node operating at the same time in the cluster of nodes of the system.
13. The system of claim 10 , wherein the coordinator transmits the message to the second node when the first node fails to communicate with the coordinator or when the first node reaches a set capacity.
14. The system of claim 10 , wherein the processing the plurality of events from the persistent event log is associated with the customer.
15. A method for telecommunications comprising:
receiving, by a router, a plurality of events for a communication session, the plurality of events being associated with a customer;
transmitting, by the router, the plurality of events;
receiving, by a first node associated with the customer, the plurality of events based on the customer, the first node being part of a plurality of cluster nodes, and having a first state machine and an internal message bus;
generating, by the first state machine, a current state of the first state machine for the communications session associated with the customer by processing the plurality of events in the order the events are received;
publishing, by the first node, the plurality of events associated with the particular user and the order in which the events are received to a persistent event log;
receiving, by a second node, a message directing the second node to subscribe to the persistent event log;
subscribing, by the second node, to the persistent event log;
receiving, by the second node from the persistent event log, the plurality of events; and
generating, by a second state machine in the second node, the current state of the first state machine on the second state machine by processing the plurality of events for the communications session associated with the customer from the persistent event log by rerunning the plurality of events on the second state machine in the same order as by the first cluster node to recreate or rebuild the current state of the first state machine to continue the communications session associated with the particular user.
16. The method of claim 15 , wherein the first node of the cluster of nodes operates using a revision of software and the second node of the cluster of nodes operates using a different revision of the same software, the first node and the second node operating at the same time in the cluster of nodes.
17. The method of claim 15 , wherein a coordinator transmits the message to the second node when the first node fails to communicate with the coordinator or when the first node reaches a set capacity.
18. The method of claim 15 , further comprising:
subscribing, by the second node, to the persistent event log while the first node is processing the plurality of events;
generating, by the second state machine in the second node, on the second state machine in the second node, the current state of the first state machine in the first node by processing the plurality of events from the persistent event log;
wherein a duplicate of an entire first node is created in case of a failure of the first node.