Package: JmsMessage

JmsMessage

name	instruction	branch	complexity	line	method
JmsMessage(JmsTopic, Date, JmsPayload)	M: 12 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 5 C: 0 0%	M: 1 C: 0 0%
getPayload()	M: 13 C: 0 0%	M: 2 C: 0 0%	M: 2 C: 0 0%	M: 3 C: 0 0%	M: 1 C: 0 0%
getReceivedOn()	M: 3 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%
getTopic()	M: 3 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%
setPayload(JmsPayload)	M: 4 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 2 C: 0 0%	M: 1 C: 0 0%
setReceivedOn(Date)	M: 4 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 2 C: 0 0%	M: 1 C: 0 0%
setTopic(JmsTopic)	M: 4 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 2 C: 0 0%	M: 1 C: 0 0%
toString()	M: 40 C: 0 0%	M: 6 C: 0 0%	M: 4 C: 0 0%	M: 5 C: 0 0%	M: 1 C: 0 0%

Coverage

1: /*******************************************************************************
2: * Copyright (c) 2016, 2020 Eurotech and/or its affiliates and others
3: *
4: * All rights reserved. This program and the accompanying materials
5: * are made available under the terms of the Eclipse Public License v1.0
6: * which accompanies this distribution, and is available at
7: * http://www.eclipse.org/legal/epl-v10.html
8: *
9: * Contributors:
10: * Eurotech - initial API and implementation
11: * Red Hat Inc
12: *******************************************************************************/
13: package org.eclipse.kapua.transport.message.jms;
14:
15: import org.eclipse.kapua.transport.message.TransportMessage;
16:
17: import java.util.Date;
18:
19: /**
20: * Implementation of {@link TransportMessage} API for JMS transport facade.
21: */
22: public class JmsMessage implements TransportMessage<JmsTopic, JmsPayload> {
23:
24: private static final long serialVersionUID = 1L;
25:
26: /**
27: * The topic of this {@link JmsMessage}.
28: *
29: * @since 1.0.0
30: */
31: private JmsTopic topic;
32:
33: /**
34: * The receivedOn of this {@link JmsMessage}.
35: *
36: * @since 1.0.0
37: */
38: private Date receivedOn;
39:
40: /**
41: * The payload of this {@link JmsMessage}.
42: *
43: * @since 1.0.0
44: */
45: private JmsPayload payload;
46:
47: /**
48: * Construct a {@link JmsMessage} with the given parameters.
49: *
50: * @param topic The {@link JmsTopic} to set for this {@link JmsMessage}.
51: * @param receivedOn The received on to set for this {@link JmsMessage}.
52: * @param payload The {@link JmsPayload} to set for this {@link JmsMessage}.
53: * @since 1.0.0
54: */
55: public JmsMessage(JmsTopic topic, Date receivedOn, JmsPayload payload) {
56: setTopic(topic);
57: setReceivedOn(receivedOn);
58: setPayload(payload);
59: }
60:
61: /**
62: * Gets the {@link JmsTopic} set for this {@link JmsMessage}.
63: *
64: * @return The {@link JmsTopic} set for this {@link JmsMessage}.
65: * @since 1.0.0
66: */
67: public JmsTopic getTopic() {
68: return topic;
69: }
70:
71: /**
72: * Sets the {@link JmsTopic} set for this {@link JmsMessage}.
73: *
74: * @param topic The {@link JmsTopic} to set for this {@link JmsMessage}.
75: * @since 1.0.0
76: */
77: public void setTopic(JmsTopic topic) {
78: this.topic = topic;
79: }
80:
81: /**
82: * Gets the received on set for this {@link JmsMessage}.
83: *
84: * @return The received on set for this {@link JmsMessage}.
85: * @since 1.0.0
86: */
87: public Date getReceivedOn() {
88: return receivedOn;
89: }
90:
91: /**
92: * Sets the received on set for this {@link JmsMessage}.
93: *
94: * @param receivedOn The received on to set for this {@link JmsMessage}.
95: * @since 1.0.0
96: */
97: public void setReceivedOn(Date receivedOn) {
98: this.receivedOn = receivedOn;
99: }
100:
101: /**
102: * Gets the {@link JmsPayload} set for this {@link JmsMessage}.
103: *
104: * @return The {@link JmsPayload} set for this {@link JmsMessage}.
105: * @since 1.0.0
106: */
107: public JmsPayload getPayload() {
108:• if (payload == null) {
109: payload = new JmsPayload(new byte[0]);
110: }
111:
112: return payload;
113: }
114:
115: /**
116: * Sets the {@link JmsPayload} set for this {@link JmsMessage}.
117: *
118: * @param payload The {@link JmsPayload} to set for this {@link JmsMessage}.
119: * @since 1.0.0
120: */
121: public void setPayload(JmsPayload payload) {
122: this.payload = payload;
123: }
124:
125: /**
126: * Gets the {@link JmsMessage} fields concatenated in a user-friendly {@link String}.
127: *
128: * @return The {@link JmsMessage} fields concatenated in a user-friendly {@link String}.
129: * @since 1.2.0
130: */
131: @Override
132: public String toString() {
133: String[] toStringTokens = new String[3];
134:
135:• toStringTokens[0] = getReceivedOn() != null ? getReceivedOn().toString() : null;
136:• toStringTokens[1] = getTopic() != null ? getTopic().toString() : null;
137:• toStringTokens[2] = getPayload() != null ? getPayload().toString() : null;
138:
139: return String.join(", ", toStringTokens);
140: }
141: }