public abstract class AbstractKafkaHeaderMapper extends java.lang.Object implements KafkaHeaderMapper
Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher
A pattern-based header matcher that matches if the specified
header matches the specified simple pattern.
|
Modifier and Type | Field and Description |
---|---|
protected org.apache.commons.logging.Log |
logger |
protected java.util.List<AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher> |
matchers |
Constructor and Description |
---|
AbstractKafkaHeaderMapper(java.lang.String... patterns) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
matches(java.lang.String header) |
protected boolean |
matches(java.lang.String header,
java.lang.Object value) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
fromHeaders, toHeaders
protected final org.apache.commons.logging.Log logger
protected final java.util.List<AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher> matchers