|
|
@ -38,12 +38,12 @@ export class EventConsumersPageComponent implements OnDestroy, OnInit { |
|
|
|
|
|
|
|
|
this.timerSubscription = |
|
|
this.timerSubscription = |
|
|
Observable.timer(2000, 2000) |
|
|
Observable.timer(2000, 2000) |
|
|
.switchMap(x => this.eventConsumersState.load().onErrorResumeNext()) |
|
|
.switchMap(x => this.eventConsumersState.load(true, true).onErrorResumeNext()) |
|
|
.subscribe(); |
|
|
.subscribe(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public reload() { |
|
|
public reload() { |
|
|
this.eventConsumersState.load(true, true).onErrorResumeNext().subscribe(); |
|
|
this.eventConsumersState.load(true, false).onErrorResumeNext().subscribe(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public start(es: EventConsumerDto) { |
|
|
public start(es: EventConsumerDto) { |
|
|
|