Skip to content

Commit

Permalink
Spring file for velpt_ab driver and fixed master_parameters file
Browse files Browse the repository at this point in the history
Change-Id: Id4d06b549d29f8e451044049d4d19f8ad3968d6a
  • Loading branch information
JeffRoy committed Dec 1, 2014
1 parent 91e4960 commit 0b26b65
Showing 1 changed file with 45 additions and 0 deletions.
45 changes: 45 additions & 0 deletions res/spring/ooi-velpt-ab-decode.xml
Original file line number Diff line number Diff line change
@@ -0,0 +1,45 @@
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">

<bean id="velpt-ab_recoveredProcessor" class="com.raytheon.uf.edex.ooi.decoder.dataset.FileDecoder">
<constructor-arg name="name" value="velpt-ab_recovered" />
<constructor-arg name="basePythonCodePath" value="#{basePythonCodeLocalizationPath}" />
<constructor-arg name="scriptPath" value="#{basePythonCodeLocalizationPath}/mi/dataset/driver/velpt_ab/velpt_ab_recovered_driver.py" />
</bean>

<camelContext id="velpt-ab-decode-camel"
xmlns="http://camel.apache.org/schema/spring" errorHandlerRef="errorHandler">

<endpoint id="velpt-ab_recoveredFileEndpoint"
uri="file:${edex.home}/data/ooi/velpt-ab_recovered?delete=true&amp;delay=3000&amp;maxMessagesPerPoll=30&amp;exclusiveReadLockStrategy=#fileChangedStrategy" />

<route id="velpt-ab_recoveredFileConsumerRoute">
<from ref="velpt-ab_recoveredFileEndpoint" />
<setHeader headerName="deliveryType">
<constant>recovered</constant>
</setHeader>
<setHeader headerName="sensor">
<constant>XX00XXXX-XX00X-00-VELABR001</constant>
</setHeader>
<bean ref="fileToString" />
<to uri="jms-durable:queue:Ingest.velpt-ab_recovered" />
</route>

<route id="velpt-ab_recoveredIngest">
<from uri="jms-durable:queue:Ingest.velpt-ab_recovered" />
<doTry>
<pipeline>
<bean ref="velpt-ab_recoveredProcessor" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>
<to uri="log:ooi.velpt-ab?level=ERROR" />
</doCatch>
</doTry>
</route>

</camelContext>
</beans>

0 comments on commit 0b26b65

Please sign in to comment.