Trying to fix CI test failures: Don't send anymore data down the transport once it's closed/disconnected.
activemq/trunk/activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTTransportFilter.java