┌───┐ ┌───┐              ┌────┐       ┌─┐
│TS1│ │TS2│              │MQES│       │K│
└─┬─┘ └─┬─┘              └──┬─┘       └┬┘
  │    call WriteEvents     │          │
  │────────────────────────>│          │
  │     │                   │          │
  │     │ call WriteEvents  │          │
  │     │──────────────────>│          │
  │     │                   │          │
  │     │                   │ Produce  │
  │     │                   │─────────>│
  │     │                   │          │
  │     │                   │   ACK    │
  │     │                   │< ─ ─ ─ ─ │
  │     │                   │          │
  │     │call Callback      │          │
  │< ─ ─│─ ─ ─ ─ ─ ─ ─ ─ ─ ─│          │
  │     │                   │          │
  │     │   call Callback   │          │
  │     │< ─ ─ ─ ─ ─ ─ ─ ─ ─│          │
  │     │                   │          │
┌─┴─┐ ┌─┴─┐              ┌──┴─┐       ┌┴┐
│TS1│ │TS2│              │MQES│       │K│
└───┘ └───┘              └────┘       └─┘