diff options
Diffstat (limited to 'jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java')
-rw-r--r-- | jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java | 38 |
1 files changed, 38 insertions, 0 deletions
diff --git a/jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java b/jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java new file mode 100644 index 00000000000..55c5f28ead6 --- /dev/null +++ b/jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java @@ -0,0 +1,38 @@ +// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. +package com.yahoo.messagebus.jdisc; + +import com.yahoo.jdisc.Request; +import com.yahoo.jdisc.service.CurrentContainer; +import com.yahoo.messagebus.Message; + +import java.net.URI; + +/** + * @author <a href="mailto:simon@yahoo-inc.com">Simon Thoresen</a> + */ +public class MbusRequest extends Request { + + private final Message message; + + public MbusRequest(CurrentContainer current, URI uri, Message msg) { + super(current, uri); + this.message = validateMessage(msg); + } + + public MbusRequest(Request parent, URI uri, Message msg) { + super(parent, uri); + this.message = validateMessage(msg); + } + + public Message getMessage() { + return message; + } + + private Message validateMessage(Message msg) { + if (msg != null) { + return msg; + } + release(); + throw new NullPointerException(); + } +} |