diff --git a/src/BridgeProps.cpp b/src/BridgeProps.cpp index a4b4854..00dd7e5 100644 --- a/src/BridgeProps.cpp +++ b/src/BridgeProps.cpp @@ -21,8 +21,9 @@ void BridgeProps::begin(void(*on_message)(String)) if (on_message) onInboxMessageReceived = on_message; } -void BridgeProps::setBrokerIpAddress(IPAddress ip) +void BridgeProps::setBrokerIpAddress(IPAddress ip, uint16_t port) { _brokerIpAddress = ip; + _client.setServer(_brokerIpAddress, port); } diff --git a/src/BridgeProps.h b/src/BridgeProps.h index 7e55a7f..e8738e3 100644 --- a/src/BridgeProps.h +++ b/src/BridgeProps.h @@ -19,7 +19,7 @@ class BridgeProps : public Props public: BridgeProps(const char*, const char*, const char*, const char*, const int); void begin(void(*)(String) = NULL); - void setBrokerIpAddress(IPAddress); + void setBrokerIpAddress(IPAddress, uint16_t port = 1883); private: BridgeClient _bridgeClient;