Custom header enricher, which returns the headers to add to messages

SampleHeaderEnricher.java

package be.rufer.amqp.integration.messaging.enricher;

import org.springframework.integration.Message;

import java.util.HashMap;
import java.util.Map;

public class SampleHeaderEnricher {

    public Map<String, Object> addCustomHeaders(Message<?> message) {
        Map<String, Object> headersToEnrich = new HashMap<>();
        headersToEnrich.put("CUSTOM_HEADER_KEY", "CUSTOM_HEADER_VALUE");
        return headersToEnrich;
    }
}