All files / js/websockets BufferedStompClient.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
 
 
 
 
 
 
 
15x
 
15x
 
 
 
67x
15x
 
52x
 
 
 
 
15x
15x
 
 
 
 
import {Client} from "@stomp/stompjs";
import {StompConfig} from "@stomp/stompjs/src/stomp-config";
import {IPublishParams} from "@stomp/stompjs/src/types";
 
export default class BufferedStompClient extends Client {
    private readonly buffer: IPublishParams[];
 
    constructor(config: StompConfig) {
        super(config);
 
        this.buffer = []
    }
 
    bufferedPublish(msg: IPublishParams) {
        if(!this.connected) {
            this.buffer.push(msg);
        } else {
            this.publish(msg);
        }
    }
 
    sendBuffer() {
        for(let msg of this.buffer) {
            this.publish(msg);
        }
    }
}