ConcurrentLinkedQueue disruptor dbscan emulator nft go.cqrs @Target @Retention @Documented sys.exit() WeakHashMap weed3 shell.application apache rocketmq mapgetters normalize Debezium messagequeue flexible beforerouteleave