AeronArchive timeouts on connect

[zyulyaev]

Following snippet throws TimeoutException on second AeronArchive.connect.

String archivingDir = Files.createTempDirectory("md").toString();
String clientDir = Files.createTempDirectory("md").toString();
try (ArchivingMediaDriver archivingDriver = ArchivingMediaDriver.launch(
    new MediaDriver.Context()
        .aeronDirectoryName(archivingDir)
        .threadingMode(ThreadingMode.SHARED),
    new Archive.Context()
        .aeronDirectoryName(archivingDir)
        .threadingMode(ArchiveThreadingMode.SHARED)
        .archiveDir(Files.createTempDirectory("ar").toFile()));
     MediaDriver clientDriver = MediaDriver.launch(new MediaDriver.Context()
         .aeronDirectoryName(clientDir)))
{
    try (Aeron aeron = Aeron.connect(new Aeron.Context()
        .aeronDirectoryName(clientDir)))
    {
        AeronArchive archive = AeronArchive.connect(new AeronArchive.Context()
            .aeron(aeron));
    }

    Thread.sleep(1000);

    try (Aeron aeron = Aeron.connect(new Aeron.Context()
        .aeronDirectoryName(clientDir));
         AeronArchive archive = AeronArchive.connect(new AeronArchive.Context()
             .aeron(aeron)))
    {

    }
}

[zyulyaev]

Looks like the problem is due to reusing archive egress publication, which leads to sending connect response before client's subscription actually connected.
Can be fixed by using exclusive publication instead.