Skip to content

Commit 09806fd

Browse files
committed
Issue #75 - Removing static logger instances from some more classes & tweaking the connection loss test for v5
Signed-off-by: James Sutton <james.sutton@uk.ibm.com>
1 parent 2494fb3 commit 09806fd

15 files changed

Lines changed: 23 additions & 16 deletions

File tree

org.eclipse.paho.client.mqttv3.test/src/test/java/org/eclipse/paho/client/mqttv3/test/utilities/ConnectionManipulationProxyServer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
public class ConnectionManipulationProxyServer implements Runnable {
1111
static final Class<?> cclass = ConnectionManipulationProxyServer.class;
1212
private static final String className = cclass.getName();
13-
private static final Logger log = Logger.getLogger(className);
13+
private Logger log = Logger.getLogger(className);
1414
private int localPort;
1515
private boolean portSet = false;
1616
private String host;

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/NetworkModuleService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
* @author Maik Scheibler
3232
*/
3333
public class NetworkModuleService {
34-
private static final Logger LOG = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT,
34+
private static Logger LOG = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT,
3535
NetworkModuleService.class.getSimpleName());
3636
private static final ServiceLoader<NetworkModuleFactory> FACTORY_SERVICE_LOADER = ServiceLoader.load(
3737
NetworkModuleFactory.class, NetworkModuleService.class.getClassLoader());

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/Token.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929

3030
public class Token {
3131
private static final String CLASS_NAME = Token.class.getName();
32-
private static final Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT,CLASS_NAME);
32+
private Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT,CLASS_NAME);
3333

3434
private volatile boolean completed = false;
3535
private boolean pendingComplete = false;

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketNetworkModule.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
public class WebSocketNetworkModule extends TCPNetworkModule {
3434

3535
private static final String CLASS_NAME = WebSocketNetworkModule.class.getName();
36-
private static final Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
36+
private Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
3737

3838
private String uri;
3939
private String host;

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
public class WebSocketReceiver implements Runnable{
2727

2828
private static final String CLASS_NAME = WebSocketReceiver.class.getName();
29-
private static final Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
29+
private Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
3030

3131
private boolean running = false;
3232
private boolean stopping = false;

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketSecureNetworkModule.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
public class WebSocketSecureNetworkModule extends SSLNetworkModule{
3333

3434
private static final String CLASS_NAME = WebSocketSecureNetworkModule.class.getName();
35-
private static final Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
35+
private Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
3636

3737
private PipedInputStream pipedInputStream;
3838
private WebSocketReceiver webSocketReceiver;

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/wire/MqttOutputStream.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
*/
3232
public class MqttOutputStream extends OutputStream {
3333
private static final String CLASS_NAME = MqttOutputStream.class.getName();
34-
private static final Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
34+
private Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
3535

3636
private ClientState clientState = null;
3737
private BufferedOutputStream out;

org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/CommsCallback.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@
5353
*/
5454
public class CommsCallback implements Runnable {
5555
private static final String CLASS_NAME = CommsCallback.class.getName();
56-
private static final Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
56+
private Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
5757

5858
private static final int INBOUND_QUEUE_SIZE = 10;
5959
private MqttCallback mqttCallback;

org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/NetworkModuleService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
* @author Maik Scheibler
3232
*/
3333
public class NetworkModuleService {
34-
private static final Logger LOG = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT,
34+
private static Logger LOG = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT,
3535
NetworkModuleService.class.getSimpleName());
3636
private static final ServiceLoader<NetworkModuleFactory> FACTORY_SERVICE_LOADER = ServiceLoader.load(
3737
NetworkModuleFactory.class, NetworkModuleService.class.getClassLoader());

org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/websocket/WebSocketNetworkModule.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
public class WebSocketNetworkModule extends TCPNetworkModule {
3434

3535
private static final String CLASS_NAME = WebSocketNetworkModule.class.getName();
36-
private static final Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
36+
private Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
3737

3838
private String uri;
3939
private String host;

0 commit comments

Comments
 (0)