Fix NPE in TbMsgMetaData constructor.

@@ -34,7 +34,7 @@ public final class TbMsgMetaData implements Serializable {
     private final Map<String, String> data = new ConcurrentHashMap<>();
     private final Map<String, String> data = new ConcurrentHashMap<>();
 
 
     public TbMsgMetaData(Map<String, String> data) {
     public TbMsgMetaData(Map<String, String> data) {
-        this.data.putAll(data);
+        data.forEach((key, val) -> putValue(key, val));
     }
     }
 
 
     public String getValue(String key) {
     public String getValue(String key) {
@@ -42,7 +42,9 @@ public final class TbMsgMetaData implements Serializable {
     }
     }
 
 
     public void putValue(String key, String value) {
     public void putValue(String key, String value) {
-        data.put(key, value);
+        if (key != null && value != null) {
+            data.put(key, value);
+        }
     }
     }
 
 
     public Map<String, String> values() {
     public Map<String, String> values() {