Thank you so much! We will try escaping the '=' in the property value to see if that resolves our issue.
Sarah From: Brock Noland <[email protected]> To: "[email protected]" <[email protected]>, Date: 09/16/2013 11:22 AM Subject: Re: Setting up JMS MessageSelector for JMS Flume Source As I would expect and can be seen here: https://github.com/apache/flume/blob/trunk/flume-ng-node/src/main/java/org/apache/flume/node/PropertiesFileConfigurationProvider.java#L190 We use java.util.Properties to read the file so whatever syntax is required for that class to read the property is required. On Mon, Sep 16, 2013 at 10:17 AM, Sarah Etzler <[email protected]> wrote: > Hi, > > Thanks for your response. > > I suppose my next question would be that Flume reads in the entire value > following the first '=' character and passes that onto the JMS > implementation, (in our case ActiveMQ)? I just want to be positive that > there isn't an issue with the second '=' character that would cause the JMS > implementation to only receive the first part of the value or the whole > value minus the '=' character. I am only lead to think this because a > proper java properties file would need to have the '=' escaped in some > manner so I want to ensure that this is not the case with the Flume > configuration file. > > Thanks in advance! > > Sarah > > > > From: Brock Noland <[email protected]> > To: "[email protected]" <[email protected]>, > Date: 09/16/2013 11:12 AM > Subject: Re: Setting up JMS MessageSelector for JMS Flume Source > ________________________________ > > > > Hi, > > Just to make sure we are the same page, the message selector is a JMS > concept, not a Flume one. We take whatever string you give us an pass > it to the JMS implementation you are using. Here is some more details > on JMS Message Selectors: > http://docs.oracle.com/cd/E19798-01/821-1841/bncer/index.html > > Based on that page I would think the syntax you specified is correct. > > Brock > > On Mon, Sep 16, 2013 at 10:06 AM, Sarah Etzler <[email protected]> > wrote: >> How does the messageSelector property work for the JMS source? Do the >> values >> need to be in quotes or escaped? The following example does not seem to >> work: >> >> agent.sources.src.messageSelector = commType = 'ascii' >> >> >> Thanks, >> >> Sarah > > > > -- > Apache MRUnit - Unit testing MapReduce - http://mrunit.apache.org > -- Apache MRUnit - Unit testing MapReduce - http://mrunit.apache.org
