diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-10-04 12:27:03 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-10-04 12:27:03 +0200 |
commit | 93b789c66b883d5ce2dc9ad9edcd164bd4539ff3 (patch) | |
tree | 6b7ebecb2c778a1911b28983d4cee4e04ba96ec9 /container-messagebus/src/main/java/com/yahoo/messagebus | |
parent | 84051a519ba5741edc897328775db8b36d87dbd5 (diff) |
Avoid use of deprecated Request.setServerRequest.
Diffstat (limited to 'container-messagebus/src/main/java/com/yahoo/messagebus')
-rw-r--r-- | container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java | 5 | ||||
-rw-r--r-- | container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/test/ClientTestDriver.java | 7 |
2 files changed, 10 insertions, 2 deletions
diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java index a0bedd678eb..1adad51a052 100644 --- a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java +++ b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java @@ -15,7 +15,10 @@ public class MbusRequest extends Request { private final Message message; public MbusRequest(CurrentContainer current, URI uri, Message msg) { - super(current, uri); + this(current, uri, msg, true); + } + public MbusRequest(CurrentContainer current, URI uri, Message msg, boolean isServerRequest) { + super(current, uri, isServerRequest); this.message = validateMessage(msg); } diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/test/ClientTestDriver.java b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/test/ClientTestDriver.java index ea0ed7eadc8..34b4d47b0b4 100644 --- a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/test/ClientTestDriver.java +++ b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/test/ClientTestDriver.java @@ -7,7 +7,12 @@ import com.yahoo.jdisc.ResourceReference; import com.yahoo.jdisc.application.ContainerBuilder; import com.yahoo.jdisc.handler.ResponseHandler; import com.yahoo.jdisc.test.TestDriver; -import com.yahoo.messagebus.*; +import com.yahoo.messagebus.Message; +import com.yahoo.messagebus.MessageBusParams; +import com.yahoo.messagebus.Protocol; +import com.yahoo.messagebus.Reply; +import com.yahoo.messagebus.SourceSession; +import com.yahoo.messagebus.SourceSessionParams; import com.yahoo.messagebus.jdisc.MbusClient; import com.yahoo.messagebus.jdisc.MbusRequest; import com.yahoo.messagebus.network.rpc.RPCNetworkParams; |