Storevalue after pub to avoid duplicates publishing in slow environment
This commit is contained in:
1 parent
68352f10e6
commit
27fa38ec45
4 files changed
+8
No files matched your search
@@ -146,6 +146,8 @@ void IRtoMQTT(){
|
|||||||
} else if (!isAduplicate(MQTTvalue) && MQTTvalue!=0) {// conditions to avoid duplications of RF -->MQTT
|
} else if (!isAduplicate(MQTTvalue) && MQTTvalue!=0) {// conditions to avoid duplications of RF -->MQTT
|
||||||
trc(F("Adv data IRtoMQTT"));
|
trc(F("Adv data IRtoMQTT"));
|
||||||
pub(subjectIRtoMQTT,IRdata);
|
pub(subjectIRtoMQTT,IRdata);
|
||||||
|
trc(F("Store to avoid duplicate"));
|
||||||
|
storeValue(MQTTvalue);
|
||||||
if (repeatIRwMQTT){
|
if (repeatIRwMQTT){
|
||||||
trc(F("Pub. IR for repeat"));
|
trc(F("Pub. IR for repeat"));
|
||||||
pub(subjectMQTTtoIR,MQTTvalue);
|
pub(subjectMQTTtoIR,MQTTvalue);
|
||||||
|
|||||||
@@ -71,6 +71,8 @@ void RFtoMQTT(){
|
|||||||
RFtoMQTTdiscovery(MQTTvalue);
|
RFtoMQTTdiscovery(MQTTvalue);
|
||||||
#endif
|
#endif
|
||||||
pub(subjectRFtoMQTT,RFdata);
|
pub(subjectRFtoMQTT,RFdata);
|
||||||
|
trc(F("Store to avoid duplicate"));
|
||||||
|
storeValue(MQTTvalue);
|
||||||
if (repeatRFwMQTT){
|
if (repeatRFwMQTT){
|
||||||
trc(F("Pub RF for rpt"));
|
trc(F("Pub RF for rpt"));
|
||||||
pub(subjectMQTTtoRF,RFdata);
|
pub(subjectMQTTtoRF,RFdata);
|
||||||
|
|||||||
@@ -69,6 +69,8 @@ boolean RF315toMQTT(){
|
|||||||
if (!isAduplicate(MQTTvalue) && MQTTvalue!=0) {// conditions to avoid duplications of RF -->MQTT
|
if (!isAduplicate(MQTTvalue) && MQTTvalue!=0) {// conditions to avoid duplications of RF -->MQTT
|
||||||
trc(F("Adv data RF315toMQTT"));
|
trc(F("Adv data RF315toMQTT"));
|
||||||
pub(subjectRF315toMQTT,RF315data);
|
pub(subjectRF315toMQTT,RF315data);
|
||||||
|
trc(F("Store to avoid duplicate"));
|
||||||
|
storeValue(MQTTvalue);
|
||||||
if (repeatRF315wMQTT){
|
if (repeatRF315wMQTT){
|
||||||
trc(F("Publish RF315 for repeat"));
|
trc(F("Publish RF315 for repeat"));
|
||||||
pub(subjectMQTTtoRF315,RF315data);
|
pub(subjectMQTTtoRF315,RF315data);
|
||||||
|
|||||||
@@ -127,6 +127,8 @@ void _rfbDecode() {
|
|||||||
if (!isAduplicate(MQTTvalue) && MQTTvalue!=0) {// conditions to avoid duplications of RF -->MQTT
|
if (!isAduplicate(MQTTvalue) && MQTTvalue!=0) {// conditions to avoid duplications of RF -->MQTT
|
||||||
trc(F("Adv data SRFBtoMQTT"));
|
trc(F("Adv data SRFBtoMQTT"));
|
||||||
pub(subjectSRFBtoMQTT,SRFBdata);
|
pub(subjectSRFBtoMQTT,SRFBdata);
|
||||||
|
trc(F("Store to avoid duplicate"));
|
||||||
|
storeValue(MQTTvalue);
|
||||||
if (repeatSRFBwMQTT){
|
if (repeatSRFBwMQTT){
|
||||||
trc(F("Publish SRFB for repeat"));
|
trc(F("Publish SRFB for repeat"));
|
||||||
pub(subjectMQTTtoSRFB,SRFBdata);
|
pub(subjectMQTTtoSRFB,SRFBdata);
|
||||||
|
|||||||
Reference in new issue
Block a user