blob: ce73a30cbc0811c1b28bc42e8e78acd93f822ae7 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
// Copyright 2017 Yahoo Holdings. 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();
}
}
|