Glad to hear! I don't see it documented anywhere but that is probably because it just depends on the jms implementation. Regardless the user guide clearly states we test with activemq so we should at least document a default setting for that. Would you be able to file a doc jira to improve this?
flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/TestIntegrationActiveMQ.java On Mon, Feb 24, 2014 at 7:09 PM, Richard Ross <[email protected]> wrote: > Thanks, Jeff. That was it. Easy peasy! Is this documented somewhere? If not, > it should be. :-) > > Richard. > > On Feb 24, 2014, at 6:09 PMEST, Jeff Lord wrote: > >> I think you can just drop the connectionFactory property from the >> config altogether with activemq and it will work. >> >> On Mon, Feb 24, 2014 at 2:17 PM, Richard Ross >> <[email protected]> wrote: >>> Thanks for these responses. I have tried the FCQN, but the "connection >>> factory" is just a name, and not a classname or FQCN. It could be "FOO", as >>> far as I can tell. The error occurs when the JNDI connection by this name is >>> looked up. I am thinking that this is possibly a configuration detail with >>> ActiveMQ. Has anyone successfully created a JMS source? >>> >>> Thanks again, >>> Richard. >>> >>> On Feb 24, 2014, at 4:05 PMEST, Jeff Lord wrote: >>> >>> Have you tried using the fqcn of the connection factory? >>> >>> On Monday, February 24, 2014, P lva <[email protected]> wrote: >>>> >>>> If there is no connection factory called 'GenericConnectionFactory' the >>>> lookup fails and you get this. >>>> >>>> >>>> >>>> On Mon, Feb 24, 2014 at 1:29 PM, richard ross <[email protected]> >>>> wrote: >>>> >>>> Thanks for the reply. No, there is no authentication setup yet. >>>> >>>> Here's a little of what I have figured out since the original email. I was >>>> misinterpreting the error from using "GenericConnectionFactory" or >>>> "org.apache.activemq.ActiveMQConnectionFactory", as this is just the JNDI >>>> context name. The error is simply coming from the lookup call from the >>>> initial context. As to why that error is occurring, I still have no idea. >>>> >>>> Richard. >>>> >>>> >>>> On Mon, Feb 24, 2014 at 1:35 PM, P lva <[email protected]> wrote: >>>> >>>> Does the queue need any username and password ? >>>> >>>> >>>> On Mon, Feb 24, 2014 at 11:41 AM, richard ross >>>> <[email protected]> wrote: >>>> >>>> Hello: >>>> >>>> I am doing a POC using Flume (1.4) with a JMS (ActiveMQ 5.6) source. I >>>> have used the example source configuration from the documentation: >>>> >>>> a1.sources = r1 >>>> a1.channels = c1 >>>> a1.sources.r1.type = jms >>>> a1.sources.r1.channels = c1 >>>> a1.sources.r1.initialContextFactory = >>>> org.apache.activemq.jndi.ActiveMQInitialContextFactory >>>> a1.sources.r1.connectionFactory = GenericConnectionFactory >>>> a1.sources.r1.providerURL = tcp://<myipaddress>:61616 >>>> a1.sources.r1.destinationName = TEST >>>> a1.sources.r1.destinationType = QUEUE >>>> >>>> >>>> I get the following error: >>>> >>>> 2014-02-24 12:33:05,959 (conf-file-poller-0) [ERROR - >>>> org.apache.flume.node.AbstractConfigurationProvider.loadSources(AbstractConfigurationProvider.java:366)] >>>> Source r1 has been removed due to an error during configuration >>>> org.apache.flume.FlumeException: Could not lookup ConnectionFactory >>>> at >>>> org.apache.flume.source.jms.JMSSource.doConfigure(JMSSource.java:222) >>>> at >>>> org.apache.flume.source.BasicSourceSemantics.configure(BasicSourceSemantics.java:65) >>>> at >>>> org.apache.flume.conf.Configurables.configure(Configurables.java:41) >>>> at >>>> org.apache.flume.node.AbstractConfigurationProvider.loadSources(AbstractCo >>> >>> >
