Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixing AMQ-4892: MQTT clients disconnecting due to socket error do not publish the configured last will and testament message.

This commit is contained in:
Hiram Chirino 2013-11-15 15:51:15 -05:00
parent a46db89b2a
commit 030c2cca31
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTInactivityMonitor.java
View File

@ -126,9 +126,6 @@ public class MQTTInactivityMonitor extends TransportFilter {
}
ASYNC_TASKS.execute(new Runnable() {
public void run() {
if (protocolConverter != null) {
protocolConverter.onTransportError();
}
onException(new InactivityIOException("Channel was inactive for too (>" + readCheckTime + ") long: " + next.getRemoteAddress()));
}
});
@ -172,6 +169,10 @@ public class MQTTInactivityMonitor extends TransportFilter {
public void onException(IOException error) {
if (failed.compareAndSet(false, true)) {
stopMonitorThread();
if (protocolConverter != null) {
protocolConverter.onTransportError();
}
protocolConverter.onTransportError();
transportListener.onException(error);
}
}