Connection lost (32109) - java.io.EOFException

Connection lost (32109) - java.io.EOFException
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:181)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.io.EOFException
at java.io.DataInputStream.readByte(DataInputStream.java:267)
at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:92)
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:133)
... 7 more

Code snippet used to build mqtt client:

__public static MqttClient addClientWithLogin(String address, String id, String uid, String pwd, ArrayList topics, MqttCallback mqttCallback) {
MqttClient client = null;
try {
client = new MqttClient(address, id);
MqttConnectOptions opts = new MqttConnectOptions();
opts.setUserName(uid);
opts.setPassword(pwd.toCharArray());
opts.setCleanSession(true);
opts.setMaxInflight(1000);
opts.setKeepAliveInterval(15);
opts.setConnectionTimeout(0);
client.setCallback(mqttCallback);
client.connect(opts);
if (topics != null && topics instanceof ArrayList) {
Object[] listOfTopics = topics.toArray();
for (Object topic : listOfTopics) {
client.subscribe(topic.toString());
}
}
} catch (MqttException ex) {
logger.error(ExceptionUtils.getStackTrace(ex));
}

return client;
}__