com.mulesoft.mule.runtime.module.batch.util

Class BatchUtils

java.lang.Object

com.mulesoft.mule.runtime.module.batch.util.BatchUtils

public abstract class BatchUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
BatchUtils()

Method Summary

Modifier and Type	Method and Description
static String	buildExceptionLogMessage(com.mulesoft.mule.runtime.module.batch.api.BatchJobInstance jobInstance, BatchStep step, Exception exception)
static void	commit(BatchTransactionContext ctx)
static void	completeWorkOnBlock(List<Record> block, boolean shouldRollback, BatchProcessingListener listener, BatchTransactionContext ctx) Perform the completion callback for each record in the block as well as any further completion operation needed related to the transaction context.
static Record	getRecord(org.mule.runtime.api.el.BindingContext bindingContext)
static Record	getRecord(org.mule.runtime.core.api.event.CoreEvent event)
static void	rollback(BatchTransactionContext ctx)
static void	singleAckAndCommitIfNecessary(BatchTransactionContext ctx)
static BatchException	toBatchException(Exception e, BatchJobInstanceAdapter jobInstance)
static Record	toRecord(org.mule.runtime.core.api.event.CoreEvent event, Object object)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BatchUtils

public BatchUtils()

Method Detail

getRecord

public static Record getRecord(org.mule.runtime.core.api.event.CoreEvent event)

getRecord

public static Record getRecord(org.mule.runtime.api.el.BindingContext bindingContext)

toBatchException

public static BatchException toBatchException(Exception e,
                                              BatchJobInstanceAdapter jobInstance)

toRecord

public static Record toRecord(org.mule.runtime.core.api.event.CoreEvent event,
                              Object object)

buildExceptionLogMessage

public static String buildExceptionLogMessage(com.mulesoft.mule.runtime.module.batch.api.BatchJobInstance jobInstance,
                                              BatchStep step,
                                              Exception exception)

commit

public static void commit(BatchTransactionContext ctx)

singleAckAndCommitIfNecessary

public static void singleAckAndCommitIfNecessary(BatchTransactionContext ctx)

rollback

public static void rollback(BatchTransactionContext ctx)

completeWorkOnBlock

public static void completeWorkOnBlock(List<Record> block,
                                       boolean shouldRollback,
                                       BatchProcessingListener listener,
                                       BatchTransactionContext ctx)

Perform the completion callback for each record in the block as well as any further completion operation needed related to the transaction context.

Parameters:

block - the block of records

shouldRollback - in case the context should be rollback

listener - processing batch listener

ctx - the transactional context