mseemann

<form [formGroup]="form">
  <p>
    <mdl-textfield label="First Name" name="firstname" type="text" formControlName="firstName" floating-label></mdl-textfield>
  </p>
  <p>
    <mdl-textfield label="Last Name" name="lastname" type="text" formControlName="lastName" floating-label></mdl-textfield>
  </p>
  <p>
    Which breakfast do you prefer?<br/>
    <mdl-radio name="breakfast" value="Continental" formControlName="breakfast" mdl-ripple>Continental</mdl-radio>

mseemann

import {
  Component,
  OnInit
} from '@angular/core';
import { flyInOutTrigger } from './../animations/flyInOutTrigger-animation';
import { hostConfig } from './../animations/flyInOutTrigger-animation';
import {
  FormGroup,
  FormControl,
  Validators,

mseemann

import io.mseemann.medium.jmxpg.beans.AppInfo;
import io.mseemann.medium.jmxpg.beans.Requests;

import javax.management.MBeanServer;
import javax.management.ObjectName;
import java.lang.management.ManagementFactory;
import java.util.Hashtable;

public class App {

mseemann

rules:
  - pattern: "jmxpg.mbeans<type=AppInfo, Version=([^:]+)><>Status: ([^:]+)"
    name: "msee_jmxpg_mbeans_app_info_status"
    type: UNTYPED
    help: "Version and status of the app. Status values: running, failed, starting and exited."
    value: 1
    labels:
      version: $1
      status: $2

mseemann

@Document(collection = ResumeTokenRepository.USER_COLLECTION)
public record User(@Id String id, @Indexed String userName) {
}

mseemann

import org.springframework.data.repository.reactive.ReactiveCrudRepository;

public interface UserRepository extends ReactiveCrudRepository<User, String> {
}

mseemann

@RestController
@AllArgsConstructor
public class UserController {

    UserRepository userRepository;

    @GetMapping("/user")
    public Flux<User> getAllUser() {
        return userRepository.findAll();

mseemann

spring:
  data:
    mongodb:
      host:                                             localhost
      port:                                             27017
      database:                                         streams

mseemann

reactiveMongoTemplate
        .changeStream(User.class)
        .watchCollection("user")
        .listen()
        .subscribe(event -> {
            log.info("change stream event {}", event);
            BsonDocument newResumeToken = Objects.requireNonNull(event.getRaw()).getResumeToken().asDocument();
            BsonString token = newResumeToken.getString("_data");
            var timeStampInMs = Objects.requireNonNull(event.getBsonTimestamp()).getTime() * 1000L;

mseemann

Query tailQ = new Query().addCriteria(Criteria.where("ns").is("streams.user"));
reactiveMongoTemplate.tail(tailQ, OplogEntry.class, "oplog.rs")
        .retryWhen(Retry.indefinitely().doAfterRetryAsync(signal -> Mono.delay(Duration.ofSeconds(10)).then()))
        .subscribe(entry -> {
            log.info("tailed entry: {}", entry);
            lastOplogAt.set(entry.ts().getTime() * 1000L);
        });