Class JndiConnectionFactory

java.lang.Object
org.springframework.jms.connection.DelegatingConnectionFactory
org.mule.jms.commons.api.connection.factory.jndi.JndiConnectionFactory
All Implemented Interfaces:
jakarta.jms.ConnectionFactory, jakarta.jms.QueueConnectionFactory, jakarta.jms.TopicConnectionFactory, org.mule.runtime.api.lifecycle.Disposable, org.mule.runtime.api.lifecycle.Initialisable, org.mule.runtime.api.lifecycle.Lifecycle, org.mule.runtime.api.lifecycle.Startable, org.mule.runtime.api.lifecycle.Stoppable, org.springframework.beans.factory.InitializingBean, org.springframework.jms.connection.SmartConnectionFactory

public class JndiConnectionFactory extends org.springframework.jms.connection.DelegatingConnectionFactory implements org.mule.runtime.api.lifecycle.Lifecycle
A ConnectionFactory that wraps a delegate that is discovered using a JndiNameResolver
Since:
1.0
  • Constructor Details

    • JndiConnectionFactory

      public JndiConnectionFactory()
  • Method Details

    • getJndiDestination

      public Optional<jakarta.jms.Destination> getJndiDestination(String name)
    • initialise

      public void initialise() throws org.mule.runtime.api.lifecycle.InitialisationException
      Specified by:
      initialise in interface org.mule.runtime.api.lifecycle.Initialisable
      Throws:
      org.mule.runtime.api.lifecycle.InitialisationException
    • start

      public void start() throws org.mule.runtime.api.exception.MuleException
      Specified by:
      start in interface org.mule.runtime.api.lifecycle.Startable
      Throws:
      org.mule.runtime.api.exception.MuleException
    • stop

      public void stop() throws org.mule.runtime.api.exception.MuleException
      Specified by:
      stop in interface org.mule.runtime.api.lifecycle.Stoppable
      Throws:
      org.mule.runtime.api.exception.MuleException
    • dispose

      public void dispose()
      Specified by:
      dispose in interface org.mule.runtime.api.lifecycle.Disposable
    • createContext

      public jakarta.jms.JMSContext createContext()
      Specified by:
      createContext in interface jakarta.jms.ConnectionFactory
      Overrides:
      createContext in class org.springframework.jms.connection.DelegatingConnectionFactory
    • createContext

      public jakarta.jms.JMSContext createContext(String userName, String password)
      Specified by:
      createContext in interface jakarta.jms.ConnectionFactory
      Overrides:
      createContext in class org.springframework.jms.connection.DelegatingConnectionFactory
    • createContext

      public jakarta.jms.JMSContext createContext(String userName, String password, int sessionMode)
      Specified by:
      createContext in interface jakarta.jms.ConnectionFactory
      Overrides:
      createContext in class org.springframework.jms.connection.DelegatingConnectionFactory
    • createContext

      public jakarta.jms.JMSContext createContext(int sessionMode)
      Specified by:
      createContext in interface jakarta.jms.ConnectionFactory
      Overrides:
      createContext in class org.springframework.jms.connection.DelegatingConnectionFactory
    • getConnectionFactoryJndiName

      public String getConnectionFactoryJndiName()
    • getLookupDestination

      public LookupJndiDestination getLookupDestination()
    • getNameResolverProvider

      public JndiNameResolverProvider getNameResolverProvider()
    • setConnectionFactoryJndiName

      public void setConnectionFactoryJndiName(String connectionFactoryJndiName)
    • setLookupDestination

      public void setLookupDestination(LookupJndiDestination lookupDestination)
    • setNameResolverProvider

      public void setNameResolverProvider(JndiNameResolverProvider nameResolverProvider)
    • getNameResolver

      public JndiNameResolver getNameResolver()
    • setNameResolver

      public void setNameResolver(JndiNameResolver nameResolver)