org.openadaptor.adaptor.jdbc.sybase
Class MultiDoSybaseSource

java.lang.Object
  org.openadaptor.adaptor.SimpleComponent
      org.openadaptor.adaptor.AbstractReader
          org.openadaptor.adaptor.AbstractSimpleSource
              org.openadaptor.adaptor.jdbc.JdbcSource
                  org.openadaptor.adaptor.jdbc.sybase.SybaseSource
                      org.openadaptor.adaptor.jdbc.sybase.MultiDoSybaseSource

All Implemented Interfaces:

java.lang.Runnable, CallbackProvider, Component, Configurable, IbafTransactionalResource, Source, DOMessageReaderDelegate

public class MultiDoSybaseSource
extends SybaseSource

Nested Class Summary

Nested classes/interfaces inherited from class org.openadaptor.adaptor.AbstractSimpleSource

AbstractSimpleSource.SourceListenThread

Nested classes/interfaces inherited from class org.openadaptor.adaptor.SimpleComponent

SimpleComponent.StateHolder

Field Summary

(package private) static org.apache.log4j.Logger

log

Fields inherited from class org.openadaptor.adaptor.jdbc.JdbcSource

_batchSize, _bcgProcNamePrefix, _dbConnection, _deadlockIsFatal, _deadlockRetryDelay, _jdbcDriver, _jdbcTypeMap, _jdbcUrl, _maxDeadlockRetry, _maxNumberOfFailures, _msgServiceId, _msgServiceName, _passingProcParamNames, _password, _sqlQueryTimeout, _sqlQueryTimeoutSet, _transactionIsolationLevel, _userName, _usingSelect, DEFAULT_DOTYPE_MAP, failedEvents, sentEvents

Fields inherited from class org.openadaptor.adaptor.AbstractSimpleSource

_last_processed_time, _max_calls_per_poll, _num_polls, _num_processed, _source_type, CALLBACK_SOURCE, LISTEN_SOURCE, POLL_SOURCE

Fields inherited from class org.openadaptor.adaptor.AbstractReader

_batch_size, _comment_regexps, _end_data, _file_name, _file_name_att, _header_lines, _re_compiler, _re_matcher, _reader, _rec_num, _rec_num_att, _record_regexps, _start_data, _stream_reader, _string_reader, _useAlternateDOXMLReader

Fields inherited from class org.openadaptor.adaptor.SimpleComponent

_controller, _formatter, _name, _propsPrefix, _readerDelegate, _textEncoding, MESSAGE_WRITER_PREFIX, MESSAGEID_ATTR, TEXT_ENCODING_ATTR

Constructor Summary

MultiDoSybaseSource()

Method Summary

protected JdbcSourceEventMessage

getNextQueuedMsgStatement(int msgServiceId) Executes the getNextQueuedMsg procedure.

Methods inherited from class org.openadaptor.adaptor.jdbc.sybase.SybaseSource

constructSqlFromEvent, dbInit, dealWithReturnValue, getProcResultSet, init, isDeadlock, registerReturnValue, retrieveMsgServiceId, setEventMessageStatus

Methods inherited from class org.openadaptor.adaptor.jdbc.JdbcSource

getBcgProcNamePrefix, getDeadlockIsFatal, getDeadlockRetryDelay, getJdbcConnection, getJdbcDriver, getJdbcUrl, getMaxDeadlockRetry, getMaxNumberOfFailures, getMsgServiceName, getNextEvent, getPassword, getSqlQueryTimeout, getTransactionIsolationLevel, getUserName, isPassingProcParamNames, isUsingSelect, jdbcTxnBegin, jdbcTxnCommit, jdbcTxnRollback, setBatchSize, setBcgProcNamePrefix, setDeadlockIsFatal, setDeadlockRetryDelay, setJdbcConnection, setJdbcDriver, setJDBCTypeMap, setJdbcUrl, setMaxDeadlockRetry, setMaxNumberOfFailures, setMsgServiceName, setPassingProcParamNames, setPassword, setSqlQueryTimeout, setTransactionIsolationLevel, setUserName, setUsingSelect, sourceCleanUp, sourcePoll, sourceStartUp, txnBegin, txnCommit, txnRollback

Methods inherited from class org.openadaptor.adaptor.AbstractSimpleSource

getPollPeriod, getSourceType, getStatus, processMessage, processMessage, processMessageWithTxn, run, runCallback, runListen, runPoll, setMaxCallsPerPoll, setPollPeriod, setSourceType, sourceHasTransactionRecovery, sourceListen, sourcePause, sourceProcess, sourceProcess, sourceProcess, sourceResume, sourceStop, sourceTransactionBegin, sourceTransactionProcess

Methods inherited from class org.openadaptor.adaptor.AbstractReader

getDOStreamReader, getDOStringReader, getLineNumberReader, getReader, getXMLString, isReaderEOF, isWhitespace, nextDataObjectArray, readDOStreamReader, readDOStringReader, readDOXML, readDOXMLAlternate, readerCleanUp, readerEOF, readerException, readerStartUp, setDOStringReader, setHeaderLines, setReader

Methods inherited from class org.openadaptor.adaptor.SimpleComponent

addCallback, canUpdateWhileRunning, cleanUp, customControl, didReceiveMessage, getAsProperties, getCallbackManager, getCurrentState, getCustomControlProperties, getLastUID, getName, getProperty, getProperty, getPropsPrefix, getRequestedState, getSecurityManager, getTextEncoding, getXMLFormatter, notifyEvent, pause, removeCallback, resume, setCallbackManager, setCallbackManager, setCurrentState, setFromProperties, setFromProperties, setFromResource, setName, setPropsPrefix, setRequestedState, terminate, txnCommitWithExceptions, txnRollback, waitForRequestedStateChange

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openadaptor.adaptor.Component

cleanUp, customControl, getName, getPropsPrefix, getRequestedState, pause, resume, setName, setPropsPrefix, terminate

Methods inherited from interface org.openadaptor.adaptor.IbafTransactionalResource

txnCommitWithExceptions, txnRollback

Methods inherited from interface org.openadaptor.adaptor.Configurable

canUpdateWhileRunning, getAsProperties, setFromProperties, setFromProperties

Methods inherited from interface org.openadaptor.adaptor.CallbackProvider

addCallback, getCallbackManager, notifyEvent, removeCallback, setCallbackManager, setCallbackManager

Field Detail

log

static org.apache.log4j.Logger log

Constructor Detail

MultiDoSybaseSource

public MultiDoSybaseSource()

Method Detail

getNextQueuedMsgStatement

protected JdbcSourceEventMessage getNextQueuedMsgStatement(int msgServiceId)
                                                    throws java.sql.SQLException,
                                                           DeadlockException

Description copied from class: SybaseSource

Executes the getNextQueuedMsg procedure. Calls BCG_GetNextMsgInFull and constructs a JdbcSourceEventMessage from the first set of results a DataObject[] from the second set of results

Overrides:

getNextQueuedMsgStatement in class SybaseSource

Throws:

java.sql.SQLException - if something goes wrong.

DeadlockException