diff --git a/openvidu-server/src/main/java/io/openvidu/server/recording/CompositeWrapper.java b/openvidu-server/src/main/java/io/openvidu/server/recording/CompositeWrapper.java
index dfa2ee7d..9b7c80f9 100644
--- a/openvidu-server/src/main/java/io/openvidu/server/recording/CompositeWrapper.java
+++ b/openvidu-server/src/main/java/io/openvidu/server/recording/CompositeWrapper.java
@@ -121,7 +121,11 @@ public class CompositeWrapper {
 
 	public void connectPublisherEndpoint(PublisherEndpoint endpoint) throws OpenViduException {
 		HubPort hubPort = new HubPort.Builder(composite).build();
-		endpoint.connect(hubPort, false);
+
+		// Block on this call: connections must have been already finished
+		// before calling `RecorderEndpoint.record()`.
+		endpoint.connect(hubPort, true);
+
 		String streamId = endpoint.getOwner().getPublisherStreamId();
 		this.hubPorts.put(streamId, hubPort);
 		this.publisherEndpoints.put(streamId, endpoint);
@@ -182,4 +186,4 @@ public class CompositeWrapper {
 		return this.endTime - this.startTime;
 	}
 
-}
\ No newline at end of file
+}