1 files changed, 5 insertions, 4 deletions
diff --git a/src/AVTInput.cpp b/src/AVTInput.cpp
index 0d6f229..16d10c3 100644
--- a/src/AVTInput.cpp
+++ b/src/AVTInput.cpp
@@ -166,10 +166,11 @@ int AVTInput::_openSocketSrv(Socket::UDPSocket* socket, const char* uri)
 
     if (_parseURI(uri, address, port)) {
         returnCode = 0;
-        socket->reinit(port);
-
-        if (!address.empty()) {
-            socket->joinGroup(address.c_str());
+        if (address.empty()) {
+            socket->reinit(port);
+        }
+        else {
+            socket->init_receive_multicast(port, "0.0.0.0", address.c_str());
         }
 
         socket->setBlocking(false);