Reader Listener

[scottf]

A way to debug incoming messages before they are processed

[MauriceVanVeen]

LGTM

[MauriceVanVeen]

Should the copyright date be updated?

[scottf]

Basic benchmark comparison shows no loss in speed, safe to merge.

┌─────────────────────┬───────────────────┬─────────────────┬──────────────────────────┬──────────────────┐
│ 2.20.5              │             count │            time │                 msgs/sec │        bytes/sec │
├─────────────────────┼───────────────────┼─────────────────┼──────────────────────────┼──────────────────┤
│ PubAsync            │   50,000,000 msgs │       28:37.522 │      29,111.709 msgs/sec │      6.94 mb/sec │
├─────────────────────┼───────────────────┼─────────────────┼──────────────────────────┼──────────────────┤
│ SubFetch            │   50,000,000 msgs │       35:23.774 │      23,542.995 msgs/sec │      5.61 mb/sec │
├─────────────────────┼───────────────────┼─────────────────┼──────────────────────────┼──────────────────┤
│ SubIterate          │   50,000,000 msgs │       17:10.329 │      48,528.189 msgs/sec │     11.57 mb/sec │
└─────────────────────┴───────────────────┴─────────────────┴──────────────────────────┴──────────────────┘

┌─────────────────────┬───────────────────┬─────────────────┬──────────────────────────┬──────────────────┐
│ 2.20.6-SNAPSHOT     │             count │            time │                 msgs/sec │        bytes/sec │
├─────────────────────┼───────────────────┼─────────────────┼──────────────────────────┼──────────────────┤
│ PubAsync            │   50,000,000 msgs │       27:10.364 │      30,667.998 msgs/sec │      7.31 mb/sec │
├─────────────────────┼───────────────────┼─────────────────┼──────────────────────────┼──────────────────┤
│ SubFetch            │   50,000,000 msgs │       34:27.336 │      24,185.715 msgs/sec │      5.77 mb/sec │
├─────────────────────┼───────────────────┼─────────────────┼──────────────────────────┼──────────────────┤
│ SubIterate          │   50,000,000 msgs │       16:36.262 │      50,187.601 msgs/sec │     11.97 mb/sec │
└─────────────────────┴───────────────────┴─────────────────┴──────────────────────────┴──────────────────┘

┌─────────────────────┬───────────────────┬─────────────────┬──────────────────────────┬──────────────────┐
│ .6.reader-listener  │             count │            time │                 msgs/sec │        bytes/sec │
├─────────────────────┼───────────────────┼─────────────────┼──────────────────────────┼──────────────────┤
│ PubAsync            │   50,000,000 msgs │       28:20.610 │      29,401.215 msgs/sec │      7.01 mb/sec │
├─────────────────────┼───────────────────┼─────────────────┼──────────────────────────┼──────────────────┤
│ SubFetch            │   50,000,000 msgs │       35:14.739 │      23,643.580 msgs/sec │      5.64 mb/sec │
├─────────────────────┼───────────────────┼─────────────────┼──────────────────────────┼──────────────────┤
│ SubIterate          │   50,000,000 msgs │       17:22.491 │      47,962.045 msgs/sec │     11.44 mb/sec │
└─────────────────────┴───────────────────┴─────────────────┴──────────────────────────┴──────────────────┘