1 package net.anyflow.lannister.client;
2
3 import io.netty.handler.codec.mqtt.MqttMessage;
4
5 public class SharedObject {
6 private MqttMessage receivedMessage;
7 private Object locker;
8
9 public SharedObject() {
10 receivedMessage = null;
11 locker = new Object();
12 }
13
14 public Object locker() {
15 return locker;
16 }
17
18 public MqttMessage receivedMessage() {
19 return receivedMessage;
20 }
21
22 public void receivedMessage(MqttMessage receivedMessage) {
23 this.receivedMessage = receivedMessage;
24 }
25 }