private <M extends BaseMessage> void consume(Consumer<M> consumer, M message,
String identifier) {
if (Objects.equals(message.getField(identifier), this.identifier.get())) {
private <M extends BaseMessage> void consume(Consumer<M> consumer, M message,
String identifier) {
if (Objects.equals(message.getField(identifier), this.identifier.get())) {