|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.mule.providers.AbstractConnector
org.mule.providers.AbstractServiceEnabledConnector
org.mule.providers.jms.JmsConnector
org.mule.providers.oracle.jms.AbstractOracleJmsConnector
| Field Summary | |
protected String |
payloadFactory
|
static String |
PAYLOADFACTORY_PROPERTY
If a queue's payload is an ADT (Oracle Advanced Data Type), the appropriate payload factory must be specified in the endpoint's properties. |
| Fields inherited from class org.mule.providers.jms.JmsConnector |
password, username |
| Fields inherited from class org.mule.providers.AbstractServiceEnabledConnector |
serviceDescriptor, serviceOverrides |
| Fields inherited from class org.mule.providers.AbstractConnector |
connected, connecting, createDispatcherPerRequest, createMultipleTransactedReceivers, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, name, receivers, serverSide, sessionHandler, started, startOnConnect |
| Fields inherited from interface org.mule.umo.provider.UMOConnector |
INT_VALUE_NOT_SET |
| Constructor Summary | |
AbstractOracleJmsConnector()
|
|
| Method Summary | |
void |
close(Session session)
Attempts to close the underlying JDBC connection before closing the JMS session. |
protected ConnectionFactory |
createConnectionFactory()
Oracle has two different factory classes: which implements and which implements so there is no single class to return in this method. |
void |
doConnect()
Template method where any connections should be made for the connector |
abstract Connection |
getJdbcConnection()
|
String |
getPayloadFactory()
|
String |
getProtocol()
The Oracle AQ connector supports both the oaq:// and the jms:// protocols. |
Session |
getSession(boolean transacted,
boolean topic)
Some versions of Oracle do not support more than one JMS session per connection. |
boolean |
isMultipleSessionsPerConnection()
|
javax.jms.Message |
preProcessMessage(javax.jms.Message message,
Session session)
If the incoming message is an XMLType, return it as a standard . |
void |
setMultipleSessionsPerConnection(boolean multipleSessionsPerConnection)
|
void |
setPayloadFactory(String payloadFactory)
|
boolean |
supportsProperty(String property)
Oracle throws a "JMS-102: Feature not supported" error if any of these "standard" properties are used. |
boolean |
supportsProtocol(String protocol)
The Oracle AQ connector supports both the oaq:// and the jms:// protocols. |
| Methods inherited from class org.mule.providers.AbstractServiceEnabledConnector |
createReceiver, getServiceDescriptor, getServiceOverrides, getStreamMessageAdapter, initFromServiceDescriptor, initialiseFromUrl, setServiceOverrides |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
public static final String PAYLOADFACTORY_PROPERTY
protected String payloadFactory
| Constructor Detail |
public AbstractOracleJmsConnector()
| Method Detail |
public String getProtocol()
getProtocol in interface UMOConnectorgetProtocol in class JmsConnectorpublic boolean supportsProtocol(String protocol)
supportsProtocol in interface UMOConnectorsupportsProtocol in class AbstractConnector
public void doConnect()
throws ConnectException
AbstractConnector
doConnect in class JmsConnectorConnectException
public Session getSession(boolean transacted,
boolean topic)
throws JMSException
getSession in class JmsConnectorJMSException#multipleSessionsPerConnectionpublic boolean supportsProperty(String property)
supportsProperty in class JmsConnector
public javax.jms.Message preProcessMessage(javax.jms.Message message,
Session session)
throws Exception
preProcessMessage in class JmsConnectormessage - - the incoming messagesession - - the JMS session
Exception
public void close(Session session)
throws JMSException
close in class JmsConnectorsession -
JMSExceptionorg.mule.providers.jms.JmsConnector.close( javax.jms.Session)
public abstract Connection getJdbcConnection()
throws JMSException
JMSExceptionpublic boolean isMultipleSessionsPerConnection()
public void setMultipleSessionsPerConnection(boolean multipleSessionsPerConnection)
protected ConnectionFactory createConnectionFactory()
throws InitialisationException,
NamingException
createConnectionFactory in class JmsConnectorInitialisationException
NamingExceptionpublic String getPayloadFactory()
public void setPayloadFactory(String payloadFactory)
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||