this.objectMapper = requireNonNull(objectMapper);
}
@Nullable
@Override
public Message decode(@Nonnull RawMessage rawMessage) {
<BUG>throw new UnsupportedOperationException("MultiMessageCodec " + getClass() + " does not support decode()");
}
@Nullable
@Override
public Collection<Message> decodeMessages(@Nonnull RawMessage rawMessage) {</BUG>
final byte[] payload = rawMessage.getPayload();

this.objectMapper = requireNonNull(objectMapper);
}
@Nullable
@Override
public Message decode(@Nonnull RawMessage rawMessage) {
