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

Merge "Issue #1989 use camel's built-in DirectVm component" into development

Browse source 
Former-commit-id: f608d0ec297d85ba3e72c23905375f086fef2477
This commit is contained in:
Nate Jensen 2013-05-23 10:43:15 -05:00 • committed by Gerrit Code Review
commit 3b058175fe
94 changed files with 152 additions and 136 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
edexOsgi/com.raytheon.edex.autobldsrv/res/spring/subscription-common.xml
View file

@ -39,7 +39,7 @@
<!-- LDAD (watch/warn) triggered script runner, internal use only -->
<route id="ldadWatchWarnDirect">
<from uri="directvm:ldadWatchWarnDirect"/>
<from uri="direct-vm:ldadWatchWarnDirect"/>
<doTry>
<bean ref="ldadScriptRunner" method="runScripts" />
<doCatch>

6
edexOsgi/com.raytheon.edex.ingestsrv/res/spring/persist-ingest.xml
View file

@ -26,7 +26,7 @@
Indexing but no alert processing
-->
<route id="persistIndex">
<from uri="directvm:persistIndex"/>
<from uri="direct-vm:persistIndex"/>
<bean ref="persist" method="persist"/>
<bean ref="index" method="index"/>
<bean ref="processUtil" method="log"/>
@ -37,7 +37,7 @@
Indexing and Alerting
-->
<route id="persistIndexAlert">
<from uri="directvm:persistIndexAlert"/>
<from uri="direct-vm:persistIndexAlert"/>
<bean ref="persist" method="persist"/>
<bean ref="index" method="index"/>
<bean ref="processUtil" method="log"/>
@ -49,7 +49,7 @@
Intended for routes that need Indexing and Alerting
-->
<route id="indexAlert">
<from uri="directvm:indexAlert"/>
<from uri="direct-vm:indexAlert"/>
<bean ref="index" method="index"/>
<bean ref="processUtil" method="log"/>
<bean ref="toDataURI" method="toDataURI"/>

2
edexOsgi/com.raytheon.edex.plugin.airep/res/spring/airep-ingest.xml
View file

@ -52,7 +52,7 @@
<doTry>
<pipeline>
<bean ref="airepDecoder" method="decode" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.binlightning/res/spring/binlightning_ep-ingest.xml
View file

@ -46,7 +46,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="binlightningDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>

2
edexOsgi/com.raytheon.edex.plugin.bufrmos/res/spring/bufrmos-ingest.xml
View file

@ -45,7 +45,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="bufrmosDecoder" method="decode"/>
<to uri="directvm:persistIndexAlert"/>
<to uri="direct-vm:persistIndexAlert"/>
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.bufrua/res/spring/bufrua-ingest.xml
View file

@ -48,7 +48,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="bufruaDecoder" method="decode"/>
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.ccfp/res/spring/ccfp-ingest.xml
View file

@ -47,7 +47,7 @@
<doTry>
<pipeline>
<bean ref="ccfpDecoder" method="decode" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-spring.xml
View file

@ -63,7 +63,7 @@
</route>
<route id="WCLWatch">
<from uri="directvm:wclWatch" />
<from uri="direct-vm:wclWatch" />
<bean ref="wclWatch" method="handleWclWatch" />
</route>

2
edexOsgi/com.raytheon.edex.plugin.goessounding/res/spring/goessounding-ingest.xml
View file

@ -54,7 +54,7 @@
<doTry>
<pipeline>
<bean ref="goessoundingDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

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

@ -92,9 +92,9 @@
<bean ref="gribPostProcessor" method="process" />
<multicast parallelProcessing="false">
<!-- send to persistence -->
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
<!-- send to transform -->
<to uri="directvm:gridToGrib"/>
<to uri="direct-vm:gridToGrib"/>
</multicast>
</pipeline>
<doCatch>
@ -114,7 +114,7 @@
</route>
<route id="gridToGrib">
<from uri="directvm:gridToGrib"/>
<from uri="direct-vm:gridToGrib"/>
<bean ref="gridToGribConverter" method="convert"/>
<bean ref="index" method="index"/>
<bean ref="toDataURI" method="toDataURI"/>

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

@ -87,7 +87,7 @@
<bean ref="gribSplitter" method="clean" />
<!-- send for processing -->
<bean ref="gribPostProcessor" method="process" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

6
edexOsgi/com.raytheon.edex.plugin.ldad/res/spring/ldad-ingest.xml
View file

@ -29,21 +29,21 @@
<from uri="jms-generic:queue:Ingest.ldad" />
<multicast>
<try>
<to uri="directvm:ldadmesonetIngest" />
<to uri="direct-vm:ldadmesonetIngest" />
<catch>
<exception>java.lang.Throwable</exception>
<to uri="log:ldadmesonet?level=ERROR&amp;showBody=false&amp;showCaughtException=true&amp;showStackTrace=true"/>
</catch>
</try>
<try>
<to uri="directvm:ldadhydroIngest" />
<to uri="direct-vm:ldadhydroIngest" />
<catch>
<exception>java.lang.Throwable</exception>
<to uri="log:ldadhydro?level=ERROR&amp;showBody=false&amp;showCaughtException=true&amp;showStackTrace=true"/>
</catch>
</try>
<try>
<to uri="directvm:ldadmanualIngest" />
<to uri="direct-vm:ldadmanualIngest" />
<catch>
<exception>java.lang.Throwable</exception>
<to uri="log:ldadmanual?level=ERROR&amp;showBody=false&amp;showCaughtException=true&amp;showStackTrace=true"/>

2
edexOsgi/com.raytheon.edex.plugin.ldadhydro/res/spring/ldadhydro-ingest.xml
View file

@ -37,7 +37,7 @@
<bean ref="stringToFile" />
<bean ref="hydroDecoder" method="decode" />
<bean ref="ldadhydroPointData" method="toPointData" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.ldadmanual/res/spring/ldadmanual-ingest.xml
View file

@ -34,7 +34,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="manualDecoder" method="decode" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.ldadprofiler/res/spring/ldadprofiler-ingest.xml
View file

@ -50,7 +50,7 @@
<bean ref="stringToFile" />
<bean ref="ldadprofilerDecoder" method="decode"/>
<bean ref="ldadprofilerPointData" method="toPointData" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.modelsounding/res/spring/modelsounding-ingest.xml
View file

@ -59,7 +59,7 @@
<doTry>
<pipeline>
<bean ref="modelsoundingDecoder" method="decode"/>
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

6
edexOsgi/com.raytheon.edex.plugin.obs/res/spring/obs-ingest.xml
View file

@ -55,9 +55,9 @@
<bean ref="obsDecoder" method="decode" />
<bean ref="metarPointData" method="toPointData" />
<multicast>
<to uri="directvm:persistIndexAlert" />
<to uri="directvm:metarToShef" />
<to uri="directvm:metarToHMDB"/>
<to uri="direct-vm:persistIndexAlert" />
<to uri="direct-vm:metarToShef" />
<to uri="direct-vm:metarToHMDB"/>
</multicast>
</pipeline>
<doCatch>

2
edexOsgi/com.raytheon.edex.plugin.pirep/res/spring/pirep-ingest.xml
View file

@ -53,7 +53,7 @@
<doTry>
<pipeline>
<bean ref="pirepDecoder" method="decode"/>
<to uri="directvm:indexAlert"/>
<to uri="direct-vm:indexAlert"/>
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.poessounding/res/spring/poessounding-ingest.xml
View file

@ -46,7 +46,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="poessoundingDecoder" method="decode"/>
<to uri="directvm:persistIndexAlert"/>
<to uri="direct-vm:persistIndexAlert"/>
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.profiler/res/spring/profiler-ingest.xml
View file

@ -46,7 +46,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="profilerDecoder" method="decode"/>
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.radar/res/spring/radar-ingest.xml
View file

@ -80,7 +80,7 @@
<bean ref="stringToFile" />
<bean ref="radarDecompressor" method="decompress" />
<bean ref="radarDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.recco/res/spring/recco-ingest.xml
View file

@ -52,7 +52,7 @@
<doTry>
<pipeline>
<bean ref="reccoDecoder" method="decode" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.redbook/res/spring/redbook-ingest.xml
View file

@ -53,7 +53,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="redbookDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.edex.plugin.satellite/res/spring/satellite-ingest.xml
View file

@ -62,7 +62,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="satelliteDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
edexOsgi/com.raytheon.edex.plugin.sfcobs/res/spring/sfcobs-ingest.xml
View file

@ -54,8 +54,8 @@
<bean ref="sfcobsDecoder" method="decode" />
<bean ref="sfcobsPointData" method="toPointData" />
<multicast>
<to uri="directvm:persistIndexAlert" />
<to uri="directvm:synopticToShef"/>
<to uri="direct-vm:persistIndexAlert" />
<to uri="direct-vm:synopticToShef"/>
</multicast>
</pipeline>
<doCatch>

14
edexOsgi/com.raytheon.edex.plugin.shef/res/spring/shef-ingest.xml
View file

@ -98,7 +98,7 @@
</setHeader>
<pipeline>
<bean ref="stringToFile" />
<to uri="directvm:shefProcessing" />
<to uri="direct-vm:shefProcessing" />
</pipeline>
</route>
<route id="shefStagedRoute">
@ -107,13 +107,13 @@
<setHeader headerName="pluginName">
<constant>shef</constant>
</setHeader>
<to uri="directvm:shefProcessing" />
<to uri="direct-vm:shefProcessing" />
</route>
<!-- directvm will be run under original thread, should this be moved to
<!-- direct-vm will be run under original thread, should this be moved to
a queue?? but will cause message to be serialized to the jms queue... -->
<route id="synopticToShefRoute">
<from uri="directvm:synopticToShef" />
<from uri="direct-vm:synopticToShef" />
<bean ref="synopticToShefFilter" method="filter" />
<pipeline>
<split streaming="true">
@ -124,10 +124,10 @@
</pipeline>
</route>
<!-- directvm will be run under original thread, should this be moved to
<!-- direct-vm will be run under original thread, should this be moved to
a queue?? but will cause message to be serialized to the jms queue... -->
<route id="metarToShefRoute">
<from uri="directvm:metarToShef" />
<from uri="direct-vm:metarToShef" />
<bean ref="metarToShefFilter" method="filter" />
<pipeline>
<split streaming="true">
@ -140,7 +140,7 @@
</route>
<route id="shefProcessingRoute">
<from uri="directvm:shefProcessing" />
<from uri="direct-vm:shefProcessing" />
<doTry>
<pipeline>
<bean ref="shefDecoder" method="decode" />

2
edexOsgi/com.raytheon.edex.plugin.taf/res/spring/taf-ingest.xml
View file

@ -55,7 +55,7 @@
<doTry>
<pipeline>
<bean ref="tafDecoder" method="decode" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
edexOsgi/com.raytheon.edex.plugin.text/res/spring/text-ingest.xml
View file

@ -70,7 +70,7 @@
Text routes
-->
<route id="textDirectDecodedIngestRoute">
<from uri="directvm:textDirectDecodedIngestRoute" />
<from uri="direct-vm:textDirectDecodedIngestRoute" />
<setHeader headerName="pluginName">
<constant>text</constant>
</setHeader>
@ -93,7 +93,7 @@
</route>
<route id="textDirectUndecodedIngestRoute">
<from uri="directvm:textDirectUndecodedIngestRoute" />
<from uri="direct-vm:textDirectUndecodedIngestRoute" />
<setHeader headerName="pluginName">
<constant>text</constant>
</setHeader>

2
edexOsgi/com.raytheon.edex.plugin.textlightning/res/spring/textlightning_ep-ingest.xml
View file

@ -46,7 +46,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="textlightningDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
edexOsgi/com.raytheon.edex.plugin.warning/res/spring/warning-ingest.xml
View file

@ -68,7 +68,7 @@
<bean ref="warningDecoder" method="decode" />
<bean ref="index" method="index" />
<multicast parallelProcessing="false">
<to uri="directvm:warningIngestAlert" />
<to uri="direct-vm:warningIngestAlert" />
<to uri="jms-warning:queue:edex.spcWatch" />
<to uri="jms-warning:queue:edex.tpcWatch" />
<filter>
@ -85,7 +85,7 @@
</route>
<route id="warningIngestAlert">
<from uri="directvm:warningIngestAlert" />
<from uri="direct-vm:warningIngestAlert" />
<bean ref="toDataURI" method="toDataURI" />
<bean ref="processUtil" method="log" />
<to uri="vm:stageNotification" />

6
edexOsgi/com.raytheon.edex.textdb/res/spring/textdb-request.xml
View file

@ -37,7 +37,7 @@
</bean>
<bean id="remoteRetrievalManager" class="com.raytheon.edex.textdb.handler.RemoteRetrievalManager">
<!-- <property name="remoteRetrievalExternalURI" value="directvm:remoteRetrievalExternalRoute" /> -->
<!-- <property name="remoteRetrievalExternalURI" value="direct-vm:remoteRetrievalExternalRoute" /> -->
<property name="rrDelegate" ref="textdbRemoteRetrievalTarget" />
</bean>
@ -58,10 +58,10 @@
<proxy id="textdbRemoteRetrievalTarget"
serviceInterface="com.raytheon.edex.textdb.handler.RemoteRetrievalManager$IRRDelegate"
serviceUrl="directvm:remoteRetrievalExternalRoute" />
serviceUrl="direct-vm:remoteRetrievalExternalRoute" />
<route id="remoteRetrievalExternal">
<from uri="directvm:remoteRetrievalExternalRoute" />
<from uri="direct-vm:remoteRetrievalExternalRoute" />
<!-- Convert from BeanInvocation if needed. -->
<convertBodyTo type="com.raytheon.uf.common.dataplugin.text.request.RemoteRetrievalRequest" />
<bean ref="serializationUtil" method="transformToThrift" />

2
edexOsgi/com.raytheon.uf.edex.cpgsrv/res/spring/cpgsrv-spring.xml
View file

@ -17,7 +17,7 @@
errorHandlerRef="errorHandler"
autoStartup="false">
<route id="cpgProcessAlerts">
<from uri="directvm:processCPGAlerts"/>
<from uri="direct-vm:processCPGAlerts"/>
<bean ref="toDataURI" method="toDataURI"/>
<to uri="vm:stageNotification"/>
</route>

2
edexOsgi/com.raytheon.uf.edex.datadelivery.bandwidth/res/spring/bandwidth-datadelivery-edex-impl.xml
View file

@ -60,7 +60,7 @@
<!-- notify retrieval threads, if data delivery made
into cluster this should move to topic post -->
<to uri="directvm:notifyRetrieval" />
<to uri="direct-vm:notifyRetrieval" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
edexOsgi/com.raytheon.uf.edex.datadelivery.retrieval/res/spring/retrieval-datadelivery-wfo.xml
View file

@ -21,7 +21,7 @@
<constructor-arg>
<bean
class="com.raytheon.uf.edex.datadelivery.retrieval.handlers.StoreRetrievedData">
<constructor-arg value="directvm:dataDeliveryNotify" />
<constructor-arg value="direct-vm:dataDeliveryNotify" />
<constructor-arg ref="retrievalDao" />
</bean>
</constructor-arg>
@ -49,7 +49,7 @@
<constructor-arg>
<bean
class="com.raytheon.uf.edex.datadelivery.retrieval.handlers.StoreRetrievedData">
<constructor-arg value="directvm:dataDeliveryNotify" />
<constructor-arg value="direct-vm:dataDeliveryNotify" />
<constructor-arg ref="retrievalDao" />
</bean>
</constructor-arg>

4
edexOsgi/com.raytheon.uf.edex.datadelivery.retrieval/res/spring/retrieval-datadelivery.xml
View file

@ -53,12 +53,12 @@
<!-- Wake retrieval threads if were not running -->
<route id="notifyRetrieval">
<!-- If data delivery clustered, move this to topic -->
<from uri="directvm:notifyRetrieval" />
<from uri="direct-vm:notifyRetrieval" />
<bean ref="retrievalHandler" method="notify" />
</route>
<route id="dataDeliveryNotify">
<from uri="directvm:dataDeliveryNotify" />
<from uri="direct-vm:dataDeliveryNotify" />
<bean ref="toDataURI" method="toDataURI" />
<to uri="vm:stageNotification" />
</route>

2
edexOsgi/com.raytheon.uf.edex.datadelivery.retrieval/utility/edex_static/base/mapping/pluginRoutes.xml
View file

@ -1,3 +1,3 @@
<pluginRouteList>
<pluginRoute name="grid" value="directvm:persistIndexAlert" />
<pluginRoute name="grid" value="direct-vm:persistIndexAlert" />
</pluginRouteList>

11
edexOsgi/com.raytheon.uf.edex.esb.camel/src/com/raytheon/uf/edex/esb/camel/directvm/DirectVMComponent.java
View file

@ -31,7 +31,9 @@ import org.apache.camel.impl.DefaultEndpoint;
import org.apache.camel.util.ServiceHelper;
/**
* Provides a cross-context synchronous component
* Provides a cross-context synchronous component. Deprecated: Use camel's
* built-in direct-vm component instead. This component can be deleted after
* that has been tested thoroughly.
*
* <pre>
*
@ -40,6 +42,7 @@ import org.apache.camel.util.ServiceHelper;
* ------------ ---------- ----------- --------------------------
* Nov 18, 2008 chammack Initial creation
* Jul 16, 2012 DR 15073 D. Friedman Don't stop all consumer in doStop.
* May 23, 2013 1989 njensen Deprecated
*
* </pre>
*
@ -48,6 +51,7 @@ import org.apache.camel.util.ServiceHelper;
*/
@SuppressWarnings("unchecked")
@Deprecated
public class DirectVMComponent extends DirectComponent {
private static Map<String, CopyOnWriteArrayList<DefaultConsumer>> CONSUMERS = new HashMap<String, CopyOnWriteArrayList<DefaultConsumer>>();
@ -78,8 +82,9 @@ public class DirectVMComponent extends DirectComponent {
protected void doStop() throws Exception {
Collection<CopyOnWriteArrayList<DefaultConsumer>> set = CONSUMERS
.values();
/* Stop only the consumers created through this instance of the
/*
* Stop only the consumers created through this instance of the
* component.
*/
for (CopyOnWriteArrayList<DefaultConsumer> consumerList : set)

6
edexOsgi/com.raytheon.uf.edex.esb.camel/src/com/raytheon/uf/edex/esb/camel/directvm/DirectVMEndpoint.java
View file

@ -28,7 +28,9 @@ import org.apache.camel.component.direct.DirectEndpoint;
import org.apache.camel.impl.DefaultConsumer;
/**
* Provides a cross-context synchronous component
* Provides a cross-context synchronous component. Deprecated: Use camel's
* built-in direct-vm component instead. This component can be deleted after
* that has been tested thoroughly.
*
* <pre>
*
@ -38,6 +40,7 @@ import org.apache.camel.impl.DefaultConsumer;
* Nov 18, 2008 chammack Initial creation
* Jul 16, 2012 DR 15073 D. Friedman Override correct methods
* May 09, 2013 1989 njensen Camel 2.11 compatibility
* May 23, 2013 1989 njensen Deprecated
*
* </pre>
*
@ -45,6 +48,7 @@ import org.apache.camel.impl.DefaultConsumer;
* @version 1.0
*/
@Deprecated
public class DirectVMEndpoint extends DirectEndpoint {
private boolean allowMultipleConsumers = true;

19
edexOsgi/com.raytheon.uf.edex.esb.camel/src/com/raytheon/uf/edex/esb/camel/directvm/DirectVMProducer.java
View file

@ -35,7 +35,9 @@ import com.raytheon.uf.common.status.UFStatus;
import com.raytheon.uf.common.status.UFStatus.Priority;
/**
* Direct VM Producer used with DirectVMConsumer
* Direct VM Producer used with DirectVMConsumer. Deprecated: Use camel's
* built-in direct-vm component instead. This component can be deleted after
* that has been tested thoroughly.
*
* <pre>
*
@ -44,6 +46,7 @@ import com.raytheon.uf.common.status.UFStatus.Priority;
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Oct 27, 2010 mschenke Initial creation
* May 23, 2013 1989 njensen Deprecated
*
* </pre>
*
@ -51,8 +54,10 @@ import com.raytheon.uf.common.status.UFStatus.Priority;
* @version 1.0
*/
@Deprecated
public class DirectVMProducer extends DirectProducer {
private static final transient IUFStatusHandler statusHandler = UFStatus.getHandler(DirectVMProducer.class);
private static final transient IUFStatusHandler statusHandler = UFStatus
.getHandler(DirectVMProducer.class);
private DirectVMEndpoint endpoint;
@ -67,8 +72,9 @@ public class DirectVMProducer extends DirectProducer {
public void process(Exchange exchange) throws Exception {
List<DefaultConsumer> consumers = endpoint.getConsumers();
if (consumers == null || consumers.size() == 0) {
statusHandler.handle(Priority.PROBLEM, "No consumers available on endpoint: "
+ endpoint + " to process: " + exchange);
statusHandler.handle(Priority.PROBLEM,
"No consumers available on endpoint: " + endpoint
+ " to process: " + exchange);
throw new CamelExchangeException(
"No consumers available on endpoint: " + endpoint, exchange);
} else {
@ -81,8 +87,9 @@ public class DirectVMProducer extends DirectProducer {
public boolean process(Exchange exchange, AsyncCallback callback) {
List<DefaultConsumer> consumers = endpoint.getConsumers();
if (consumers == null || consumers.size() == 0) {
statusHandler.handle(Priority.PROBLEM, "No consumers available on endpoint: "
+ endpoint + " to process: " + exchange);
statusHandler.handle(Priority.PROBLEM,
"No consumers available on endpoint: " + endpoint
+ " to process: " + exchange);
// indicate its done synchronously
exchange.setException(new CamelExchangeException(
"No consumers available on endpoint: " + endpoint, exchange));

2
edexOsgi/com.raytheon.uf.edex.metartohmdbsrv/res/spring/metartohmdb-plugin.xml
View file

@ -31,7 +31,7 @@
<endpoint id="metarToHMDBEndpoint" />
<route id="metarToHMDBRoute">
<from uri="directvm:metarToHMDB"/>
<from uri="direct-vm:metarToHMDB"/>
<bean ref="metarToHMDB" method="process"/>
</route>
</camelContext>

2
edexOsgi/com.raytheon.uf.edex.ohd/res/spring/satpre-spring.xml
View file

@ -19,7 +19,7 @@
<pipeline>
<bean ref="serializationUtil" method="transformFromThrift" />
<bean ref="satPreFilter" method="matchURI"/>
<!-- <to uri="directvm:persistIndexAlert"/> -->
<!-- <to uri="direct-vm:persistIndexAlert"/> -->
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
edexOsgi/com.raytheon.uf.edex.plugin.acars/res/spring/acars-ingest.xml
View file

@ -49,8 +49,8 @@
<pipeline>
<bean ref="acarsDecoder" method="decode" />
<multicast>
<to uri="directvm:indexAlert" />
<to uri="directvm:acarsSounding" />
<to uri="direct-vm:indexAlert" />
<to uri="direct-vm:acarsSounding" />
</multicast>
</pipeline>
<doCatch>

4
edexOsgi/com.raytheon.uf.edex.plugin.acarssounding/res/spring/acarssounding-ingest.xml
View file

@ -57,7 +57,7 @@
<method bean="acarsSounding" method="getQueueTime" />
</setHeader>
<bean ref="acarsSounding" method="processSounding" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>
@ -68,7 +68,7 @@
</route>
<route id="acarsSoundingRoute">
<from uri="directvm:acarsSounding"/>
<from uri="direct-vm:acarsSounding"/>
<bean ref="acarsPersistObs" method="process" />
</route>
</camelContext>

2
edexOsgi/com.raytheon.uf.edex.plugin.bufrascat/res/spring/bufrascat-ingest.xml
View file

@ -53,7 +53,7 @@
<bean ref="stringToFile" />
<bean ref="bufrascatDecoder" method="decode" />
<bean ref="ascatSHFilter" method="filter" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.bufrhdw/res/spring/bufrhdw-ingest.xml
View file

@ -46,7 +46,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="bufrhdwDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.bufrmthdw/res/spring/bufrmthdw-ingest.xml
View file

@ -46,7 +46,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="bufrmthdwDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.bufrncwf/res/spring/bufrncwf-ingest.xml
View file

@ -45,7 +45,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="bufrncwfDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.bufrquikscat/res/spring/bufrquikscat-ingest.xml
View file

@ -53,7 +53,7 @@
<bean ref="stringToFile" />
<bean ref="bufrquikscatDecoder" method="decode" />
<bean ref="quikscatSHFilter" method="filter" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.bufrsigwx/res/spring/bufrsigwx-ingest.xml
View file

@ -47,7 +47,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="bufrsigwxDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.bufrssmi/res/spring/bufrssmi-ingest.xml
View file

@ -53,7 +53,7 @@
<bean ref="stringToFile" />
<bean ref="bufrssmiDecoder" method="decode" />
<bean ref="ssmiSHFilter" method="filter" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.cwa/res/spring/cwa-ingest.xml
View file

@ -33,7 +33,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="cwaDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.ldadmesonet/res/spring/ldadmesonet-ingest.xml
View file

@ -37,7 +37,7 @@
<bean ref="stringToFile" />
<bean ref="mesonetDecoder" method="decode" />
<bean ref="ldadmesonetPointData" method="toPointData" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.lsr/res/spring/lsr-ingest.xml
View file

@ -47,7 +47,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="lclstrmrptDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.mesowest/res/spring/mesowest-ingest.xml
View file

@ -62,7 +62,7 @@
<bean ref="stringToFile" />
<bean ref="mesowestDecoder" method="decode" />
<bean ref="mesowestFilter" method="filter" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.npp.crimss/res/spring/crimss-ingest.xml
View file

@ -33,7 +33,7 @@
<bean ref="stringToFile" />
<bean ref="extractWMOHeader" method="remove"/>
<bean ref="crimssDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.npp.nucaps/res/spring/nucaps-ingest.xml
View file

@ -33,7 +33,7 @@
<bean ref="stringToFile" />
<bean ref="extractWMOHeader" method="remove"/>
<bean ref="nucapsDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.npp.viirs/res/spring/viirs-ingest.xml
View file

@ -49,7 +49,7 @@
<bean ref="extractWMOHeader" method="remove"/>
<bean ref="dataUnzipper" method="gunzip"/>
<bean ref="viirsDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

6
edexOsgi/com.raytheon.uf.edex.plugin.qc/res/spring/qc-ingest.xml
View file

@ -21,7 +21,7 @@
autoStartup="false">
<proxy id="qcScannerTarget"
serviceInterface="com.raytheon.uf.edex.plugin.qc.IQCScannerTarget"
serviceUrl="directvm:qcToIndexAlert"/>
serviceUrl="direct-vm:qcToIndexAlert"/>
<endpoint id="scheduledQCCron" uri="clusteredquartz://qc/scanQC/?cron=${qc.cron}"/>
@ -31,14 +31,14 @@
</route>
<route id="qcToIndexAlert">
<from uri="directvm:qcToIndexAlert" />
<from uri="direct-vm:qcToIndexAlert" />
<setHeader headerName="pluginName">
<constant>qc</constant>
</setHeader>
<setHeader headerName="ingestFileName">
<simple>${body.args[0].[last].ncSet}(${body.args[0].[last].ncIndex})</simple>
</setHeader>
<to uri="directvm:indexAlert" pattern="InOnly"/>
<to uri="direct-vm:indexAlert" pattern="InOnly"/>
</route>
<route id="scheduledQCScanWork">

2
edexOsgi/com.raytheon.uf.edex.plugin.satellite.mcidas/res/spring/satellite-mcidas-ingest.xml
View file

@ -45,7 +45,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="satelliteMcidasDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.svrwx/res/spring/svrwx-ingest.xml
View file

@ -33,7 +33,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="svrwxDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.tcg/res/spring/tcg-ingest.xml
View file

@ -33,7 +33,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="tcgDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.tcs/res/spring/tcs-ingest.xml
View file

@ -33,7 +33,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="tcsDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.plugin.vaa/res/spring/vaa-ingest.xml
View file

@ -47,7 +47,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="vaaDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
edexOsgi/com.raytheon.uf.edex.textdbsrv/res/spring/textdbsrv-common.xml
View file

@ -10,7 +10,7 @@
<camelContext id="textdbsrv-common-camel" xmlns="http://camel.apache.org/schema/spring" errorHandlerRef="errorHandler">
<route id="textdbsrvinternal">
<from uri="directvm:int.textdb.request"/>
<from uri="direct-vm:int.textdb.request"/>
<bean ref="serializationUtil" method="unmarshalFromXml" />
<bean ref="textdbsrv" method="processMessage" />
<bean ref="serializationUtil" method="marshalToXml" />

2
ncep/gov.noaa.nws.ncep.edex.plugin.airmet/res/spring/airmet-ingest.xml
View file

@ -53,7 +53,7 @@
<doTry>
<pipeline>
<bean ref="airmetDecoder" method="decode"/>
<to uri="directvm:indexAlert"/>
<to uri="direct-vm:indexAlert"/>
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
ncep/gov.noaa.nws.ncep.edex.plugin.atcf/res/spring/atcf-ingest.xml
View file

@ -17,7 +17,7 @@
factory-method="getInstance" depends-on="alphaNumericDatatypePool">
<constructor-arg><value>AlphaNumeric</value></constructor-arg>
<constructor-arg><value>atcf</value></constructor-arg>
<constructor-arg><value>directvm:atcfIngest</value></constructor-arg>
<constructor-arg><value>direct-vm:atcfIngest</value></constructor-arg>
</bean> -->
<!-- class=" com.raytheon.uf.edex.distribution.DistributionSrv" -->
<bean id="atcfDistRegistry" factory-bean="distributionSrv"
@ -58,7 +58,7 @@
<doTry>
<pipeline>
<bean ref="atcfDecoder" method="decode" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
ncep/gov.noaa.nws.ncep.edex.plugin.aww/res/spring/aww-ingest.xml
View file

@ -16,7 +16,7 @@
factory-method="getInstance" depends-on="alphaNumericDatatypePool">
<constructor-arg><value>AlphaNumeric</value></constructor-arg>
<constructor-arg><value>aww</value></constructor-arg>
<constructor-arg><value>directvm:awwIngest</value></constructor-arg>
<constructor-arg><value>direct-vm:awwIngest</value></constructor-arg>
</bean-->
<bean id="awwDistRegistry" factory-bean="distributionSrv"
@ -65,7 +65,7 @@
<doTry>
<pipeline>
<bean ref="awwDecoder" method="decode"/>
<to uri="directvm:indexAlert"/>
<to uri="direct-vm:indexAlert"/>
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.convsigmet/res/spring/convsigmet-ingest.xml
View file

@ -54,7 +54,7 @@
<doTry>
<pipeline>
<bean ref="convsigmetDecoder" method="decode"/>
<to uri="directvm:indexAlert"/>
<to uri="direct-vm:indexAlert"/>
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.ffg/res/spring/ffg-ingest.xml
View file

@ -54,7 +54,7 @@
<doTry>
<pipeline>
<bean ref="ffgDecoder" method="decode"/>
<to uri="directvm:indexAlert"/>
<to uri="direct-vm:indexAlert"/>
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.geomag/res/spring/geomag-ingest.xml
View file

@ -63,7 +63,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="geomagDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.idft/res/spring/idft-ingest.xml
View file

@ -46,7 +46,7 @@
<doTry>
<pipeline>
<bean ref="idftDecoder" method="decode" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.intlsigmet/res/spring/intlsigmet-ingest.xml
View file

@ -53,7 +53,7 @@
<doTry>
<pipeline>
<bean ref="intlsigmetDecoder" method="decode"/>
<to uri="directvm:indexAlert"/>
<to uri="direct-vm:indexAlert"/>
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
ncep/gov.noaa.nws.ncep.edex.plugin.mcidas/res/spring/mcidas-ingest.xml
View file

@ -17,7 +17,7 @@
factory-method="getInstance" depends-on="alphaNumericDatatypePool">
<constructor-arg><value>AlphaNumeric</value></constructor-arg>
<constructor-arg><value>mcidas</value></constructor-arg>
<constructor-arg><value>directvm:mcidasIngest</value></constructor-arg>
<constructor-arg><value>direct-vm:mcidasIngest</value></constructor-arg>
</bean-->
<bean id="mcidasRegistry" factory-bean="distributionSrv"
@ -53,7 +53,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="mcidasDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
ncep/gov.noaa.nws.ncep.edex.plugin.mosaic/res/spring/mosaic-ingest.xml
View file

@ -24,7 +24,7 @@
<value>mosaic</value>
</constructor-arg>
<constructor-arg>
<value>directvm:mosaicIngest</value>
<value>direct-vm:mosaicIngest</value>
</constructor-arg>
</bean>
@ -56,7 +56,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="mosaicDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
ncep/gov.noaa.nws.ncep.edex.plugin.ncairep/res/spring/ncairep-ingest.xml
View file

@ -57,8 +57,8 @@
<!-- Add next line for h5 version and change next
line from indexAlert to persistIndexAlert" /-->
<bean ref="ncairepPointData" method="toPointData" />
<!-- to uri="directvm:indexAlert" /-->
<to uri="directvm:persistIndexAlert" />
<!-- to uri="direct-vm:indexAlert" /-->
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.ncccfp/res/spring/ncccfp-ingest.xml
View file

@ -50,7 +50,7 @@
<doTry>
<pipeline>
<bean ref="ncccfpDecoder" method="decode" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

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

@ -85,7 +85,7 @@
<bean ref="index" method="index" />
<bean ref="ncgridAssembler" method="process"/>
<multicast parallelProcessing="false">
<to uri="directvm:ncgribIngestAlert" />
<to uri="direct-vm:ncgribIngestAlert" />
<to uri="vm:ncgribNotification" />
</multicast>
</pipeline>
@ -100,7 +100,7 @@
</route>
<route id="ncgribIngestAlert">
<from uri="directvm:ncgribIngestAlert" />
<from uri="direct-vm:ncgribIngestAlert" />
<bean ref="toDataURI" method="toDataURI" />
<bean ref="processUtil" method="log" />
<to uri="vm:stageNotification" />

4
ncep/gov.noaa.nws.ncep.edex.plugin.ncpafm/res/spring/ncpafm-ingest.xml
View file

@ -59,8 +59,8 @@
<bean ref="ncpafmDecoder" method="decode" />
<!-- Add next line for h5 version /-->
<bean ref="ncpafmPointDataTransform" method="toPointData" />
<!--to uri="directvm:indexAlert" /-->
<to uri="directvm:persistIndexAlert" />
<!--to uri="direct-vm:indexAlert" /-->
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
ncep/gov.noaa.nws.ncep.edex.plugin.ncpirep/res/spring/ncpirep-ingest.xml
View file

@ -63,8 +63,8 @@
<!-- Add next line for h5 version and change next
line from indexAlert to persistIndexAlert" /-->
<bean ref="ncpirepPointData" method="toPointData" />
<!-- to uri="directvm:indexAlert" /-->
<to uri="directvm:persistIndexAlert" />
<!-- to uri="direct-vm:indexAlert" /-->
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.ncscat/res/spring/ncscat-ingest.xml
View file

@ -57,7 +57,7 @@
need to replace the method decode with decodeNcscatInputFile
<bean ref="ncscatDecoder" method="decode" /> -->
<bean ref="ncscatDecoder" method="decodeNcscatInputFile" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
ncep/gov.noaa.nws.ncep.edex.plugin.ncscd/res/spring/ncscd-ingest.xml
View file

@ -18,7 +18,7 @@
<!-- bean id="ncscdRegistry" class=" com.raytheon.uf.edex.esb.camel.BasicThreadPoolRouter"
factory-method="getInstance" depends-on="alphaNumericDatatypePool"> <constructor-arg><value>AlphaNumeric</value></constructor-arg>
<constructor-arg><value>ncscd</value></constructor-arg> <constructor-arg><value>directvm:ncscdIngest</value></constructor-arg>
<constructor-arg><value>ncscd</value></constructor-arg> <constructor-arg><value>direct-vm:ncscdIngest</value></constructor-arg>
</bean -->
<bean id="ncscdDistRegistry" factory-bean="distributionSrv"
@ -61,7 +61,7 @@
<pipeline>
<bean ref="ncscdDecoder" method="decode" />
<bean ref="ncscdPointData" method="toPointData" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.nctaf/res/spring/nctaf-ingest.xml
View file

@ -53,7 +53,7 @@
<pipeline>
<bean ref="nctafDecoder" method="decode" />
<bean ref="nctafToPointData" method="toPointData" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.nctext/res/spring/nctext-ingest.xml
View file

@ -51,7 +51,7 @@
<!-- bean ref="nctextDecoderSbn" method="decodeTextInputFile" /-->
<multicast>
<!-- to uri="activemq:queue:watchwarn" /-->
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</multicast>
</pipeline>
<doCatch>

2
ncep/gov.noaa.nws.ncep.edex.plugin.ncuair/res/spring/ncuair-ingest.xml
View file

@ -58,7 +58,7 @@
<!-- chin bean ref="ncuairDecoder" method="decode" /-->
<bean ref="ncuairDecoder" method="decodeBatch" />
<bean ref="ncuairToPointData" method="toPointData" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.nonconvsigmet/res/spring/nonconvsigmet-ingest.xml
View file

@ -54,7 +54,7 @@
<doTry>
<pipeline>
<bean ref="nonconvsigmetDecoder" method="decode"/>
<to uri="directvm:indexAlert"/>
<to uri="direct-vm:indexAlert"/>
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.ntrans/res/spring/ntrans-ingest.xml
View file

@ -57,7 +57,7 @@
need to replace the method decode with decodeNtransMetafile
<bean ref="ntransDecoder" method="decode" /> -->
<bean ref="ntransDecoder" method="decodeNtransMetafile" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.sgwh/res/spring/sgwh-ingest.xml
View file

@ -54,7 +54,7 @@
<bean ref="stringToFile" />
<bean ref="sgwhDecoder" method="decode" />
<bean ref="sgwhToPointData" method="toPointData" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.sgwhv/res/spring/sgwhv-ingest.xml
View file

@ -54,7 +54,7 @@
<bean ref="stringToFile" />
<bean ref="sgwhvDecoder" method="decode" />
<bean ref="swghvToPointData" method="toPointData" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.solarimage/res/spring/solarimage-ingest.xml
View file

@ -66,7 +66,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="solarimageDecoder" method="decode" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.ssha/res/spring/ssha-ingest.xml
View file

@ -55,7 +55,7 @@
<bean ref="stringToFile" />
<bean ref="sshaDecoder" method="decode" />
<bean ref="sshaToPointData" method="toPointData" />
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

4
ncep/gov.noaa.nws.ncep.edex.plugin.stormtrack/res/spring/stormtrack-ingest.xml
View file

@ -17,7 +17,7 @@
factory-method="getInstance" depends-on="alphaNumericDatatypePool">
<constructor-arg><value>AlphaNumeric</value></constructor-arg>
<constructor-arg><value>stormTrack</value></constructor-arg>
<constructor-arg><value>directvm:stormTrackIngest</value></constructor-arg>
<constructor-arg><value>direct-vm:stormTrackIngest</value></constructor-arg>
</bean> -->
<!-- class=" com.raytheon.uf.edex.distribution.DistributionSrv" -->
<bean id="stormTrackDistRegistry" factory-bean="distributionSrv"
@ -58,7 +58,7 @@
<doTry>
<pipeline>
<bean ref="stormTrackDecoder" method="decode" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.tcm/res/spring/tcm-ingest.xml
View file

@ -51,7 +51,7 @@
<doTry>
<pipeline>
<bean ref="tcmDecoder" method="decode" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ncep/gov.noaa.nws.ncep.edex.plugin.wcp/res/spring/wcp-ingest.xml
View file

@ -46,7 +46,7 @@
<doTry>
<pipeline>
<bean ref="wcpDecoder" method="decode" />
<to uri="directvm:indexAlert" />
<to uri="direct-vm:indexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>

2
ost/gov.noaa.nws.ost.edex.plugin.regionalsat/res/spring/regionalsat-ingest.xml
View file

@ -51,7 +51,7 @@
<pipeline>
<bean ref="stringToFile" />
<bean ref="regionalSatDecoder" method="decode"/>
<to uri="directvm:persistIndexAlert" />
<to uri="direct-vm:persistIndexAlert" />
</pipeline>
<doCatch>
<exception>java.lang.Throwable</exception>