diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2020-12-21 12:46:23 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2020-12-21 12:46:23 +0100 |
commit | 4c1e1dff938c79360c8c9cf38c2dd9fd14845ee7 (patch) | |
tree | 55948b50c588baa5cdc804a10230202c0ea148a0 /docproc | |
parent | da2c5cbd98fae2aa49de427236a5259d79ad2083 (diff) |
Avoid indirection and outdated code
Diffstat (limited to 'docproc')
-rw-r--r-- | docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MbusRequestContext.java | 14 |
1 files changed, 4 insertions, 10 deletions
diff --git a/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MbusRequestContext.java b/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MbusRequestContext.java index 2b9042bafac..f712231e939 100644 --- a/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MbusRequestContext.java +++ b/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MbusRequestContext.java @@ -77,7 +77,7 @@ public class MbusRequestContext implements RequestContext, ResponseHandler { public void skip() { if (deserialized.get()) throw new IllegalStateException("Can not skip processing after deserialization"); - dispatchRequest(requestMsg, request.getUri().getPath(), responseHandler); + dispatchRequest(requestMsg, getUri().getPath(), responseHandler); } @Override @@ -183,7 +183,9 @@ public class MbusRequestContext implements RequestContext, ResponseHandler { @Override protected Request newRequest() { - return new MbusRequest(request, resolveUri(uriPath), msg); + return new MbusRequest(request, + uriCache.computeIfAbsent(uriPath, __ -> URI.create("mbus://remotehost" + uriPath)), + msg); } @Override @@ -203,12 +205,4 @@ public class MbusRequestContext implements RequestContext, ResponseHandler { return new MessageFactory(message); } - private static URI resolveUri(String path) { - URI uri = uriCache.get(path); - if (uri == null) { - uri = URI.create("mbus://remotehost" + path); - uriCache.put(path, uri); - } - return uri; - } } |