Using auto create container flag in reactive repository

This commit is contained in:
Kushagra Thapar 2020-03-09 10:18:56 -07:00
Родитель 0ac8d64328
Коммит a4fb017e21
1 изменённых файлов: 6 добавлений и 2 удалений

Просмотреть файл

@ -33,7 +33,9 @@ public class SimpleReactiveCosmosRepository<T, K extends Serializable> implement
this.cosmosOperations = applicationContext.getBean(ReactiveCosmosOperations.class);
this.entityInformation = metadata;
createContainerIfNotExists();
if (this.entityInformation.isAutoCreateContainer()) {
createContainerIfNotExists();
}
}
public SimpleReactiveCosmosRepository(CosmosEntityInformation<T, K> metadata,
@ -41,7 +43,9 @@ public class SimpleReactiveCosmosRepository<T, K extends Serializable> implement
this.cosmosOperations = reactiveCosmosOperations;
this.entityInformation = metadata;
createContainerIfNotExists();
if (this.entityInformation.isAutoCreateContainer()) {
createContainerIfNotExists();
}
}
private CosmosContainerResponse createContainerIfNotExists() {