()
| 789 | } |
| 790 | |
| 791 | override close() { |
| 792 | this.publish({ |
| 793 | type: MessageType.ADAPTER_CLOSE, |
| 794 | }); |
| 795 | clearTimeout(this.heartbeatTimer); |
| 796 | if (this.cleanupTimer) { |
| 797 | clearInterval(this.cleanupTimer); |
| 798 | } |
| 799 | } |
| 800 | |
| 801 | override onMessage(message: ClusterMessage, offset?: string) { |
| 802 | if (message.uid === this.uid) { |