xan/awips2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Issue #1874 - created external properties files for specifying the number of grib decode threads

Browse source 
- there is now one property for the number of threads
- the property is now used to set the number of concurrent consumers

Change-Id: I5e0c39928d1f3b92ad2875e6b720c9dde1b779ff

Former-commit-id: d1799b4e0f [formerly 4ef22f8e93] [formerly 70aa1a040fe4bf5844f91afa107629db085a2618 [formerly eb04d2b85f]] [formerly b5994702dc [formerly eb04d2b85f [formerly deeab1e1074fec2d62e55760d9fe45ec7379b9f8]]]
Former-commit-id: b5994702dc
Former-commit-id: e08966d5518c4d5452b179ec7af6e2e7ae211afb [formerly a60f14f5d6]
Former-commit-id: fa1e0a02b0
This commit is contained in:
Bryan Kowal 2013-04-10 10:37:32 -05:00
parent 212dd227cc
commit 2393357287
6 changed files with 20 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
edexOsgi/com.raytheon.edex.plugin.grib/.classpath
View file

@ -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"/>

10
edexOsgi/com.raytheon.edex.plugin.grib/res/spring/grib-decode.xml
View file

@ -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&amp;destinationResolver=#qpidDurableResolver" />
<from uri="ingest-grib:queue:Ingest.Grib?concurrentConsumers=#gribDecodeThreads&amp;destinationResolver=#qpidDurableResolver" />
<setHeader headerName="pluginName">
<constant>grid</constant>
</setHeader>

2
edexOsgi/com.raytheon.edex.plugin.grib/resources/com.raytheon.edex.plugin.grib.properties Normal file
View file

@ -0,0 +1,2 @@
# the number of grib decode threads.
grib-decode.count.threads=4

1
ncep/gov.noaa.nws.ncep.edex.plugin.ncgrib/.classpath
View file

@ -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>

10
ncep/gov.noaa.nws.ncep.edex.plugin.ncgrib/res/spring/ncgrib-ingest.xml
View file

@ -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&amp;destinationResolver=#qpidDurableResolver" />
<from uri="ingest-ncgrib:queue:Ingest.Ncgrib?concurrentConsumers=#ncgribDecodeThreads&amp;destinationResolver=#qpidDurableResolver" />
<setHeader headerName="pluginName">
<constant>ncgrib</constant>
</setHeader>

2
ncep/gov.noaa.nws.ncep.edex.plugin.ncgrib/resources/gov.noaa.nws.ncep.edex.plugin.ncgrib.properties Normal file
View file

@ -0,0 +1,2 @@
# the number of ncgrib decode threads.
ncgrib-decode.count.threads=4