public void process()

in library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/serialization/kafka/KafkaHeaderDeserializer.java [41:58]

• 15 lines of code
• 5 McCabe index (conditional complexity)

    public void process(Exchange exchange) throws Exception {
        if (!enabled) {
            return;
        }

        Map<String, Object> headers = exchange.getMessage().getHeaders();

        TypeConverter typeConverter = exchange.getContext().getTypeConverter();
        if (typeConverter == null) {
            typeConverter = defaultTypeConverter;
        }

        for (Map.Entry<String, Object> header : headers.entrySet()) {
            if (shouldDeserialize(header)) {
                header.setValue(typeConverter.convertTo(String.class, header.getValue()));
            }
        }
    }