Skip to content
This repository was archived by the owner on Mar 13, 2021. It is now read-only.

Commit a2a5686

Browse files
trisbergdsyer
authored andcommitted
Skip read-only timestamp header when converting incoming message
Fixes #62
1 parent 395c3ff commit a2a5686

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/main/java/io/projectriff/invoker/MessageConversionUtils.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,9 @@ public static Message<byte[]> fromGrpc(
3939
MessageBuilder<byte[]> builder = MessageBuilder
4040
.withPayload(input.getPayload().toByteArray());
4141
for (Entry<String, HeaderValue> entry : input.getHeadersMap().entrySet()) {
42+
if (MessageHeaders.TIMESTAMP.equals(entry.getKey())) {
43+
continue;
44+
}
4245
HeaderValue header = entry.getValue();
4346
if (header.getValuesCount() > 0) {
4447
Object value;

0 commit comments

Comments
 (0)