On Thu, Oct 8, 2009 at 11:22 AM, titexe <abdellatifbouch...@eurofins.com> wrote:
>
>
> my incoming queue, receives messages of bytes type.
>
> the message content in bytes may be an XML or CSV or PDF file that I
> converted a file in the end.
>
> In the header of the message,there's on properties(Action), that allows me
> to place this file to the proper directory.
>
Ah are you saying its a JMS property that has this value? If so you
can route without xpath using the header predicate instead
<xpath> $ action = 'AAE' </ xpath>
Could then be
<simple>${header.action} == 'AAE' </header>
Using the simple language to test this
http://camel.apache.org/simple.html
> From where I put <xpath> $ action = 'AAE' </ xpath> <to
> uri="file:///c:/CSV/AAE"/>
>
> Thank you for helping me find a good solution to my problem
>
> Thank you again for your help
>
>
> Claus Ibsen-2 wrote:
>>
>> Hi
>>
>> Why do you have mixed message on that JMS queue?
>>
>> Can you not have 1 queue for XML files
>> And another queue for CSV files?
>>
>> If not I suggest to use 3 routes
>>
>> 1st route will consume from that JMS queue and check the message
>> content if its XML or CSV.
>> And then route to either A or B depending on that
>>
>> 2nd route = A which is the XML route where you can use xpath
>>
>> 3rd route = B which is the CSV route where you use something else than
>> xpath. For example a java bean to check the action or what you would
>> like to do with the CSV file.
>>
>>
>> On Thu, Oct 8, 2009 at 10:48 AM, titexe <abdellatifbouch...@eurofins.com>
>> wrote:
>>>
>>> Firstly, thank you for your reply,
>>>
>>> Action is a field that exists in the header of the message (Message
>>> proportions), normally xpath ($ action = 'AAE') should not parse the
>>> message
>>> body.
>>>
>>> if not, it is possible to use another command that allows me to filter
>>> the
>>> fields in the header of the message without parsing the message body? and
>>> it
>>> is possible to use it in my case <choice> of my route?
>>>
>>> Thank you in advance
>>>
>>>
>>> Claus Ibsen-2 wrote:
>>>>
>>>> Hi
>>>>
>>>> You are using XPath expressions
>>>> <xpath> $ action = 'AAE' </ xpath>
>>>>
>>>> And they *require* the payload to be XML.
>>>> So you cannot use XPath with CSV.
>>>>
>>>>
>>>> On Wed, Oct 7, 2009 at 10:59 AM, titexe
>>>> <abdellatifbouch...@eurofins.com>
>>>> wrote:
>>>>>
>>>>> For information
>>>>>
>>>>> Version Camel = Camel V1.6.1.2
>>>>> Version Activemq = Fuse message broker 5.3.0.3
>>>>> Version Java = V1.6.0_16
>>>>>
>>>>>
>>>>> titexe wrote:
>>>>>>
>>>>>> Hello,
>>>>>>
>>>>>> Here is the description of my route camel : I get a message type Bytes
>>>>>> in
>>>>>> my queue, I transferred this message to another broker instance in
>>>>>> another
>>>>>> machine.
>>>>>>
>>>>>> was receiving this message I transformed this message to CSV or XML
>>>>>> file.
>>>>>>
>>>>>> my problem is that my route works very well for XML files and not for
>>>>>> CSV
>>>>>> files.
>>>>>>
>>>>>> Here is my setup:
>>>>>>
>>>>>> <route errorHandlerRef="myDeadLetterChannel">
>>>>>> <from uri="activemq:queue:IN"/>
>>>>>> <choice>
>>>>>> <when>
>>>>>> <xpath> $ action = 'AAE' </ xpath>
>>>>>> <t uri="file:///c:/IN/AAE/"/>
>>>>>> <setBody>
>>>>>> <simple> UPDATE SET CAMEL CamelDate = CURRENT_TIMESTAMP WHERE message
>>>>>> =
>>>>>> '$
>>>>>> (in.header.MessageId)' </ simple>
>>>>>> </ setBody>
>>>>>> <t uri="jdbc:testdb"/>
>>>>>> </ when>
>>>>>> <when>
>>>>>> <xpath> $ action = 'FAE' </ xpath>
>>>>>> <t uri="file:///c:/IN/FAE/"/>
>>>>>> <setBody>
>>>>>> <simple> UPDATE SET CAMEL CamelDate = CURRENT_TIMESTAMP WHERE message
>>>>>> =
>>>>>> '$
>>>>>> (in.header.MessageId)' </ simple>
>>>>>> </ setBody>
>>>>>> <t uri="jdbc:testdb"/>
>>>>>> </ when>
>>>>>>
>>>>>> <otherwise>
>>>>>> <t uri="activemq:queue:FilterError"/>
>>>>>> </ otherwise>
>>>>>>
>>>>>> </ choice>
>>>>>> </ route>
>>>>>>
>>>>>>
>>>>>> Here is the error that I receive when the transformationfor CSV file.
>>>>>>
>>>>>>
>>>>>> WARN EndpointMessageListener - Endpoint [ActiveMQ: tail: IN] consumer
>>>>>> caught an exception while processing JMS message: ActiveMQBytesMessage
>>>>>> CommandID = (10, responseRequired = false, messageId = ID:
>>>>>> DCFR-4099-1254861846625-3: 0:1:1:1, originalDestination = null,
>>>>>> originalTransactionId = null,
>>>>>> producerId = ID: DCFR-4099-1254861846625-2: 0:1:1, destination =
>>>>>> queue:
>>>>>> / / IN, transactionId = null, expiration = 0, timestamp =
>>>>>> 1254862039687,
>>>>>> arrived
>>>>>> l = 0, brokerInTime = 1254879861750, brokerOutTime = 1254879861765,
>>>>>> CorrelationId = null, ReplyTo = null, persistent = true, type = null,
>>>>>> priority = 4
>>>>>> , GroupID = null, groupSequence = 0, targetConsumerId = null,
>>>>>> compressed
>>>>>> =
>>>>>> false, userID = null, content = org.apache.activemq.util.ByteSequence
>>>>>> @
>>>>>> 6baf2
>>>>>> 4 marshalledProperties = org.apache.activemq.util.ByteSequence @
>>>>>> 1b7a553,
>>>>>> Datastructures = null, redeliveryCounter = 0, size = 2597, properties
>>>>>> =
>>>>>> (Sourc
>>>>>> eEndpoint = null, org_apache_camel_file_name = EUANNA_PCA_20090901
>>>>>> (50e71be4-B408-48b3-9048-4e68faf6cbd3). csv DestinationEndpoint =
>>>>>> null,
>>>>>> MessageId = (50e71be
>>>>>> 4-B408-48b3-9048-4e68faf6cbd3), Action = PCA PartnerCode = EUANNA,
>>>>>> SourceEndpointUser = null, RequestMessageId = null),
>>>>>> readOnlyProperties
>>>>>> =
>>>>>> true, readOnlyBo
>>>>>> dy = true, droppable = false) (ActiveMQBytesMessage = null bytesOut,
>>>>>> dataOut = null, @ DATAIN = java.io.DataInputStream 1d314cc)
>>>>>> org.apache.camel.RuntimeCamelException: org.xml.sax.SAXParseException:
>>>>>> Content is not allowed in prolog.
>>>>>> at org.apache.camel.util.ObjectHelper.invokeMethod
>>>>>> (ObjectHelper.java: 567)
>>>>>> at
>>>>>> org.apache.camel.impl.converter.InstanceMethodTypeConverter.convertTo
>>>>>> (InstanceMethodTypeConverter.java: 57)
>>>>>> at
>>>>>> org.apache.camel.impl.converter.DefaultTypeConverter.doConvertTo
>>>>>> (DefaultTypeConverter.java: 119)
>>>>>> at
>>>>>> org.apache.camel.impl.converter.DefaultTypeConverter.convertTo
>>>>>> (DefaultTypeConverter.java: 90)
>>>>>> at org.apache.camel.impl.MessageSupport.getBody
>>>>>> (MessageSupport.java: 79)
>>>>>> at org.apache.camel.impl.MessageSupport.getBody
>>>>>> (MessageSupport.java: 52)
>>>>>> at org.apache.camel.builder.xml.XPathBuilder.getDocument
>>>>>> (XPathBuilder.java: 536)
>>>>>> at org.apache.camel.builder.xml.XPathBuilder.evaluateAs
>>>>>> (XPathBuilder.java: 428)
>>>>>> at org.apache.camel.builder.xml.XPathBuilder.matches
>>>>>> (XPathBuilder.java: 106)
>>>>>> at org.apache.camel.builder.xml.XPathBuilder.matches
>>>>>> (XPathBuilder.java: 65)
>>>>>> at org.apache.camel.processor.ChoiceProcessor.process
>>>>>> (ChoiceProcessor.java: 47)
>>>>>> at
>>>>>> org.apache.camel.management.InstrumentationProcessor.process
>>>>>> (InstrumentationProcessor.java: 80)
>>>>>>
>>>>>> Thank you for helping me resolve this problem,
>>>>>>
>>>>>> Thank you in advance,
>>>>>>
>>>>>> best regards,
>>>>>>
>>>>>> titexe
>>>>>>
>>>>>
>>>>> --
>>>>> View this message in context:
>>>>> http://www.nabble.com/Camel-%3A-Error-Message-to-CSV-file-tp25781902p25782958.html
>>>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>>>
>>>>>
>>>>
>>>>
>>>>
>>>> --
>>>> Claus Ibsen
>>>> Apache Camel Committer
>>>>
>>>> Open Source Integration: http://fusesource.com
>>>> Blog: http://davsclaus.blogspot.com/
>>>> Twitter: http://twitter.com/davsclaus
>>>>
>>>>
>>>
>>> --
>>> View this message in context:
>>> http://www.nabble.com/Camel-%3A-Error-Message-to-CSV-file-tp25781902p25800470.html
>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>
>>>
>>
>>
>>
>> --
>> Claus Ibsen
>> Apache Camel Committer
>>
>> Open Source Integration: http://fusesource.com
>> Blog: http://davsclaus.blogspot.com/
>> Twitter: http://twitter.com/davsclaus
>>
>>
>
> --
> View this message in context:
> http://www.nabble.com/Camel-%3A-Error-Message-to-CSV-file-tp25781902p25800861.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
--
Claus Ibsen
Apache Camel Committer
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus
