Add guard against null values in extract adapter.
@@ -12,9 +12,11 @@ public class TextMapExtractAdapter implements TextMap {
public TextMapExtractAdapter(final Map<String, Object> headers) {
for (final Map.Entry<String, Object> entry : headers.entrySet()) {
+ if (entry != null && entry.getValue() != null) {
map.put(entry.getKey(), entry.getValue().toString());
}
}
+ }
@Override
public Iterator<Map.Entry<String, String>> iterator() {
