com.mulesoft.mule.runtime.module.batch.internal.engine.queue

Class BatchQueueLoader

java.lang.Object

com.mulesoft.mule.runtime.module.batch.internal.engine.queue.BatchQueueLoader

public class BatchQueueLoader
extends Object

This components loads the contents of a CoreEvent into a batch stepping queue.

Since:

3.5.0

Constructor Summary

Constructors

Constructor and Description
BatchQueueLoader(BatchEngine batchEngine, int blockSize, org.mule.runtime.core.internal.routing.SplittingStrategy<org.mule.runtime.core.api.event.CoreEvent,org.mule.runtime.core.internal.routing.MessageSequence<?>> splittingStrategy, org.mule.runtime.api.notification.NotificationDispatcher notificationDispatcher)

Method Summary

Modifier and Type	Method and Description
long	splitAndLoad(BatchJob job, BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.event.CoreEvent event)

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchQueueLoader

public BatchQueueLoader(BatchEngine batchEngine,
                        int blockSize,
                        org.mule.runtime.core.internal.routing.SplittingStrategy<org.mule.runtime.core.api.event.CoreEvent,org.mule.runtime.core.internal.routing.MessageSequence<?>> splittingStrategy,
                        org.mule.runtime.api.notification.NotificationDispatcher notificationDispatcher)

Method Detail

splitAndLoad

public long splitAndLoad(BatchJob job,
                         BatchJobInstanceAdapter jobInstance,
                         org.mule.runtime.core.api.event.CoreEvent event)
                  throws org.mule.runtime.api.exception.MuleException

Throws:

org.mule.runtime.api.exception.MuleException