org.jboss.soa.esb.actions
Class AbstractSqlRowAction

java.lang.Object
  org.jboss.soa.esb.actions.AbstractSqlRowAction

All Implemented Interfaces:

ActionProcessor

Direct Known Subclasses:

MockSqlRowAction

public abstract class AbstractSqlRowAction
extends java.lang.Object
implements ActionProcessor

Abstract SQL Row action.

Convienience class for processing messages from the org.jboss.soa.esb.listeners.old.SqlTablePoller listener. Implementing classes receive a single row resultset through their implementation of the process(Map) method.

Since:

Version 4.0

Author:

tom.fennelly@jboss.com

Field Summary

protected org.apache.log4j.Logger

logger

Constructor Summary

protected

AbstractSqlRowAction(java.lang.String actionName, java.util.List<KeyValuePair> properties)

Method Summary

protected abstract java.lang.Object	process(java.util.Map resultSet) Process the SQL poll resultset.
Message	process(Message message) Perform the processing action on the message

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jboss.soa.esb.actions.ActionProcessor

getErrorNotification, getOkNotification

Field Detail

logger

protected org.apache.log4j.Logger logger

Constructor Detail

AbstractSqlRowAction

protected AbstractSqlRowAction(java.lang.String actionName,
                               java.util.List<KeyValuePair> properties)
                        throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

process

public final Message process(Message message)
                      throws ActionProcessingException

Description copied from interface: ActionProcessor

Perform the processing action on the message

Specified by:

process in interface ActionProcessor

Parameters:

message - The message to be processed.

Returns:

Message - result of process

Throws:

ActionProcessingException - Exception during payload processing.

process

protected abstract java.lang.Object process(java.util.Map resultSet)
                                     throws ActionProcessingException

Process the SQL poll resultset.

Parameters:

resultSet - SQL Poller resultset.

Returns:

Processing result.

Throws:

ActionProcessingException