Uses of Class
com.broadleafcommerce.dataexchange.service.BatchContext

Packages that use BatchContext

Package	Description
com.broadleafcommerce.dataexchange.domain.util
com.broadleafcommerce.dataexchange.service
com.broadleafcommerce.dataexchange.service.catalog
com.broadleafcommerce.dataexchange.service.product
com.broadleafcommerce.dataexchange.service.provider
com.broadleafcommerce.dataexchange.service.provider.external

Uses of BatchContext in com.broadleafcommerce.dataexchange.domain.util

Methods in com.broadleafcommerce.dataexchange.domain.util with parameters of type BatchContext

Modifier and Type	Method	Description
static void	ReflectionUtils.resolveErrors(Function<Throwable,DataExchangeError> dataExchangeErrorSupplier, BatchContext<?> batchContext)	This method walks the resulting object graph from getSavedTopLevelEntities() that were either saved or errored, and assigns errors to getResponseErrors().
Retryable.RetryableBuilder<X>	Retryable.RetryableBuilder.withExceptionConsumer(ExchangeObject exchangeObject, BatchContext<?> batchContext)	Creates a Consumer that calls registerException(String, Throwable) using the ExchangeObject.getCorrelationId() as the key and logs the exception.

Uses of BatchContext in com.broadleafcommerce.dataexchange.service

Methods in com.broadleafcommerce.dataexchange.service that return BatchContext

Modifier and Type	Method	Description
BatchContext<T1>	HandlerArgs.getBatchContext()	The batch context that the item is being saved in.
final BatchContext<T>	AbstractDataExchangeService.saveAll(@NonNull List<T> entities, @NonNull com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	This method takes the list of entities to be saved, splits them into their individual pieces that have to be saved separately.
BatchContext<T>	DataExchangeService.saveAll(List<T> entities, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Accepts a list of entities, typically composite entities that require calls to multiple services and/or service API endpoints to create or update.

Methods in com.broadleafcommerce.dataexchange.service with parameters of type BatchContext

Modifier and Type	Method	Description
protected void	AbstractDataExchangeService.aggregate(BatchContext<T> batchContext)	This process takes all the entities that have been saved, aggregates or augments them, and returns them.
CompletableFuture<Void>	AbstractBatchItemHandler.execute(T1 parent, ExchangeObject exchangeObject, BatchContext<T1> batchContext, org.springframework.core.task.AsyncTaskExecutor executor, org.springframework.retry.support.RetryTemplate retryTemplate)
CompletableFuture<Void>	AbstractBatchItemHandler.execute(T1 parent, ExchangeObject exchangeObject, BatchContext<T1> batchContext, org.springframework.core.task.AsyncTaskExecutor executor, org.springframework.retry.support.RetryTemplate retryTemplate, BatchItemOperationType operationType)
CompletableFuture<Void>	AbstractBatchItemHandler.execute(T1 parent, ExchangeObject exchangeObject, BatchContext<T1> batchContext, org.springframework.core.task.AsyncTaskExecutor executor, org.springframework.retry.support.RetryTemplate retryTemplate, BatchItemOperationType operationType, Map<String,Object> additionalArgs)
CompletableFuture<Void>	AbstractBatchItemHandler.execute(T1 parent, ExchangeObject exchangeObject, BatchContext<T1> batchContext, org.springframework.core.task.AsyncTaskExecutor executor, org.springframework.retry.support.RetryTemplate retryTemplate, Map<String,Object> additionalArgs)
CompletableFuture<Void>	BatchItemHandler.execute(T1 parent, ExchangeObject exchangeObject, BatchContext<T1> batchContext, org.springframework.core.task.AsyncTaskExecutor executor, org.springframework.retry.support.RetryTemplate retryTemplate)	The entry point for the handler.
CompletableFuture<Void>	BatchItemHandler.execute(T1 parent, ExchangeObject exchangeObject, BatchContext<T1> batchContext, org.springframework.core.task.AsyncTaskExecutor executor, org.springframework.retry.support.RetryTemplate retryTemplate, BatchItemOperationType operationType)	The entry point for the handler.
CompletableFuture<Void>	BatchItemHandler.execute(T1 parent, ExchangeObject exchangeObject, BatchContext<T1> batchContext, org.springframework.core.task.AsyncTaskExecutor executor, org.springframework.retry.support.RetryTemplate retryTemplate, BatchItemOperationType operationType, Map<String,Object> additionalArgs)	The entry point for the handler.
CompletableFuture<Void>	BatchItemHandler.execute(T1 parent, ExchangeObject exchangeObject, BatchContext<T1> batchContext, org.springframework.core.task.AsyncTaskExecutor executor, org.springframework.retry.support.RetryTemplate retryTemplate, Map<String,Object> additionalArgs)	The entry point for the handler.
protected Function<Throwable,DataExchangeError>	AbstractDataExchangeService.getDataExchangeErrorSupplier(BatchContext<T> batchContext)	Returns a Function that maps a Throwable to a DataExchangeError.
default void	BatchExtensionProcessor.postProcess(BatchContext<?> batchContext)	This method will be executed to allow further processing prior to a response being composed and returned.
default void	BatchExtensionProcessor.preProcess(BatchContext<?> batchContext)	This method will be executed to allow customers to fetch, for example, data that is required for future processing.
protected <R, C extends ExchangeObject> Callable<R>	AbstractDataExchangeService.retryableCallable(C payload, BatchContext<T> batchContext, Callable<R> supplier)
protected <R, C extends ExchangeObject> Callable<R>	AbstractDataExchangeService.retryableCallable(List<C> payload, BatchContext<T> batchContext, Callable<R> supplier)
protected <C extends ExchangeObject> Runnable	AbstractDataExchangeService.retryableRunnable(C payload, BatchContext<T> batchContext, Callable<Void> supplier)
protected <C extends ExchangeObject> Runnable	AbstractDataExchangeService.retryableRunnable(List<C> payload, BatchContext<T> batchContext, Callable<Void> supplier)
protected <R, C extends ExchangeObject> Supplier<R>	AbstractDataExchangeService.retryableSupplier(C payload, BatchContext<T> batchContext, Callable<R> supplier)
protected <R, C extends ExchangeObject> Supplier<List<R>>	AbstractDataExchangeService.retryableSupplier(List<C> payload, BatchContext<T> batchContext, Callable<List<R>> supplier)
protected abstract void	AbstractDataExchangeService.saveAll(BatchContext<T> batchContext)	This is the entry point for subclasses to inject logic to handle the structure that has been passed in.
void	HandlerArgs.setBatchContext(BatchContext<T1> batchContext)	The batch context that the item is being saved in.
protected void	AbstractDataExchangeService.split(List<T> entities, BatchContext<T> batchContext)	This method "flattens" the object graph into a Map of exchange objects.

Constructors in com.broadleafcommerce.dataexchange.service with parameters of type BatchContext

Modifier	Constructor	Description
	HandlerArgs(T1 topLevelEntity, T2 beforeSaveItem, BatchContext<T1> batchContext, org.springframework.core.task.AsyncTaskExecutor executor, org.springframework.retry.support.RetryTemplate retryTemplate)
	HandlerArgs(T1 topLevelEntity, T2 beforeSaveItem, T2 savedItem, BatchContext<T1> batchContext, BatchItemOperationType operationType, org.springframework.core.task.AsyncTaskExecutor executor, org.springframework.retry.support.RetryTemplate retryTemplate)

Uses of BatchContext in com.broadleafcommerce.dataexchange.service.catalog

Methods in com.broadleafcommerce.dataexchange.service.catalog with parameters of type BatchContext

Modifier and Type	Method	Description
protected List<CompletableFuture<Void>>	DefaultComprehensiveProductExchangeService.createProductSaveCompletableFutures(BatchContext<T> batchContext)	Creates a list of CompletableFuture, one for each ComprehensiveProduct, such that each product can be saved individually in an asynchronous way.
protected void	DefaultComprehensiveProductExchangeService.fetchExistingProductData(BatchContext<T> batchContext)
protected void	DefaultComprehensiveProductExchangeService.fetchExistingProducts(List<T> originalProductList, BatchContext<T> batchContext)
protected void	DefaultComprehensiveProductExchangeService.fetchExistingVariants(BatchContext<T> batchContext)
protected @NotNull List<T>	DefaultComprehensiveProductExchangeService.getOriginalProductList(BatchContext<T> batchContext)
protected void	DefaultComprehensiveProductExchangeService.saveAll(BatchContext<T> batchContext)

Uses of BatchContext in com.broadleafcommerce.dataexchange.service.product

Methods in com.broadleafcommerce.dataexchange.service.product with parameters of type BatchContext

Modifier and Type	Method	Description
protected CompletableFuture<Void>	ProductBatchItemHandler.deleteVariantsFuture(HandlerArgs<T,T> args, BatchContext<T> tBatchContext)
protected org.apache.commons.lang3.tuple.Pair<Collection<String>,Collection<String>>	DefaultAdvancedTagPreloader.findTagNamesAndIds(BatchContext<?> batchContext)	Find tag names and ids for the given batch context.
protected List<Variant>	ProductBatchItemHandlerHelper.getExistingVariants(BatchContext<T> batchContext, T product)
void	DefaultAdvancedTagPreloader.preProcess(BatchContext<?> batchContext)
void	DefaultPriceDataPreloadProcessor.preProcess(BatchContext<?> batchContext)
protected T	ProductBatchItemHandler.resolveExistingProducts(T product, BatchContext<T> batchContext)
CompletableFuture<Void>	ProductBatchItemHandler.saveProduct(T product, BatchContext<T> batchContext, org.springframework.core.task.AsyncTaskExecutor executor, org.springframework.retry.support.RetryTemplate retryTemplate)
protected void	ProductTagBatchItemHandler.validateParent(BatchContext<ComprehensiveProduct> batchContext, T productTag)

Uses of BatchContext in com.broadleafcommerce.dataexchange.service.provider

Methods in com.broadleafcommerce.dataexchange.service.provider with parameters of type BatchContext

Modifier and Type	Method	Description
List<T>	PriceProvider.bulkReadPriceData(BatchContext<ComprehensiveProduct> batch)	Bulk read price data for products in a batch.
T	PriceProvider.createPriceData(T priceData, BatchContext<?> batch)
T1	CatalogProvider.createProduct(T1 product, BatchContext<?> batchContext)
T	ProductAssetProvider.createProductAsset(String productId, T asset, BatchContext<?> batchContext)
T2	AdvancedTagProvider.createProductTag(T2 productTag, BatchContext<?> batchContext)
T	InventoryProvider.createSkuInventory(T inventory, BatchContext<ComprehensiveProduct> batchContext)
T2	CatalogProvider.createVariant(T1 product, T2 variant, BatchContext<?> batchContext)
T2	AdvancedTagProvider.createVariantTag(T2 variantTag, BatchContext<?> batchContext)
void	PriceProvider.deletePriceData(String id, BatchContext<?> batch)
void	AdvancedTagProvider.deleteProductTag(String productId, String tagId, BatchContext<?> batchContext)
void	CatalogProvider.deleteVariant(String productId, String variantId, BatchContext<?> context)
void	AdvancedTagProvider.deleteVariantTag(String productId, String variantId, String id, BatchContext<?> batchContext)
List<T1>	AdvancedTagProvider.readAdvancedTags(Collection<String> names, Collection<String> ids, BatchContext<?> batchContext)
List<T>	ProductAssetProvider.readProductAssets(String productId, BatchContext<?> batchContext)	Fetch any assets associated with the supplied product id.
T1	CatalogProvider.readProductById(String productId, BatchContext<?> batchContext)
ProductList<T1>	CatalogProvider.readProducts(List<T1> requestedProducts, BatchContext<?> batchContext)	Fetches a list of Products based on externalId, SKU, or URI.
ProductList<T1>	CatalogProvider.readProducts(org.springframework.util.MultiValueMap<String,String> params, BatchContext<?> context)
List<T2>	AdvancedTagProvider.readProductTags(String productId, BatchContext<?> batchContext)
List<T>	InventoryProvider.readSkuInventory(String locationId, SkuRef skuRef, BatchContext<ComprehensiveProduct> batchContext)
T2	CatalogProvider.readVariant(String productId, String variantId, BatchContext<?> context)
T2	CatalogProvider.readVariantById(String productId, String variantId, BatchContext<?> batchContext)
List<T2>	CatalogProvider.readVariants(List<T1> products, BatchContext<?> batchContext)
List<T2>	CatalogProvider.readVariantsForProduct(T1 products, BatchContext<?> batchContext)
List<T2>	AdvancedTagProvider.readVariantTags(String productId, String variantId, BatchContext<?> batchContext)
List<Translation>	CatalogProvider.saveProductTranslations(T1 product, Locale locale, List<Translation> translations, BatchContext<?> batchContext)	Saves translations, specifically for a Product.
List<Translation>	ProductAssetProvider.saveTranslations(String productId, String assetId, Locale locale, List<Translation> translations, BatchContext<?> batchContext)
List<Translation>	CatalogProvider.saveVariantTranslations(T1 product, T2 variant, Locale locale, List<Translation> translations, BatchContext<?> batchContext)
T	PriceProvider.updatePriceData(T priceData, BatchContext<?> batch)
T1	CatalogProvider.updateProduct(T1 product, BatchContext<?> batchContext)
T	ProductAssetProvider.updateProductAsset(String productId, T asset, BatchContext<?> batchContext)
T2	AdvancedTagProvider.updateProductTag(T2 productTag, BatchContext<?> batchContext)
T	InventoryProvider.updateSkuInventory(T inventory, BatchContext<ComprehensiveProduct> batchContext)
T2	CatalogProvider.updateVariant(T1 product, T2 variant, BatchContext<?> batchContext)
T2	AdvancedTagProvider.updateVariantTag(T2 variantTag, BatchContext<?> batchContext)

Uses of BatchContext in com.broadleafcommerce.dataexchange.service.provider.external

Methods in com.broadleafcommerce.dataexchange.service.provider.external with parameters of type BatchContext

Modifier and Type	Method	Description
protected cz.jirutka.rsql.parser.ast.Node	ExternalPriceProvider.buildBulkReadCriteria(BatchContext<ComprehensiveProduct> batch)
List<T>	ExternalPriceProvider.bulkReadPriceData(BatchContext<ComprehensiveProduct> batch)
protected Optional<String>	ExternalCatalogProvider.createExistingProductRsqlQuery(List<T1> products, BatchContext<?> batchContext)	When we want to query for existing products, we normally do so by querying by contextId, externalId, or sku.
T	ExternalPriceProvider.createPriceData(T priceData, BatchContext<?> batch)
T1	ExternalCatalogProvider.createProduct(T1 product, BatchContext<?> batchContext)
T	ExternalProductAssetProvider.createProductAsset(String productId, T asset, BatchContext<?> batchContext)
T2	ExternalAdvancedTagProvider.createProductTag(T2 productTag, BatchContext<?> batchContext)
T	ExternalInventoryProvider.createSkuInventory(T inventory, BatchContext<ComprehensiveProduct> batchContext)
T2	ExternalCatalogProvider.createVariant(T1 product, T2 variant, BatchContext<?> batchContext)
T2	ExternalAdvancedTagProvider.createVariantTag(T2 productTag, BatchContext<?> batchContext)
void	ExternalPriceProvider.deletePriceData(String id, BatchContext<?> batch)
void	ExternalAdvancedTagProvider.deleteProductTag(String productId, String id, BatchContext<?> batchContext)
protected org.springframework.web.reactive.function.client.WebClient.RequestHeadersSpec<?>	AbstractRestApiExternalProvider.deleteRequest(String uri, BatchContext<?> batchContext)
void	ExternalCatalogProvider.deleteVariant(String productId, String variantId, BatchContext<?> context)
void	ExternalAdvancedTagProvider.deleteVariantTag(String productId, String variantId, String id, BatchContext<?> batchContext)
protected org.springframework.web.reactive.function.client.WebClient.RequestHeadersSpec<?>	AbstractRestApiExternalProvider.getRequest(String uri, BatchContext<?> batchContext)
protected org.springframework.web.reactive.function.client.WebClient.RequestBodySpec	AbstractRestApiExternalProvider.patchRequest(String uri, BatchContext<?> batchContext)
protected org.springframework.web.reactive.function.client.WebClient.RequestBodySpec	AbstractRestApiExternalProvider.postRequest(String uri, BatchContext<?> batchContext)
protected org.springframework.web.reactive.function.client.WebClient.RequestBodySpec	AbstractRestApiExternalProvider.putRequest(String uri, BatchContext<?> batchContext)
List<T1>	ExternalAdvancedTagProvider.readAdvancedTags(Collection<String> names, Collection<String> ids, BatchContext<?> batchContext)
List<T>	ExternalProductAssetProvider.readProductAssets(String productId, BatchContext<?> batchContext)
T1	ExternalCatalogProvider.readProductById(String productId, BatchContext<?> batchContext)
ProductList<T1>	ExternalCatalogProvider.readProducts(List<T1> requestedProducts, BatchContext<?> batchContext)
ProductList<T1>	ExternalCatalogProvider.readProducts(org.springframework.util.MultiValueMap<String,String> params, BatchContext<?> batchContext)
List<T2>	ExternalAdvancedTagProvider.readProductTags(String productId, BatchContext<?> batchContext)
List<T>	ExternalInventoryProvider.readSkuInventory(String locationId, SkuRef skuRef, BatchContext<ComprehensiveProduct> batchContext)
T2	ExternalCatalogProvider.readVariant(String productId, String variantId, BatchContext<?> context)
T2	ExternalCatalogProvider.readVariantById(String productId, String variantId, BatchContext<?> batchContext)
List<T2>	ExternalCatalogProvider.readVariants(List<T1> products, BatchContext<?> batchContext)
List<T2>	ExternalCatalogProvider.readVariantsForProduct(T1 product, BatchContext<?> batchContext)
List<T2>	ExternalAdvancedTagProvider.readVariantTags(String productId, String variantId, BatchContext<?> batchContext)
List<Translation>	ExternalCatalogProvider.saveProductTranslations(T1 product, Locale locale, List<Translation> translations, BatchContext<?> batchContext)
List<Translation>	ExternalProductAssetProvider.saveTranslations(String productId, String assetId, Locale locale, List<Translation> translations, BatchContext<?> batchContext)
List<Translation>	ExternalCatalogProvider.saveVariantTranslations(T1 product, T2 variant, Locale locale, List<Translation> translations, BatchContext<?> batchContext)
T	ExternalPriceProvider.updatePriceData(T priceData, BatchContext<?> batch)
T1	ExternalCatalogProvider.updateProduct(T1 product, BatchContext<?> batchContext)
T	ExternalProductAssetProvider.updateProductAsset(String productId, T asset, BatchContext<?> batchContext)
T2	ExternalAdvancedTagProvider.updateProductTag(T2 productTag, BatchContext<?> batchContext)
T	ExternalInventoryProvider.updateSkuInventory(T inventory, BatchContext<ComprehensiveProduct> batchContext)
T2	ExternalCatalogProvider.updateVariant(T1 product, T2 variant, BatchContext<?> batchContext)
T2	ExternalAdvancedTagProvider.updateVariantTag(T2 productTag, BatchContext<?> batchContext)