diff --git a/pkg/test/integration/camlistore_test.go b/pkg/test/integration/camlistore_test.go
index 976adc83f..5b9370b17 100644
--- a/pkg/test/integration/camlistore_test.go
+++ b/pkg/test/integration/camlistore_test.go
@@ -90,6 +90,15 @@ func TestWebsocketQuery(t *testing.T) {
 			errc <- err
 			return
 		}
+		if !strings.HasPrefix(string(inMsg), `{"tag":"_status"`) {
+			errc <- fmt.Errorf("unexpected message type=%d msg=%q, wanted status update", inType, inMsg)
+			return
+		}
+		inType, inMsg, err = wc.ReadMessage()
+		if err != nil {
+			errc <- err
+			return
+		}
 		if strings.Contains(string(inMsg), pn.String()) {
 			errc <- nil
 			return