Watching Connection Status

Author: kum-deepak

src/app/app.component.html

@@ -3,4 +3,5 @@ <h1>
     Welcome to {{ title }}!
   </h1>
 </div>
+<app-status></app-status>
 <app-messages></app-messages>

src/app/app.module.ts

@@ -6,11 +6,13 @@ import { InjectableRxStompConfig, RxStompService, rxStompServiceFactory } from '
 import { AppComponent } from './app.component';
 import { myRxStompConfig } from './my-rx-stomp.config';
 import { MessagesComponent } from './messages/messages.component';
+import { StatusComponent } from './status/status.component';
 
 @NgModule({
   declarations: [
     AppComponent,
-    MessagesComponent
+    MessagesComponent,
+    StatusComponent
   ],
   imports: [
     BrowserModule

src/app/status/status.component.css

@@ -0,0 +1,30 @@
+div#status {
+    text-align: center;
+    font-family: Arial, serif;
+    font-size: 1.2em;
+}
+
+div#indicator {
+    width: 12px;
+    height: 12px;
+    border-radius: 6px;
+    margin: 0 10px;
+    display: inline-block;
+}
+
+div.CLOSED#indicator {
+    background: red;
+}
+
+div.CONNECTING#indicator, div.CLOSING#indicator {
+    background: yellow;
+}
+
+div.OPEN#indicator {
+    background: green;
+}
+
+button {
+    margin: 0 10px;
+    font-size: 1em;
+}

src/app/status/status.component.html

@@ -0,0 +1,7 @@
+<div id="status">
+  <div id="indicator" class="{{connectionStatus$|async}}"></div>
+  <span>{{connectionStatus$|async}}</span>
+  <button class="btn" (click)="rxStompService.activate()">Activate</button>
+  <button class="btn" (click)="rxStompService.deactivate()">DeActivate</button>
+  <button class="btn" (click)="rxStompService.stompClient.forceDisconnect()">Simulate Error</button>
+</div>

src/app/status/status.component.spec.ts

@@ -0,0 +1,25 @@
+import { async, ComponentFixture, TestBed } from '@angular/core/testing';
+
+import { StatusComponent } from './status.component';
+
+describe('StatusComponent', () => {
+  let component: StatusComponent;
+  let fixture: ComponentFixture<StatusComponent>;
+
+  beforeEach(async(() => {
+    TestBed.configureTestingModule({
+      declarations: [ StatusComponent ]
+    })
+    .compileComponents();
+  }));
+
+  beforeEach(() => {
+    fixture = TestBed.createComponent(StatusComponent);
+    component = fixture.componentInstance;
+    fixture.detectChanges();
+  });
+
+  it('should create', () => {
+    expect(component).toBeTruthy();
+  });
+});

src/app/status/status.component.ts

@@ -0,0 +1,24 @@
+import { Component, OnInit } from '@angular/core';
+import {RxStompService} from '@stomp/ng2-stompjs';
+import {Observable} from 'rxjs';
+import {map} from 'rxjs/operators';
+import {RxStompState} from '@stomp/rx-stomp';
+
+@Component({
+  selector: 'app-status',
+  templateUrl: './status.component.html',
+  styleUrls: ['./status.component.css']
+})
+export class StatusComponent implements OnInit {
+  public connectionStatus$: Observable<string>;
+
+  constructor(public rxStompService: RxStompService) {
+    this.connectionStatus$ = rxStompService.connectionState$.pipe(map((state) => {
+      return RxStompState[state];
+    }));
+  }
+
+  ngOnInit() {
+  }
+
+}

src/styles.css

@@ -1 +1,4 @@
 /* You can add global styles to this file, and also import other style files */
+button.btn {
+    font-size: 1.1em;
+}