Browse Source

TbMsgMetaData refactored constructor and copy method

pull/5843/head
Sergey Matvienko 5 years ago
parent
commit
f5c09d221d
  1. 13
      common/message/src/main/java/org/thingsboard/server/common/msg/TbMsgMetaData.java

13
common/message/src/main/java/org/thingsboard/server/common/msg/TbMsgMetaData.java

@ -15,9 +15,7 @@
*/ */
package org.thingsboard.server.common.msg; package org.thingsboard.server.common.msg;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
import java.util.Collections; import java.util.Collections;
@ -29,15 +27,18 @@ import java.util.concurrent.ConcurrentHashMap;
* Created by ashvayka on 13.01.18. * Created by ashvayka on 13.01.18.
*/ */
@Data @Data
@NoArgsConstructor
public final class TbMsgMetaData implements Serializable { public final class TbMsgMetaData implements Serializable {
public static final TbMsgMetaData EMPTY = new TbMsgMetaData(Collections.emptyMap()); public static final TbMsgMetaData EMPTY = new TbMsgMetaData(Collections.emptyMap());
private final Map<String, String> data = new ConcurrentHashMap<>(); private final Map<String, String> data;
public TbMsgMetaData() {
this.data = new ConcurrentHashMap<>();
}
public TbMsgMetaData(Map<String, String> data) { public TbMsgMetaData(Map<String, String> data) {
data.forEach((key, val) -> putValue(key, val)); this.data = new ConcurrentHashMap<>(data);
} }
public String getValue(String key) { public String getValue(String key) {
@ -55,6 +56,6 @@ public final class TbMsgMetaData implements Serializable {
} }
public TbMsgMetaData copy() { public TbMsgMetaData copy() {
return new TbMsgMetaData(new ConcurrentHashMap<>(data)); return new TbMsgMetaData(data);
} }
} }

Loading…
Cancel
Save