Package com.adaptris.core.services.jdbc

Class JdbcIteratingDataCaptureServiceImpl

java.lang.Object
com.adaptris.core.ServiceImp
com.adaptris.core.jdbc.JdbcService
com.adaptris.core.services.jdbc.JdbcServiceWithParameters
com.adaptris.core.services.jdbc.JdbcDataCaptureServiceImpl
com.adaptris.core.services.jdbc.JdbcIteratingDataCaptureServiceImpl
All Implemented Interfaces:
AdaptrisComponent, ComponentLifecycle, ComponentLifecycleExtension, ConfigComment, ConnectedService, MessageEventGenerator, Service, StateManagedComponent
Direct Known Subclasses:
JdbcBatchingDataCaptureService, JdbcDataCaptureService
public abstract class JdbcIteratingDataCaptureServiceImpl extends JdbcDataCaptureServiceImpl

  • Constructor Details

    • JdbcIteratingDataCaptureServiceImpl

      public JdbcIteratingDataCaptureServiceImpl()

  • Method Details

    • initJdbcService

      protected void initJdbcService() throws CoreException
      Overrides:
      initJdbcService in class JdbcDataCaptureServiceImpl
      Throws:
      CoreException

    • doService

      public void doService(AdaptrisMessage msg) throws ServiceException
      Description copied from interface: Service

      Apply the service to the message.

      Parameters:
      msg - the AdaptrisMessage to process
      Throws:
      ServiceException - wrapping any underlying Exceptions

    • executeUpdate

      protected abstract long executeUpdate(PreparedStatement insert) throws SQLException
      Throws:
      SQLException

    • finishUpdate

      protected abstract long finishUpdate(PreparedStatement insert) throws SQLException
      Throws:
      SQLException

    • getNamespaceContext

      public KeyValuePairSet getNamespaceContext()
      Returns:
      the namespaceContext

    • setNamespaceContext

      public void setNamespaceContext(KeyValuePairSet kvps)
      Set the namespace context for resolving namespaces.
      • The key is the namespace prefix
      • The value is the namespace uri
      Parameters:
      kvps - the namespace context
      See Also:

    • getXmlDocumentFactoryConfig

      public DocumentBuilderFactoryBuilder getXmlDocumentFactoryConfig()

    • setXmlDocumentFactoryConfig

      public void setXmlDocumentFactoryConfig(DocumentBuilderFactoryBuilder xml)

    • setIterationXpath

      public void setIterationXpath(String xpath)

      An Xpath that can be iterated on.

      An Iteration Xpath defines some repeating element or value in the payload.

      Parameters:
      xpath - the xpath
      See Also:

    • getIterationXpath

      public String getIterationXpath()
      Get the configured iteration xpath.
      Returns:
      the xpath.

    • setIterates

      public void setIterates(Boolean iterates)

      Set the service to iterate on the given xpath.

      If set to true, then it is expected that there is a configured iteration xpath available for use. If this is not the case, then results are undefined, and depends on the underlying Xpath implementation

      Parameters:
      iterates - the flag.
      See Also:

    • getIterates

      public Boolean getIterates()
      Get the configured iteration flag.
      Returns:
      the flag.