diff --git a/schainpy/model/io/pxIO_param.py b/schainpy/model/io/pxIO_param.py
index d7d4223..fb8446e 100644
--- a/schainpy/model/io/pxIO_param.py
+++ b/schainpy/model/io/pxIO_param.py
@@ -12,12 +12,6 @@ import datetime
 import tarfile
 
 import numpy
-try:
-    from netCDF4 import Dataset
-except:
-    log.warning(
-        'You should install "netCDF4" module if you want to read/write NCDF files'
-        )
 
 from utils import folder_in_range
 
@@ -26,6 +20,13 @@ from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation
 from schainpy.model.data.jrodata import Parameters
 from schainpy.utils import log
 
+try:
+    from netCDF4 import Dataset
+except:
+    log.warning(
+        'You should install "netCDF4" module if you want to read/write NCDF files'
+        )
+
 UT1970 = datetime.datetime(1970, 1, 1) - datetime.timedelta(seconds=time.timezone)
 
 
diff --git a/schainpy/model/utils/jroutils_publish.py b/schainpy/model/utils/jroutils_publish.py
index fdd71ab..7f2b188 100644
--- a/schainpy/model/utils/jroutils_publish.py
+++ b/schainpy/model/utils/jroutils_publish.py
@@ -686,18 +686,23 @@ class PlotterReceiver(ProcessingUnit, Process):
                             if socks.get(self.sender_web) == zmq.POLLIN:
                                 reply = self.sender_web.recv_string()
                                 if reply == 'ok':
+                                    log.log("Response from server ok", self.name)
                                     break
                                 else:
-                                    print("Malformed reply from server: %s" % reply)
+                                    log.warning("Malformed reply from server: {}".format(reply), self.name)
 
                             else:
-                                print("No response from server, retrying...")
+                                log.warning("No response from server, retrying...", self.name)
                             self.sender_web.setsockopt(zmq.LINGER, 0)
                             self.sender_web.close()
                             self.poll.unregister(self.sender_web)
                             retries -= 1
                             if retries == 0:
-                                print("Server seems to be offline, abandoning")
+                                log.error("Server seems to be offline, abandoning", self.name)
+                                self.sender_web = self.context.socket(zmq.REQ)
+                                self.sender_web.connect(self.web_address)
+                                self.poll.register(self.sender_web, zmq.POLLIN)
+                                time.sleep(1)
                                 break
                             self.sender_web = self.context.socket(zmq.REQ)
                             self.sender_web.connect(self.web_address)