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
JmsProvider
Provides the JMS ConnectionFactory
.
connectionFactory
in interface JmsProvider
Exception
public javax.jms.Destination destination() throws Exception
JmsProvider
Provides the Destination
(topic or queue) from which the JmsSpout
will receive messages.
destination
in interface JmsProvider
Exception
Copyright © 2022 The Apache Software Foundation. All rights reserved.