public class SpringJmsProvider extends Object implements JmsProvider
A JmsProvider that uses the spring framework to obtain a JMS ConnectionFactory and Desitnation objects.
The constructor takes three arguments:
| Constructor and Description |
|---|
SpringJmsProvider(String appContextClasspathResource,
String connectionFactoryBean,
String destinationBean)
Constructs a
SpringJmsProvider object given the name of a classpath resource (the spring application context file), and the bean names of a JMS connection factory and destination. |
| Modifier and Type | Method and Description |
|---|---|
javax.jms.ConnectionFactory |
connectionFactory()
Provides the JMS
ConnectionFactory. |
javax.jms.Destination |
destination()
Provides the
Destination (topic or queue) from which the JmsSpout will receive messages. |
public SpringJmsProvider(String appContextClasspathResource, String connectionFactoryBean, String destinationBean)
Constructs a SpringJmsProvider object given the name of a classpath resource (the spring application context file), and the bean names of a JMS connection factory and destination.
appContextClasspathResource - connectionFactoryBean - destinationBean - public javax.jms.ConnectionFactory connectionFactory()
throws Exception
JmsProviderProvides the JMS ConnectionFactory.
connectionFactory in interface JmsProviderExceptionpublic javax.jms.Destination destination()
throws Exception
JmsProviderProvides the Destination (topic or queue) from which the JmsSpout will receive messages.
destination in interface JmsProviderExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.