Merge "Issue #1874 - created external properties files for specifying the number of grib decode threads" into omaha_13.4.1
Former-commit-id:7f25a86e4d
[formerlya244fe0cd0
[formerly cd417d34a230322f80dd48eb59416c938697320d]] Former-commit-id:a244fe0cd0
Former-commit-id:b29d274316
This commit is contained in:
commit
7816a9baa7
6 changed files with 20 additions and 6 deletions
|
@ -1,6 +1,7 @@
|
|||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<classpath>
|
||||
<classpathentry kind="src" path="src"/>
|
||||
<classpathentry kind="src" path="resources"/>
|
||||
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
|
||||
<classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/>
|
||||
<classpathentry kind="output" path="bin"/>
|
||||
|
|
|
@ -15,10 +15,14 @@
|
|||
factory-bean="jmsConfig" factory-method="copy">
|
||||
</bean>
|
||||
|
||||
<bean id="gribDecodeThreads" class="java.lang.Integer">
|
||||
<constructor-arg value="${grib-decode.count.threads}" />
|
||||
</bean>
|
||||
|
||||
<bean id="gribThreadPool"
|
||||
class="com.raytheon.uf.edex.esb.camel.spring.JmsThreadPoolTaskExecutor">
|
||||
<property name="corePoolSize" value="4" />
|
||||
<property name="maxPoolSize" value="4" />
|
||||
<property name="corePoolSize" ref="gribDecodeThreads" />
|
||||
<property name="maxPoolSize" ref="gribDecodeThreads" />
|
||||
</bean>
|
||||
|
||||
<bean id="largeFileChecker" class="com.raytheon.edex.plugin.grib.GribLargeFileChecker" />
|
||||
|
@ -71,7 +75,7 @@
|
|||
|
||||
<!-- Begin Grib Decode Route -->
|
||||
<route id="gribIngestRoute">
|
||||
<from uri="ingest-grib:queue:Ingest.Grib?concurrentConsumers=4&destinationResolver=#qpidDurableResolver" />
|
||||
<from uri="ingest-grib:queue:Ingest.Grib?concurrentConsumers=#gribDecodeThreads&destinationResolver=#qpidDurableResolver" />
|
||||
<setHeader headerName="pluginName">
|
||||
<constant>grid</constant>
|
||||
</setHeader>
|
||||
|
|
|
@ -0,0 +1,2 @@
|
|||
# the number of grib decode threads.
|
||||
grib-decode.count.threads=4
|
|
@ -2,6 +2,7 @@
|
|||
<classpath>
|
||||
<classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/>
|
||||
<classpathentry kind="src" path="src"/>
|
||||
<classpathentry kind="src" path="resources"/>
|
||||
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
|
||||
<classpathentry kind="output" path="bin"/>
|
||||
</classpath>
|
||||
|
|
|
@ -13,6 +13,10 @@
|
|||
|
||||
<bean id="ncgridAssembler" class="gov.noaa.nws.ncep.edex.plugin.ncgrib.NcgridAssembler"/>
|
||||
|
||||
<bean id="ncgribDecodeThreads" class="java.lang.Integer">
|
||||
<constructor-arg value="${ncgrib-decode.count.threads}" />
|
||||
</bean>
|
||||
|
||||
<bean id="ingest-ncgrib" class="org.apache.camel.component.jms.JmsComponent">
|
||||
<constructor-arg ref="jmsIngestNcgribConfig" />
|
||||
<property name="taskExecutor" ref="ncgribThreadPool" />
|
||||
|
@ -22,8 +26,8 @@
|
|||
</bean>
|
||||
<bean id="ncgribThreadPool"
|
||||
class="com.raytheon.uf.edex.esb.camel.spring.JmsThreadPoolTaskExecutor">
|
||||
<property name="corePoolSize" value="4" />
|
||||
<property name="maxPoolSize" value="4" />
|
||||
<property name="corePoolSize" ref="ncgribDecodeThreads" />
|
||||
<property name="maxPoolSize" ref="ncgribDecodeThreads" />
|
||||
</bean>
|
||||
|
||||
<bean id="ncgribLargeFileChecker" class="gov.noaa.nws.ncep.edex.plugin.ncgrib.NcgribLargeFileChecker" />
|
||||
|
@ -68,7 +72,7 @@
|
|||
|
||||
|
||||
<route id="ncgribIngestRoute">
|
||||
<from uri="ingest-ncgrib:queue:Ingest.Ncgrib?concurrentConsumers=4&destinationResolver=#qpidDurableResolver" />
|
||||
<from uri="ingest-ncgrib:queue:Ingest.Ncgrib?concurrentConsumers=#ncgribDecodeThreads&destinationResolver=#qpidDurableResolver" />
|
||||
<setHeader headerName="pluginName">
|
||||
<constant>ncgrib</constant>
|
||||
</setHeader>
|
||||
|
|
|
@ -0,0 +1,2 @@
|
|||
# the number of ncgrib decode threads.
|
||||
ncgrib-decode.count.threads=4
|
Loading…
Add table
Reference in a new issue