Skip to content

Commit c7f7252

Browse files
committed
Update MessageHeaderWarp.java
1 parent 9e618da commit c7f7252

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

arex-instrumentation/mq/arex-integration-mqtt/src/main/java/io/arex/inst/mqtt/warp/MessageHeaderWarp.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,8 +42,14 @@ public MessageHeaderWarp(Map<String, Object> headers, UUID id, Long timestamp) {
4242
}
4343

4444

45+
public Object put(String key, Object value){
46+
this.headers.put(key,value);
47+
return value;
48+
}
4549

46-
50+
public void remove(String key){
51+
this.headers.remove(key);
52+
}
4753

4854
public Map<String, Object> getHeaders() {
4955
return Collections.unmodifiableMap(headers);

0 commit comments

Comments
 (0)