public class BulkExecuteMessageProcessor extends AbstractDbMessageProcessor
MuleEvent
being processed.dbConfigResolver
logger, muleContext, next, notificationHandler
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
BulkExecuteMessageProcessor(DbConfigResolver dbConfigResolver,
BulkQueryResolver bulkQueryResolver,
BulkQueryExecutorFactory bulkUpdateExecutorFactory,
TransactionalAction transactionalAction) |
Modifier and Type | Method and Description |
---|---|
protected Object |
executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected List<QueryType> |
getValidQueryTypes() |
getInputMetaData, getOutputMetaData, getQueryMetadataProvider, getSource, getTarget, initialise, mustCloseConnection, process, resolveSource, setQueryMetadataProvider, setSource, 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 BulkExecuteMessageProcessor(DbConfigResolver dbConfigResolver, BulkQueryResolver bulkQueryResolver, BulkQueryExecutorFactory bulkUpdateExecutorFactory, TransactionalAction transactionalAction)
protected Object executeQuery(DbConnection connection, MuleEvent muleEvent) throws SQLException
executeQuery
in class AbstractDbMessageProcessor
SQLException
protected List<QueryType> getValidQueryTypes()
getValidQueryTypes
in class AbstractDbMessageProcessor
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.