|
|||||||||||
| 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
JmsConnector is a JMS 1.0.2b compliant connector that can be used
by a Mule endpoint. The connector supports all JMS functionality including topics
and queues, durable subscribers, acknowledgement modes and local transactions.
| Field Summary | |
String |
password
|
String |
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 | |
JmsConnector()
|
|
| Method Summary | |
void |
close(MessageProducer producer)
Closes the MessageProducer |
void |
closeQuietly(MessageProducer producer)
Closes the MessageProducer without throwing an exception (an error message is logged instead). |
protected Connection |
createConnection()
|
protected ConnectionFactory |
createConnectionFactory()
|
protected RedeliveryHandler |
createRedeliveryHandler()
|
void |
doConnect()
Template method where any connections should be made for the connector |
void |
doDisconnect()
Template method where any connected resources used by the connector should be disconnected |
protected void |
doDispose()
Template method to perform any work when destroying the connectoe |
void |
doInitialise()
|
void |
doStart()
Template method to perform any work when starting the connectoe |
int |
getAcknowledgementMode()
|
String |
getClientId()
|
Connection |
getConnection()
|
ConnectionFactory |
getConnectionFactory()
|
String |
getConnectionFactoryClass()
|
String |
getConnectionFactoryJndiName()
|
Map |
getConnectionFactoryProperties()
|
JmsSupport |
getJmsSupport()
|
Context |
getJndiContext()
|
String |
getJndiInitialFactory()
|
Map |
getJndiProviderProperties()
|
String |
getJndiProviderUrl()
|
int |
getMaxRedelivery()
|
UMOMessageAdapter |
getMessageAdapter(Object message)
Gets a UMOMessageAdapter for the endpoint for the given message
(data) |
String |
getPassword()
|
String |
getProtocol()
|
protected Object |
getReceiverKey(UMOComponent component,
UMOEndpoint endpoint)
The method determines the key used to store the receiver against. |
String |
getRedeliveryHandler()
|
ReplyToHandler |
getReplyToHandler()
|
Session |
getSession(boolean transacted,
boolean topic)
|
Session |
getSession(UMOImmutableEndpoint endpoint)
|
Object |
getSessionFactory(UMOEndpoint endpoint)
|
Session |
getSessionFromTransaction()
|
String |
getSpecification()
|
String |
getUsername()
|
protected void |
initJndiContext()
|
boolean |
isCacheJmsSessions()
|
boolean |
isDurable()
|
boolean |
isForceJndiDestinations()
|
boolean |
isJndiDestinations()
|
boolean |
isNoLocal()
|
boolean |
isPersistentDelivery()
|
boolean |
isRecoverJmsConnections()
|
boolean |
isRemoteSyncEnabled()
|
void |
onNotification(UMOServerNotification notification)
|
javax.jms.Message |
preProcessMessage(javax.jms.Message message,
Session session)
This method may be overridden in order to apply pre-processing to the message as soon as it arrives. |
void |
setAcknowledgementMode(int acknowledgementMode)
|
void |
setCacheJmsSessions(boolean cacheJmsSessions)
|
void |
setClientId(String clientId)
|
protected void |
setConnection(Connection connection)
|
void |
setConnectionFactory(ConnectionFactory connectionFactory)
|
void |
setConnectionFactoryClass(String connectionFactoryClass)
|
void |
setConnectionFactoryJndiName(String connectionFactoryJndiName)
|
void |
setConnectionFactoryProperties(Map connectionFactoryProperties)
|
void |
setDurable(boolean durable)
|
void |
setForceJndiDestinations(boolean forceJndiDestinations)
|
void |
setJmsSupport(JmsSupport jmsSupport)
|
void |
setJndiContext(Context jndiContext)
|
void |
setJndiDestinations(boolean jndiDestinations)
|
void |
setJndiInitialFactory(String jndiInitialFactory)
|
void |
setJndiProviderProperties(Map jndiProviderProperties)
|
void |
setJndiProviderUrl(String jndiProviderUrl)
|
void |
setMaxRedelivery(int maxRedelivery)
|
void |
setNoLocal(boolean noLocal)
|
void |
setPassword(String password)
|
void |
setPersistentDelivery(boolean persistentDelivery)
|
void |
setRecoverJmsConnections(boolean recover)
|
void |
setRedeliveryHandler(String redeliveryHandler)
|
void |
setSpecification(String specification)
|
void |
setUsername(String username)
|
boolean |
supportsProperty(String property)
This method may be overridden in case a certain JMS implementation does not support all the standard JMS properties. |
| 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 String username
public String password
| Constructor Detail |
public JmsConnector()
| Method Detail |
public void doInitialise()
throws InitialisationException
doInitialise in class AbstractServiceEnabledConnectorInitialisationException
protected void initJndiContext()
throws NamingException,
InitialisationException
NamingException
InitialisationExceptionprotected void setConnection(Connection connection)
protected ConnectionFactory createConnectionFactory()
throws InitialisationException,
NamingException
InitialisationException
NamingException
protected Connection createConnection()
throws NamingException,
JMSException,
InitialisationException
NamingException
JMSException
InitialisationException
public void doConnect()
throws ConnectException
AbstractConnector
doConnect in class AbstractConnectorConnectException
public void doDisconnect()
throws ConnectException
AbstractConnector
doDisconnect in class AbstractConnectorConnectException
public UMOMessageAdapter getMessageAdapter(Object message)
throws MessagingException
AbstractServiceEnabledConnectorUMOMessageAdapter for the endpoint for the given message
(data)
getMessageAdapter in interface UMOConnectorgetMessageAdapter in class AbstractServiceEnabledConnectormessage - the data with which to initialise the
UMOMessageAdapter
UMOMessageAdapter for the endpoint
MessagingException - if the message parameter is not
supportedUMOMessageAdapter
protected Object getReceiverKey(UMOComponent component,
UMOEndpoint endpoint)
AbstractConnector
getReceiverKey in class AbstractConnectorcomponent - the component for which the endpoint is being registeredendpoint - the endpoint being registered for the component
public Object getSessionFactory(UMOEndpoint endpoint)
public Session getSessionFromTransaction()
public Session getSession(boolean transacted,
boolean topic)
throws JMSException
JMSException
public void doStart()
throws UMOException
AbstractConnector
doStart in class AbstractConnectorUMOException - if the method failspublic String getProtocol()
getProtocol in interface UMOConnectorgetProtocol in class AbstractConnectorprotected void doDispose()
AbstractConnector
doDispose in class AbstractConnectorpublic int getAcknowledgementMode()
public void setAcknowledgementMode(int acknowledgementMode)
acknowledgementMode - The acknowledgementMode to set.public String getConnectionFactoryJndiName()
public void setConnectionFactoryJndiName(String connectionFactoryJndiName)
connectionFactoryJndiName - The connectionFactoryJndiName to set.public boolean isDurable()
public void setDurable(boolean durable)
durable - The durable to set.public boolean isNoLocal()
public void setNoLocal(boolean noLocal)
noLocal - The noLocal to set.public boolean isPersistentDelivery()
public void setPersistentDelivery(boolean persistentDelivery)
persistentDelivery - The persistentDelivery to set.public Map getJndiProviderProperties()
public void setJndiProviderProperties(Map jndiProviderProperties)
jndiProviderProperties - The JNDI providerProperties to set.public Map getConnectionFactoryProperties()
public void setConnectionFactoryProperties(Map connectionFactoryProperties)
connectionFactoryProperties - properties to be set on the underlying
ConnectionFactory.public String getJndiInitialFactory()
public void setJndiInitialFactory(String jndiInitialFactory)
public String getJndiProviderUrl()
public void setJndiProviderUrl(String jndiProviderUrl)
public Session getSession(UMOImmutableEndpoint endpoint)
throws Exception
Exceptionpublic ConnectionFactory getConnectionFactory()
public void setConnectionFactory(ConnectionFactory connectionFactory)
public String getConnectionFactoryClass()
public void setConnectionFactoryClass(String connectionFactoryClass)
public JmsSupport getJmsSupport()
public void setJmsSupport(JmsSupport jmsSupport)
public String getSpecification()
public void setSpecification(String specification)
public boolean isJndiDestinations()
public void setJndiDestinations(boolean jndiDestinations)
public boolean isForceJndiDestinations()
public void setForceJndiDestinations(boolean forceJndiDestinations)
public Context getJndiContext()
public void setJndiContext(Context jndiContext)
public void setRecoverJmsConnections(boolean recover)
public boolean isRecoverJmsConnections()
protected RedeliveryHandler createRedeliveryHandler()
throws IllegalAccessException,
NoSuchMethodException,
InvocationTargetException,
InstantiationException,
ClassNotFoundException
IllegalAccessException
NoSuchMethodException
InvocationTargetException
InstantiationException
ClassNotFoundExceptionpublic ReplyToHandler getReplyToHandler()
getReplyToHandler in class AbstractConnectorpublic String getUsername()
public void setUsername(String username)
public String getPassword()
public void setPassword(String password)
public Connection getConnection()
public String getClientId()
public void setClientId(String clientId)
public int getMaxRedelivery()
public void setMaxRedelivery(int maxRedelivery)
public String getRedeliveryHandler()
public void setRedeliveryHandler(String redeliveryHandler)
public boolean isRemoteSyncEnabled()
isRemoteSyncEnabled in interface UMOConnectorisRemoteSyncEnabled in class AbstractConnectorpublic void onNotification(UMOServerNotification notification)
onNotification in interface UMOServerNotificationListenerpublic boolean isCacheJmsSessions()
public void setCacheJmsSessions(boolean cacheJmsSessions)
public boolean supportsProperty(String property)
public javax.jms.Message preProcessMessage(javax.jms.Message message,
Session session)
throws Exception
message - - the incoming messagesession - - the JMS session
Exception
public void close(MessageProducer producer)
throws JMSException
producer -
JMSExceptionpublic void closeQuietly(MessageProducer producer)
producer -
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||