Skip to content

Commit 55d69e4

Browse files
committed
fixes user's metadata retrieval
1 parent 577966c commit 55d69e4

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

rsocket-ipc-core/src/main/java/io/rsocket/ipc/decoders/CompositeMetadataDecoder.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import static io.rsocket.metadata.CompositeMetadataFlyweight.hasEntry;
44

55
import io.netty.buffer.ByteBuf;
6+
import io.netty.buffer.Unpooled;
67
import io.opentracing.SpanContext;
78
import io.opentracing.Tracer;
89
import io.rsocket.Payload;
@@ -34,7 +35,7 @@ public CompositeMetadataDecoder(Tracer tracer) {
3435
public <T> T decode(Payload payload, Handler<T> transformer) throws Exception {
3536
ByteBuf metadata = payload.sliceMetadata();
3637

37-
ByteBuf meta = null;
38+
ByteBuf meta;
3839
String route = null;
3940
SpanContext context = null;
4041

@@ -70,12 +71,14 @@ public <T> T decode(Payload payload, Handler<T> transformer) throws Exception {
7071
try {
7172
String service = Metadata.getService(metadata);
7273
String method = Metadata.getMethod(metadata);
74+
meta = Metadata.getMetadata(metadata);
7375

7476
route = service + "." + method;
7577
context = Tracing.deserializeTracingMetadata(tracer, metadata);
7678
} catch (Throwable t) {
7779
// Here we probably got something from Spring-Messaging :D
7880
route = metadata.toString(Charset.defaultCharset());
81+
meta = Unpooled.EMPTY_BUFFER;
7982
}
8083
}
8184

0 commit comments

Comments
 (0)