org.mule.providers.jdbc
Class JdbcConnector
java.lang.Object
org.mule.providers.AbstractConnector
org.mule.providers.AbstractServiceEnabledConnector
org.mule.providers.jdbc.JdbcConnector
- All Implemented Interfaces:
- Disposable, java.beans.ExceptionListener, Initialisable, Startable, Stoppable, UMOConnector
- public class JdbcConnector
- extends AbstractServiceEnabledConnector
- Version:
- $Revision: 1.4 $
- Author:
- Guillaume Nodet
Fields inherited from class org.mule.providers.AbstractConnector |
DEFAULT_RETRY_COUNT, DEFAULT_RETRY_FREQUENCY, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, exceptionListener, initialised, logger, name, receivers, started |
Methods inherited from class org.mule.providers.AbstractConnector |
checkDisposed, createDispatcher, destroyReceiver, dispose, disposeConnector, exceptionThrown, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcher, getDispatcherFactory, getDispatchers, getDispatcherThreadingProfile, getExceptionListener, getName, getReceiverKey, getReceiverThreadingProfile, getReplyToHandler, getRetryCount, getRetryFrequency, handleException, initialise, isDisposed, isDisposeDispatcherOnCompletion, isStarted, registerListener, setDefaultInboundTransformer, setDefaultOutboundTransformer, setDefaultResponseTransformer, setDispatcherFactory, setDispatcherThreadingProfile, setDisposeDispatcherOnCompletion, setExceptionListener, setName, setReceiverThreadingProfile, setRetryCount, setRetryFrequency, start, startConnector, stop, stopConnector, unregisterListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JdbcConnector
public JdbcConnector()
getProtocol
public java.lang.String getProtocol()
- Specified by:
getProtocol
in interface UMOConnector
- Specified by:
getProtocol
in class AbstractConnector
createReceiver
public UMOMessageReceiver createReceiver(UMOComponent component,
UMOEndpoint endpoint)
throws java.lang.Exception
- Overrides:
createReceiver
in class AbstractServiceEnabledConnector
- Throws:
java.lang.Exception
initJndiContext
protected void initJndiContext()
throws javax.naming.NamingException
- Throws:
javax.naming.NamingException
createDataSource
protected void createDataSource()
throws InitialisationException,
javax.naming.NamingException
- Throws:
InitialisationException
javax.naming.NamingException
doInitialise
public void doInitialise()
throws InitialisationException
- Overrides:
doInitialise
in class AbstractServiceEnabledConnector
- Throws:
InitialisationException
getReadAndAckStatements
public java.lang.String[] getReadAndAckStatements(UMOEndpointURI endpointUri,
UMOEndpoint endpoint)
getQuery
public java.lang.String getQuery(UMOEndpoint endpoint,
java.lang.String stmt)
getDataSource
public javax.sql.DataSource getDataSource()
- Returns:
- Returns the dataSource.
setDataSource
public void setDataSource(javax.sql.DataSource dataSource)
- Parameters:
dataSource
- The dataSource to set.
getPollingFrequency
public long getPollingFrequency()
- Returns:
- Returns the pollingFrequency.
setPollingFrequency
public void setPollingFrequency(long pollingFrequency)
- Parameters:
pollingFrequency
- The pollingFrequency to set.
getQueries
public java.util.Map getQueries()
- Returns:
- Returns the queries.
setQueries
public void setQueries(java.util.Map queries)
- Parameters:
queries
- The queries to set.
getDataSourceJndiName
public java.lang.String getDataSourceJndiName()
- Returns:
- Returns the dataSourceJndiName.
setDataSourceJndiName
public void setDataSourceJndiName(java.lang.String dataSourceJndiName)
- Parameters:
dataSourceJndiName
- The dataSourceJndiName to set.
getJndiContext
public javax.naming.Context getJndiContext()
- Returns:
- Returns the jndiContext.
setJndiContext
public void setJndiContext(javax.naming.Context jndiContext)
- Parameters:
jndiContext
- The jndiContext to set.
getJndiInitialFactory
public java.lang.String getJndiInitialFactory()
- Returns:
- Returns the jndiInitialFactory.
setJndiInitialFactory
public void setJndiInitialFactory(java.lang.String jndiInitialFactory)
- Parameters:
jndiInitialFactory
- The jndiInitialFactory to set.
getJndiProviderUrl
public java.lang.String getJndiProviderUrl()
- Returns:
- Returns the jndiProviderUrl.
setJndiProviderUrl
public void setJndiProviderUrl(java.lang.String jndiProviderUrl)
- Parameters:
jndiProviderUrl
- The jndiProviderUrl to set.
getProviderProperties
public java.util.Map getProviderProperties()
- Returns:
- Returns the providerProperties.
setProviderProperties
public void setProviderProperties(java.util.Map providerProperties)
- Parameters:
providerProperties
- The providerProperties to set.
getSessionFactory
public java.lang.Object getSessionFactory(UMOEndpoint endpoint)
throws java.lang.Exception
- Throws:
java.lang.Exception
getConnection
public java.sql.Connection getConnection()
throws java.lang.Exception
- Throws:
java.lang.Exception
Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.