How to use @stomp/rx-stomp - 10 common examples
To help you get started, we’ve selected a few @stomp/rx-stomp examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
stomp-js / ng2-stompjs / src / specs / app / services / rx-stomp-rpc.service.spec.ts View on Github 
beforeEach((done) => {
rxStomp = new RxStomp();
const rxStompConfig: RxStompConfig = (Object as any).assign({}, defaultRxStompConfig);
// Identify log messages on the server side
rxStompConfig.debug = (str: string) => {
console.log('RPC Server: ', new Date(), str);
};
rxStomp.configure(rxStompConfig);
rxStomp.activate();
rxStomp.connected$.pipe(take(1)).subscribe(() => {
const receiptId = UUID.UUID();
rxStomp.watch(myServiceEndPoint, {receipt: receiptId}).subscribe((message: IMessage) => {
const replyTo = message.headers['reply-to'];
const correlationId = message.headers['correlation-id'];
const incomingMessage = message.body;function (st) {
if (st === RxStompState.CONNECTING) {
return StompState.TRYING;
}
if (st === RxStompState.OPEN) {
return StompState.CONNECTED;
}
if (st === RxStompState.CLOSING) {
return StompState.DISCONNECTING;
}
if (st === RxStompState.CLOSED) {
return StompState.CLOSED;
}
};
Object.defineProperty(StompRService.prototype, "connectObservable", {static _mapStompState(st) {
if (st === RxStompState.CONNECTING) {
return StompState.TRYING;
}
if (st === RxStompState.OPEN) {
return StompState.CONNECTED;
}
if (st === RxStompState.CLOSING) {
return StompState.DISCONNECTING;
}
if (st === RxStompState.CLOSED) {
return StompState.CLOSED;
}
}
/**function (st) {
if (st === RxStompState.CONNECTING) {
return StompState.TRYING;
}
if (st === RxStompState.OPEN) {
return StompState.CONNECTED;
}
if (st === RxStompState.CLOSING) {
return StompState.DISCONNECTING;
}
if (st === RxStompState.CLOSED) {
return StompState.CLOSED;
}
};
Object.defineProperty(StompRService.prototype, "connectObservable", {static _mapStompState(st) {
if (st === RxStompState.CONNECTING) {
return StompState.TRYING;
}
if (st === RxStompState.OPEN) {
return StompState.CONNECTED;
}
if (st === RxStompState.CLOSING) {
return StompState.DISCONNECTING;
}
if (st === RxStompState.CLOSED) {
return StompState.CLOSED;
}
}
/**private static _mapStompState(st: RxStompState): StompState {
if (st === RxStompState.CONNECTING) {
return StompState.TRYING;
}
if (st === RxStompState.OPEN) {
return StompState.CONNECTED;
}
if (st === RxStompState.CLOSING) {
return StompState.DISCONNECTING;
}
if (st === RxStompState.CLOSED) {
return StompState.CLOSED;
}
}private static _mapStompState(st: RxStompState): StompState {
if (st === RxStompState.CONNECTING) {
return StompState.TRYING;
}
if (st === RxStompState.OPEN) {
return StompState.CONNECTED;
}
if (st === RxStompState.CLOSING) {
return StompState.DISCONNECTING;
}
if (st === RxStompState.CLOSED) {
return StompState.CLOSED;
}
}static _mapStompState(st) {
if (st === RxStompState.CONNECTING) {
return StompState.TRYING;
}
if (st === RxStompState.OPEN) {
return StompState.CONNECTED;
}
if (st === RxStompState.CLOSING) {
return StompState.DISCONNECTING;
}
if (st === RxStompState.CLOSED) {
return StompState.CLOSED;
}
}
/**function (st) {
if (st === RxStompState.CONNECTING) {
return StompState.TRYING;
}
if (st === RxStompState.OPEN) {
return StompState.CONNECTED;
}
if (st === RxStompState.CLOSING) {
return StompState.DISCONNECTING;
}
if (st === RxStompState.CLOSED) {
return StompState.CLOSED;
}
};
Object.defineProperty(StompRService.prototype, "connectObservable", {function (st) {
if (st === RxStompState.CONNECTING) {
return StompState.TRYING;
}
if (st === RxStompState.OPEN) {
return StompState.CONNECTED;
}
if (st === RxStompState.CLOSING) {
return StompState.DISCONNECTING;
}
if (st === RxStompState.CLOSED) {
return StompState.CLOSED;
}
};
Object.defineProperty(StompRService.prototype, "connectObservable", {@stomp/rx-stomp
RxJS STOMP client for Javascript and Typescript
