Added settings for auto-initialize. Fixes #144

src/Akka.Persistence.Azure/Journal/AzureTableStorageJournal.cs

@@ -737,8 +737,26 @@ private async Task<CloudTable> InitCloudStorage(
                 var tableClient = _storageAccount.CreateCloudTableClient();
                 var tableRef = tableClient.GetTableReference(_settings.TableName);
                 var op = new OperationContext();
+
                 using (var cts = new CancellationTokenSource(_settings.ConnectTimeout))
                 {
+                    if (!_settings.AutoInitialize)
+                    {
+                        var exists = await tableRef.ExistsAsync(null, null, cts.Token);
+
+                        if (!exists)
+                        {
+                            remainingTries = 0;
+
+                            throw new Exception(
+                                $"Table {_settings.TableName} doesn't exist. Either create it or turn auto-initialize on");
+                        }
+
+                        _log.Info("Successfully connected to existing table", _settings.TableName);
+
+                        return tableRef;
+                    }
+
                     if (await tableRef.CreateIfNotExistsAsync(new TableRequestOptions(), op, cts.Token))
                         _log.Info("Created Azure Cloud Table", _settings.TableName);
                     else

src/Akka.Persistence.Azure/Journal/AzureTableStorageJournalSettings.cs

@@ -24,7 +24,8 @@ public AzureTableStorageJournalSettings(
             TimeSpan connectTimeout,
             TimeSpan requestTimeout, 
             bool verboseLogging,
-            bool development)
+            bool development, 
+            bool autoInitialize)
         {
             if(string.IsNullOrWhiteSpace(tableName))
                 throw new ConfigurationException("[AzureTableStorageJournal] Table name is null or empty.");
@@ -43,6 +44,7 @@ public AzureTableStorageJournalSettings(
             RequestTimeout = requestTimeout;
             VerboseLogging = verboseLogging;
             Development = development;
+            AutoInitialize = autoInitialize;
         }
 
         /// <summary>
@@ -71,6 +73,8 @@ public AzureTableStorageJournalSettings(
         public bool VerboseLogging { get; }
 
         public bool Development { get; }
+
+        public bool AutoInitialize { get; }
 
         /// <summary>
         ///     Creates an <see cref="AzureTableStorageJournalSettings" /> instance using the
@@ -86,14 +90,16 @@ public static AzureTableStorageJournalSettings Create(Config config)
             var requestTimeout = config.GetTimeSpan("request-timeout", TimeSpan.FromSeconds(3));
             var verbose = config.GetBoolean("verbose-logging", false);
             var development = config.GetBoolean("development", false);
+            var autoInitialize = config.GetBoolean("auto-initialize", true);
 
             return new AzureTableStorageJournalSettings(
                 connectionString, 
                 tableName, 
                 connectTimeout, 
                 requestTimeout,
                 verbose,
-                development);
+                development,
+                autoInitialize);
         }
     }
 }

src/Akka.Persistence.Azure/Snapshot/AzureBlobSnapshotStore.cs

@@ -70,6 +70,23 @@ private async Task<CloudBlobContainer> InitCloudStorage(int remainingTries)
 
                 using (var cts = new CancellationTokenSource(_settings.ConnectTimeout))
                 {
+                    if (!_settings.AutoInitialize)
+                    {
+                        var exists = await containerRef.ExistsAsync(null, null, cts.Token);
+
+                        if (!exists)
+                        {
+                            remainingTries = 0;
+
+                            throw new Exception(
+                                $"Container {_settings.ContainerName} doesn't exist. Either create it or turn auto-initialize on");
+                        }
+
+                        _log.Info("Successfully connected to existing container", _settings.ContainerName);
+
+                        return containerRef;
+                    }
+
                     if (await containerRef.CreateIfNotExistsAsync(BlobContainerPublicAccessType.Container,
                         new BlobRequestOptions(), op, cts.Token))
                         _log.Info("Created Azure Blob Container", _settings.ContainerName);

src/Akka.Persistence.Azure/Snapshot/AzureBlobSnapshotStoreSettings.cs

@@ -17,7 +17,7 @@ namespace Akka.Persistence.Azure.Snapshot
     public sealed class AzureBlobSnapshotStoreSettings
     {
         public AzureBlobSnapshotStoreSettings(string connectionString, string containerName,
-            TimeSpan connectTimeout, TimeSpan requestTimeout, bool verboseLogging, bool development)
+            TimeSpan connectTimeout, TimeSpan requestTimeout, bool verboseLogging, bool development, bool autoInitialize)
         {
             if (string.IsNullOrWhiteSpace(containerName))
                 throw new ConfigurationException("[AzureBlobSnapshotStore] Container name is null or empty.");
@@ -29,6 +29,7 @@ public AzureBlobSnapshotStoreSettings(string connectionString, string containerN
             ConnectTimeout = connectTimeout;
             VerboseLogging = verboseLogging;
             Development = development;
+            AutoInitialize = autoInitialize;
         }
 
         /// <summary>
@@ -58,6 +59,8 @@ public AzureBlobSnapshotStoreSettings(string connectionString, string containerN
 
         public bool Development { get; }
 
+        public bool AutoInitialize { get; }
+
         /// <summary>
         ///     Creates an <see cref="AzureBlobSnapshotStoreSettings" /> instance using the
         ///     `akka.persistence.snapshot-store.azure-blob-store` HOCON configuration section.
@@ -72,14 +75,16 @@ public static AzureBlobSnapshotStoreSettings Create(Config config)
             var requestTimeout = config.GetTimeSpan("request-timeout", TimeSpan.FromSeconds(3));
             var verbose = config.GetBoolean("verbose-logging", false);
             var development = config.GetBoolean("development", false);
+            var autoInitialize = config.GetBoolean("auto-initialize", true);
 
             return new AzureBlobSnapshotStoreSettings(
                 connectionString, 
                 containerName, 
                 connectTimeout, 
                 requestTimeout,
                 verbose,
-                development);
+                development,
+                autoInitialize);
         }
     }
 }

src/Akka.Persistence.Azure/reference.conf

@@ -31,6 +31,9 @@ akka.persistence {
       # Support for Azure Storage Emulator for local development.
       # Will ignore connection string settings if turned on.
       development = off
+
+      # Creates the required table if set
+      auto-initialize = on
     }
   }  
 
@@ -86,6 +89,9 @@ akka.persistence {
       # Support for Azure Storage Emulator for local development.
       # Will ignore connection string settings if turned on.
       development = off
+
+      # Creates the required container if set
+      auto-initialize = on
     }
   }
 }