public class DynamicBulkUpdateMessageProcessor extends AbstractBulkUpdateMessageProcessor
MuleEvent
being processed.autoGeneratedKeyStrategy, bulkUpdateExecutorFactory, queryResolver, source, validQueryTypes
dbConfigResolver
logger, muleContext, next, notificationHandler
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
DynamicBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver,
QueryResolver queryResolver,
BulkQueryExecutorFactory bulkUpdateExecutorFactory,
TransactionalAction transactionalAction,
List<QueryType> validQueryTypes) |
Modifier and Type | Method and Description |
---|---|
protected Object |
executeQuery(DbConnection connection,
MuleEvent muleEvent) |
getIterator, getSource, getValidQueryTypes, setAutoGeneratedKeyStrategy, setSource
getInputMetaData, getOutputMetaData, getQueryMetadataProvider, getTarget, initialise, mustCloseConnection, process, resolveSource, setQueryMetadataProvider, setTarget, validateQueryType
addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener, setMuleContext, toString
getAnnotation, getAnnotations, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setListener
public DynamicBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver, QueryResolver queryResolver, BulkQueryExecutorFactory bulkUpdateExecutorFactory, TransactionalAction transactionalAction, List<QueryType> validQueryTypes)
protected Object executeQuery(DbConnection connection, MuleEvent muleEvent) throws SQLException
executeQuery
in class AbstractDbMessageProcessor
SQLException
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.