diff --git a/lighthub/flashstream.cpp b/lighthub/flashstream.cpp
index ee79226..06fef8f 100644
--- a/lighthub/flashstream.cpp
+++ b/lighthub/flashstream.cpp
@@ -39,6 +39,8 @@ extern NRFFlashStorage EEPROM;
 
 #if defined(__SAM3X8E__)
 DueFlashStorage EEPROM;
+ static char samBuffer[64];
+ short samBufferPos = 0;
 #endif
 
 #ifdef NRF5
@@ -129,6 +131,10 @@ NRFFlashStorage EEPROM;
     int  flashStream::open(short fileNum, char mode) 
                 {
 
+                  #if  defined(__SAM3X8E__)
+                  samBufferPos = 0;
+                  #endif 
+
                  switch (fileNum) {
                    case FN_CONFIG_JSON:     
                         pos = 0;
@@ -138,6 +144,7 @@ NRFFlashStorage EEPROM;
                         #ifdef OTA
                         contentType = HTTP_TEXT_JSON;
                         #endif
+                        openmode = mode;
                         return 1;    
                     
                   case FN_CONFIG_BIN:                    
@@ -148,6 +155,7 @@ NRFFlashStorage EEPROM;
                         #ifdef OTA
                         contentType = HTTP_OCTET_STREAM;
                         #endif
+                        openmode = mode;
                         return 1;
 
                    default:
@@ -171,7 +179,13 @@ NRFFlashStorage EEPROM;
                 };
 
      unsigned int flashStream::seek(unsigned int _pos) 
-        {   pos=min(_pos, streamSize);
+        {   
+         
+          #if  defined(__SAM3X8E__)
+          if (samBufferPos) flush();
+          #endif
+
+         pos=min(_pos, streamSize);
             //debugSerial<<F("Seek:")<<pos<<endl;
             return pos;
         };
@@ -196,21 +210,37 @@ NRFFlashStorage EEPROM;
             else return -1;    
             };
 
+    
     void flashStream::flush() {
         #if defined(ESP8266) || defined(ESP32)
         if (EEPROM.commitReset())
                 infoSerial<<"Commited to FLASH"<<endl;
         else    errorSerial<<"Commit error. len:"<<EEPROM.length()<<endl;       
+        #elif  defined(__SAM3X8E__)
+        if (samBufferPos)
+             EEPROM.write(startPos+pos-samBufferPos,(byte*)samBuffer,samBufferPos);    
         #endif
    };
-          
+   
+
     size_t flashStream::write(uint8_t ch) 
             {
                #if defined(__AVR__)
                   EEPROM.update(startPos+pos++,(char)ch);
                   return 1;
                #elif  defined(__SAM3X8E__)
-                  return EEPROM.write(startPos+pos++,(char)ch);
+      
+               if (samBufferPos==sizeof(samBuffer))
+                        {            
+                           samBufferPos = 0;
+                           EEPROM.write(startPos+pos-sizeof(samBuffer),(byte*)samBuffer,sizeof(samBuffer));                     
+                        }
+           
+               samBuffer[samBufferPos++]=ch;
+               pos++;
+               return 1;
+                //  return EEPROM.write(startPos+pos++,(char)ch);
+
                #else 
                   EEPROM.write(startPos+pos++,(char)ch);
                   return 1;  
@@ -237,7 +267,10 @@ NRFFlashStorage EEPROM;
 
  void flashStream::close()  
     {  
-       putEOF();
+      if (openmode == 'w') putEOF();
+      #if  defined(__SAM3X8E__)
+      if (samBufferPos) flush();
+      #endif
     }    
 
 
diff --git a/lighthub/flashstream.h b/lighthub/flashstream.h
index 5cfb6d4..0c9cab6 100644
--- a/lighthub/flashstream.h
+++ b/lighthub/flashstream.h
@@ -53,9 +53,10 @@ class flashStream : public seekableStream
 protected:
 unsigned int pos;  
 unsigned int startPos; 
+char openmode ;
 
 public:
-    flashStream():seekableStream(MAX_STREAM_SIZE){};
+    flashStream():seekableStream(MAX_STREAM_SIZE){openmode = '\0';};
     void setSize(unsigned int _size);
     int open(short fileNum, char mode='\0') ; 
     virtual int open(String _filename, char mode='\0') override;
diff --git a/lighthub/main.cpp b/lighthub/main.cpp
index 81ec8ee..0ccc4b4 100644
--- a/lighthub/main.cpp
+++ b/lighthub/main.cpp
@@ -664,6 +664,8 @@ lan_status lanLoop() {
                 setTopic(buf,sizeof(buf),T_OUT);
                 strncat(buf, "+/+/#", sizeof(buf)); // Subscribing only on separated command/parameters topics
                 mqttClient.unsubscribe(buf);
+                
+                onMQTTConnect();
 
                 lanStatus = OPERATION;//3;
                 infoSerial<<F("Accepting commands...\n");
@@ -1002,7 +1004,7 @@ void ip_ready_config_loaded_connecting_to_broker() {
             debugSerialPort.println(buf);
             mqttClient.subscribe(buf);
 
-            onMQTTConnect();
+            //onMQTTConnect();
             // if (_once) {DMXput(); _once=0;}
             lanStatus = RETAINING_COLLECTING;//4;
             timerLanCheckTime = millis();// + 5000;
@@ -1497,11 +1499,11 @@ if (arg_cnt>1)
     #else
     sysConfStream.open(FN_CONFIG_JSON,'w');
     #endif
-
+/*
 #if defined(__SAM3X8E__) 
   long configBufSize = min(MAX_JSON_CONF_SIZE,freeRam()-1024);
   debugSerial<<"Allocate "<<configBufSize<<" bytes for buffer"<<endl;
-  char* outBuf = (char*) malloc(configBufSize); /* XXX: Dynamic size. */
+  char* outBuf = (char*) malloc(configBufSize); 
   if (!outBuf)
     {
       sysConfStream.close();  
@@ -1509,23 +1511,22 @@ if (arg_cnt>1)
       return 500;
     }
   infoSerial<<F("Saving config to EEPROM..")<<endl;
-  aJsonStringStream stringStream(NULL, outBuf, configBufSize);
+  aJsonStringStream stringStream(NULL, outBuf, configBufSize-2);
   aJson.print(root, &stringStream);
   int len = strlen(outBuf);
   outBuf[len++]= EOFchar;
-  
+  infoSerial<<len<< F(" bytes collected")<<endl;
   size_t res = sysConfStream.write((byte*) outBuf,len);
   free (outBuf);
-  infoSerial<<res<< F(" bytes from ")<<len<<F(" are saved to EEPROM")<<endl;
-#else
+  infoSerial<<res<< F(" bytes are saved to EEPROM")<<endl;
+#else */
+
     aJsonStream jsonEEPROMStream = aJsonStream(&sysConfStream);
     infoSerial<<F("Saving config to EEPROM..");
     aJson.print(root, &jsonEEPROMStream);
-    //sysConfStream.putEOF();
-    //sysConfStream.flush();
     sysConfStream.close();
     infoSerial<<F("Saved to EEPROM")<<endl;
-#endif
+//#endif
 sysConf.saveETAG();
 return 200;
 }
@@ -2285,6 +2286,10 @@ infoSerial<<F("\n(+)HUMIDIFIER");
 #ifdef ELEVATOR_ENABLE
 infoSerial<<F("\n(+)ELEVATOR");
 #endif
+
+#ifdef IPMODBUS
+infoSerial<<F("\n(+)IPMODBUS");
+#endif
 infoSerial<<endl;
 
 //    WDT_Disable( WDT ) ;
diff --git a/lighthub/main.h b/lighthub/main.h
index 336db9e..91494ab 100644
--- a/lighthub/main.h
+++ b/lighthub/main.h
@@ -317,4 +317,6 @@ void ip_ready_config_loaded_connecting_to_broker();
 
 void printCurentLanConfig();
 
+void onMQTTConnect();
+
 //void printFreeRam();
diff --git a/lighthub/modules/out_pid.cpp b/lighthub/modules/out_pid.cpp
index c577b62..9c12589 100644
--- a/lighthub/modules/out_pid.cpp
+++ b/lighthub/modules/out_pid.cpp
@@ -14,6 +14,7 @@ bool out_pid::getConfig()
   double kI=0.0;
   double kD=0.0;
   int direction = DIRECT;
+  bool limits = false;
 
   // Retrieve and store 
   if (!store || !item || !item->itemArg || (item->itemArg->type != aJson_Array) || aJson.getArraySize(item->itemArg)<1)
@@ -28,8 +29,8 @@ bool out_pid::getConfig()
               errorSerial<<F("Invalid PID param array.")<<endl;
               return false;
             }
-   double outMin=0.;  //UNUSED
-   double outMax=255.;//UNUSED
+   double outMin=0.;  
+   double outMax=255.;
    float  dT=5.;
    uint32_t   alarmTO=PERIOD_THERMOSTAT_FAILED;
 
@@ -37,13 +38,13 @@ bool out_pid::getConfig()
    switch (aJson.getArraySize(kPIDObj))
    { case 8: //kP,kI,kD,dT, alarmTO, alarmVal, outMin, outMax
        param = aJson.getArrayItem(kPIDObj, 7);
-       if (param->type == aJson_Float) outMax=param->valuefloat;
-       else if (param->type == aJson_Int) outMax=param->valueint;
+       if (param->type == aJson_Float) {outMax=param->valuefloat;limits=true;}
+       else if (param->type == aJson_Int) {outMax=param->valueint;limits=true;}
 
      case 7: //kP,kI,kD,dT alarmTO, alarmVal, outMin
        param = aJson.getArrayItem(kPIDObj, 6);
-       if (param->type == aJson_Float) outMin=param->valuefloat;
-       else if (param->type == aJson_Int) outMin=param->valueint;    
+       if (param->type == aJson_Float) {outMin=param->valuefloat;limits=true;}
+       else if (param->type == aJson_Int) {outMin=param->valueint;limits=true;}    
 
      case 6: //kP,kI,kD,dT, alarmTO, alarmVal
      case 5: //kP,kI,kD,dT, alarmTO
@@ -99,7 +100,7 @@ bool out_pid::getConfig()
       {store->pid= new PID  (&store->input, &store->output, &store->setpoint, kP, kI, kD, direction);
       if (!store->pid) return false;
       store->pid->SetMode(AUTOMATIC);
-      //store->pid->SetOutputLimits(outMin,outMax);
+      if (limits) store->pid->SetOutputLimits(outMin,outMax);
       store->pid->SetSampleTime(dT*1000.0); 
       return true;}
   else errorSerial<<F("PID already initialized")<<endl;    
diff --git a/lighthub/options.h b/lighthub/options.h
index 21f045e..a67e8d5 100644
--- a/lighthub/options.h
+++ b/lighthub/options.h
@@ -9,7 +9,7 @@
 #ifndef MAX_JSON_CONF_SIZE
 
 #if defined(__SAM3X8E__)
-#define MAX_JSON_CONF_SIZE 24000
+#define MAX_JSON_CONF_SIZE 65535
 #elif defined(ARDUINO_ARCH_AVR)
 #define MAX_JSON_CONF_SIZE 4096
 #elif defined(ARDUINO_ARCH_ESP32)