diff --git a/cave/com.raytheon.viz.warngen/src/com/raytheon/viz/warngen/comm/WarningSender.java b/cave/com.raytheon.viz.warngen/src/com/raytheon/viz/warngen/comm/WarningSender.java
index 868dd9241b..53e963aaeb 100644
--- a/cave/com.raytheon.viz.warngen/src/com/raytheon/viz/warngen/comm/WarningSender.java
+++ b/cave/com.raytheon.viz.warngen/src/com/raytheon/viz/warngen/comm/WarningSender.java
@@ -28,6 +28,7 @@ import java.util.regex.Pattern;
import javax.jms.BytesMessage;
import javax.jms.Connection;
+import javax.jms.DeliveryMode;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
@@ -47,7 +48,7 @@ import com.raytheon.viz.texteditor.msgs.IWarngenObserver;
import com.raytheon.viz.texteditor.util.SiteAbbreviationUtil;
/**
- * TODO Add Description
+ * Sends warning products to text workstation and text database.
*
*
*
@@ -58,6 +59,7 @@ import com.raytheon.viz.texteditor.util.SiteAbbreviationUtil;
* 01Jun2010 2187 cjeanbap Added operational mode functionality
* 02Aug2010 2187 cjeanbap Update variable/method signature to be consistent.
* 04Oct2010 7193 cjeanbap Add time-to-live value to MessageProducer.
+ * Sep 13, 2013 2368 rjpeter Set delivery mode to PERSISTENT.
*
*
* @author mschenke
@@ -65,209 +67,208 @@ import com.raytheon.viz.texteditor.util.SiteAbbreviationUtil;
*/
public class WarningSender implements IWarngenObserver {
- private static final transient IUFStatusHandler statusHandler = UFStatus
- .getHandler(WarningSender.class);
+ private static final transient IUFStatusHandler statusHandler = UFStatus
+ .getHandler(WarningSender.class);
- private String hostName = null;
+ private final String hostName = null;
- private boolean notifyError;
+ private boolean notifyError;
- private static final long MILLISECONDS_PER_SECOND = 1000;
+ private static final long MILLISECONDS_PER_SECOND = 1000;
- private static final long SECONDS_PER_MINUTE = 60;
+ private static final long SECONDS_PER_MINUTE = 60;
- private static final long TTL_MINUTES = 5;
+ private static final long TTL_MINUTES = 5;
- private static Pattern PATTERN = Pattern.compile("(\\d{1,1})");
+ private static Pattern PATTERN = Pattern.compile("(\\d{1,1})");
- private static final SimpleDateFormat sdf;
+ private static final SimpleDateFormat sdf;
- static {
- sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
- sdf.setTimeZone(TimeZone.getTimeZone("GMT"));
- }
+ static {
+ sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
+ sdf.setTimeZone(TimeZone.getTimeZone("GMT"));
+ }
- /*
- * (non-Javadoc) Incoming message was not a binary
- *
- * @see
- * com.raytheon.viz.texteditor.msgs.IWarngenObserver#setTextWarngenDisplay
- * (java.lang.String)
- */
- @Override
- public void setTextWarngenDisplay(String warning, boolean ne) {
- this.notifyError = ne;
+ /*
+ * (non-Javadoc) Incoming message was not a binary
+ *
+ * @see
+ * com.raytheon.viz.texteditor.msgs.IWarngenObserver#setTextWarngenDisplay
+ * (java.lang.String)
+ */
+ @Override
+ public void setTextWarngenDisplay(String warning, boolean ne) {
+ this.notifyError = ne;
- String number = "0";
- String host = TextWorkstationConstants.getId();
- long t0 = System.currentTimeMillis();
- String siteNode = SiteAbbreviationUtil.getSiteNode(LocalizationManager
- .getInstance().getCurrentSite());
- System.out.println("Get site node time: "
- + (System.currentTimeMillis() - t0));
- if (host == null) {
- statusHandler.handle(Priority.ERROR,
- "Text Workstation host not set in preferences.");
- } else {
- Matcher m = PATTERN.matcher(host);
- if (m.find()) {
- number = m.group();
- }
- }
+ String number = "0";
+ String host = TextWorkstationConstants.getId();
+ long t0 = System.currentTimeMillis();
+ String siteNode = SiteAbbreviationUtil.getSiteNode(LocalizationManager
+ .getInstance().getCurrentSite());
+ statusHandler.debug("Get site node time: "
+ + (System.currentTimeMillis() - t0));
+ if (host == null) {
+ statusHandler.handle(Priority.ERROR,
+ "Text Workstation host not set in preferences.");
+ } else {
+ Matcher m = PATTERN.matcher(host);
+ if (m.find()) {
+ number = m.group();
+ }
+ }
- String id = siteNode + "WRKWG" + number;
- boolean sentToTextDatabase = false;
+ String id = siteNode + "WRKWG" + number;
+ boolean sentToTextDatabase = false;
- try {
- boolean messageNotSent = true;
- int connectCount = 0;
- t0 = System.currentTimeMillis();
- byte[] data = SerializationUtil.transformToThrift(id + ":"
- + warning);
- while (messageNotSent && connectCount < 4) {
- Session s = null;
- MessageProducer mp = null;
- Connection conn = null;
- try {
- conn = JMSConnection.getInstance().getFactory()
- .createConnection();
- s = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
- mp = s.createProducer(s
- .createQueue(TextWorkstationConstants
- .getDestinationTextWorkstationQueueName()));
- mp.setTimeToLive(TTL_MINUTES * SECONDS_PER_MINUTE
- * MILLISECONDS_PER_SECOND);
- BytesMessage m = s.createBytesMessage();
- m.writeBytes(data);
- mp.send(m);
- long t1 = System.currentTimeMillis();
- System.out.println(WarningSender.getCurTimeString() + ": "
- + id + " sent to text workstation in " + (t1 - t0)
- + "ms in " + (connectCount + 1)
- + (connectCount > 0 ? " tries" : " try"));
- messageNotSent = false;
- } catch (JMSException e) {
- if (notifyError) {
- statusHandler
- .handle(Priority.PROBLEM,
- "Error trying to send product ["
- + id
- + "] to Text Workstation. Attempting to reconnect. ",
- e);
- notifyError = false;
- }
- } finally {
- if (mp != null) {
- try {
- mp.close();
- mp = null;
- } catch (Exception e) {
- mp = null;
- }
- }
- if (s != null) {
- try {
- s.close();
- s = null;
- } catch (Exception e) {
- s = null;
- }
- }
- if (conn != null) {
- try {
- conn.close();
- conn = null;
- } catch (Exception e) {
- conn = null;
- }
- }
- }
- if (messageNotSent) {
- if (!sentToTextDatabase) {
- try {
- sendToTextDatabase(id, warning);
- sentToTextDatabase = true;
- } catch (Exception e) {
- statusHandler.handle(Priority.PROBLEM,
- "Error trying to save product [" + id
- + "] to Text Database: ", e);
- }
- }
+ try {
+ boolean messageNotSent = true;
+ int connectCount = 0;
+ t0 = System.currentTimeMillis();
+ byte[] data = SerializationUtil.transformToThrift(id + ":"
+ + warning);
+ while (messageNotSent && (connectCount < 4)) {
+ Session s = null;
+ MessageProducer mp = null;
+ Connection conn = null;
+ try {
+ conn = JMSConnection.getInstance().getFactory()
+ .createConnection();
+ s = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
+ mp = s.createProducer(s
+ .createQueue(TextWorkstationConstants
+ .getDestinationTextWorkstationQueueName()));
+ mp.setTimeToLive(TTL_MINUTES * SECONDS_PER_MINUTE
+ * MILLISECONDS_PER_SECOND);
+ BytesMessage m = s.createBytesMessage();
+ m.writeBytes(data);
+ m.setJMSDeliveryMode(DeliveryMode.PERSISTENT);
+ mp.send(m);
+ long t1 = System.currentTimeMillis();
+ statusHandler.debug(id + " sent to text workstation in "
+ + (t1 - t0) + "ms in " + (connectCount + 1)
+ + (connectCount > 0 ? " tries" : " try"));
+ messageNotSent = false;
+ } catch (JMSException e) {
+ if (notifyError) {
+ statusHandler
+ .handle(Priority.PROBLEM,
+ "Error trying to send product ["
+ + id
+ + "] to Text Workstation. Attempting to reconnect. ",
+ e);
+ notifyError = false;
+ }
+ } finally {
+ if (mp != null) {
+ try {
+ mp.close();
+ mp = null;
+ } catch (Exception e) {
+ mp = null;
+ }
+ }
+ if (s != null) {
+ try {
+ s.close();
+ s = null;
+ } catch (Exception e) {
+ s = null;
+ }
+ }
+ if (conn != null) {
+ try {
+ conn.close();
+ conn = null;
+ } catch (Exception e) {
+ conn = null;
+ }
+ }
+ }
+ if (messageNotSent) {
+ if (!sentToTextDatabase) {
+ try {
+ sendToTextDatabase(id, warning);
+ sentToTextDatabase = true;
+ } catch (Exception e) {
+ statusHandler.handle(Priority.PROBLEM,
+ "Error trying to save product [" + id
+ + "] to Text Database: ", e);
+ }
+ }
- connectCount++;
- switch (connectCount) {
- case 1:
- Thread.sleep(1000);
- break;
- case 2:
- Thread.sleep(5 * 1000);
- break;
- case 3:
- Thread.sleep(30 * 1000);
- break;
- case 4:
- statusHandler.handle(Priority.PROBLEM,
- "Could not reconnect (" + id
- + ") after 3 tries: ");
- break;
- }
- }
- }
+ connectCount++;
+ switch (connectCount) {
+ case 1:
+ Thread.sleep(1000);
+ break;
+ case 2:
+ Thread.sleep(5 * 1000);
+ break;
+ case 3:
+ Thread.sleep(30 * 1000);
+ break;
+ case 4:
+ statusHandler.handle(Priority.PROBLEM,
+ "Could not reconnect (" + id
+ + ") after 3 tries: ");
+ break;
+ }
+ }
+ }
- if (!sentToTextDatabase) {
- try {
- sendToTextDatabase(id, warning);
- sentToTextDatabase = true;
- } catch (Exception e) {
- statusHandler.handle(Priority.PROBLEM,
- "Error trying to save product [" + id
- + "] to Text Database: ", e);
- }
- }
- } catch (UnknownHostException uhe) {
- if (notifyError) {
- statusHandler.handle(Priority.PROBLEM,
- "unable to map hostname, " + hostName
- + ", to an ip address", uhe);
- notifyError = false;
- }
+ if (!sentToTextDatabase) {
+ try {
+ sendToTextDatabase(id, warning);
+ sentToTextDatabase = true;
+ } catch (Exception e) {
+ statusHandler.handle(Priority.PROBLEM,
+ "Error trying to save product [" + id
+ + "] to Text Database: ", e);
+ }
+ }
+ } catch (UnknownHostException uhe) {
+ if (notifyError) {
+ statusHandler.handle(Priority.PROBLEM,
+ "unable to map hostname, " + hostName
+ + ", to an ip address", uhe);
+ notifyError = false;
+ }
- } catch (Exception e) {
- statusHandler.handle(Priority.PROBLEM,
- "Error trying to send product [" + id
- + "] to Text Workstation: ", e);
- }
+ } catch (Exception e) {
+ statusHandler.handle(Priority.PROBLEM,
+ "Error trying to send product [" + id
+ + "] to Text Workstation: ", e);
+ }
- }
+ }
- /**
- * Saves a product to the text database.
- *
- * @param id
- * @param warning
- * @throws VizException
- */
- public static void sendToTextDatabase(String id, String warning)
- throws VizException {
- CAVEMode mode = CAVEMode.getMode();
- boolean operationalMode = (CAVEMode.OPERATIONAL.equals(mode)
- || CAVEMode.TEST.equals(mode) ? true : false);
+ /**
+ * Saves a product to the text database.
+ *
+ * @param id
+ * @param warning
+ * @throws VizException
+ */
+ public static void sendToTextDatabase(String id, String warning)
+ throws VizException {
+ CAVEMode mode = CAVEMode.getMode();
+ boolean operationalMode = (CAVEMode.OPERATIONAL.equals(mode)
+ || CAVEMode.TEST.equals(mode) ? true : false);
- // Generate StdTextProduct and insert into db
- long t0 = System.currentTimeMillis();
- ThriftClient.sendRequest(new InsertStdTextProductRequest(id, warning,
- operationalMode));
+ // Generate StdTextProduct and insert into db
+ long t0 = System.currentTimeMillis();
+ ThriftClient.sendRequest(new InsertStdTextProductRequest(id, warning,
+ operationalMode));
- System.out.println(WarningSender.getCurTimeString() + ": " + id
- + " saved to textdb in " + (System.currentTimeMillis() - t0)
- + "ms");
- }
+ statusHandler.debug(id + " saved to textdb in "
+ + (System.currentTimeMillis() - t0) + "ms");
+ }
- public static String getCurTimeString() {
- String rval = null;
- synchronized (sdf) {
- rval = sdf.format(new Date());
- }
- return rval;
- }
+ public static String getCurTimeString() {
+ String rval = null;
+ synchronized (sdf) {
+ rval = sdf.format(new Date());
+ }
+ return rval;
+ }
}
diff --git a/edexOsgi/build.edex/esb/conf/spring/edex.xml b/edexOsgi/build.edex/esb/conf/spring/edex.xml
index 546d3abf49..275133fb82 100644
--- a/edexOsgi/build.edex/esb/conf/spring/edex.xml
+++ b/edexOsgi/build.edex/esb/conf/spring/edex.xml
@@ -40,8 +40,19 @@
+
+
+
+
+
+ factory-bean="jmsConfig" factory-method="copy"/>
+
+
+
+
+
@@ -71,6 +82,7 @@
+
-
+
diff --git a/edexOsgi/com.raytheon.edex.autobldsrv/res/spring/subscription-spring.xml b/edexOsgi/com.raytheon.edex.autobldsrv/res/spring/subscription-spring.xml
index c7050e3009..cdf139c5bf 100644
--- a/edexOsgi/com.raytheon.edex.autobldsrv/res/spring/subscription-spring.xml
+++ b/edexOsgi/com.raytheon.edex.autobldsrv/res/spring/subscription-spring.xml
@@ -50,7 +50,7 @@
-
+
diff --git a/edexOsgi/com.raytheon.edex.ingestsrv/res/spring/persist-ingest.xml b/edexOsgi/com.raytheon.edex.ingestsrv/res/spring/persist-ingest.xml
index ca32da1f75..23ffbb0dcc 100644
--- a/edexOsgi/com.raytheon.edex.ingestsrv/res/spring/persist-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.ingestsrv/res/spring/persist-ingest.xml
@@ -76,7 +76,7 @@
-
+
diff --git a/edexOsgi/com.raytheon.edex.plugin.airep/res/spring/airep-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.airep/res/spring/airep-ingest.xml
index 3fa5094f14..a757baaf8e 100644
--- a/edexOsgi/com.raytheon.edex.plugin.airep/res/spring/airep-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.airep/res/spring/airep-ingest.xml
@@ -12,7 +12,7 @@
-
+
airep
-
+
-->
-
+
airep
diff --git a/edexOsgi/com.raytheon.edex.plugin.binlightning/res/spring/binlightning_ep-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.binlightning/res/spring/binlightning_ep-ingest.xml
index 22f5fb05ea..0e28d3357b 100644
--- a/edexOsgi/com.raytheon.edex.plugin.binlightning/res/spring/binlightning_ep-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.binlightning/res/spring/binlightning_ep-ingest.xml
@@ -9,7 +9,7 @@
-
+
binlightning
-
+
-->
-
+
binlightning
diff --git a/edexOsgi/com.raytheon.edex.plugin.bufrmos/res/spring/bufrmos-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.bufrmos/res/spring/bufrmos-ingest.xml
index 656b35ba9b..90ea632604 100644
--- a/edexOsgi/com.raytheon.edex.plugin.bufrmos/res/spring/bufrmos-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.bufrmos/res/spring/bufrmos-ingest.xml
@@ -8,7 +8,7 @@
-
+
bufrmos
-
+
-->
-
+
bufrmos
diff --git a/edexOsgi/com.raytheon.edex.plugin.bufrua/res/spring/bufrua-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.bufrua/res/spring/bufrua-ingest.xml
index 4b2643dff6..df4ddcd80c 100644
--- a/edexOsgi/com.raytheon.edex.plugin.bufrua/res/spring/bufrua-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.bufrua/res/spring/bufrua-ingest.xml
@@ -32,13 +32,13 @@
bufrua
-
+
-->
-
+
bufrua
diff --git a/edexOsgi/com.raytheon.edex.plugin.ccfp/res/spring/ccfp-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.ccfp/res/spring/ccfp-ingest.xml
index bca9b008bb..a13ea2bad9 100644
--- a/edexOsgi/com.raytheon.edex.plugin.ccfp/res/spring/ccfp-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.ccfp/res/spring/ccfp-ingest.xml
@@ -29,13 +29,13 @@
ccfp
-
+
-->
-
+
ccfp
diff --git a/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-common.xml b/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-common.xml
index 9035319bc5..0d8633aa53 100644
--- a/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-common.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-common.xml
@@ -55,7 +55,7 @@
errorHandlerRef="errorHandler">
-
+
@@ -72,7 +72,7 @@
-
+
java.lang.Throwable
@@ -87,7 +87,7 @@
-
+
diff --git a/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-request.xml b/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-request.xml
index b1b68a4994..d4a6b8d09e 100644
--- a/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-request.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-request.xml
@@ -461,11 +461,9 @@
-
+
-
@@ -487,11 +485,9 @@
-
+
-
@@ -623,7 +619,7 @@
-
+
@@ -643,7 +639,7 @@
errorHandlerRef="errorHandler" autoStartup="false">
-
+
diff --git a/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-spring.xml b/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-spring.xml
index c2c87fd5bf..6eb027af7c 100644
--- a/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-spring.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.gfe/res/spring/gfe-spring.xml
@@ -5,11 +5,9 @@
-
+
-
@@ -40,7 +38,7 @@
xmlns="http://camel.apache.org/schema/spring"
errorHandlerRef="errorHandler">
-
+
@@ -51,7 +49,7 @@
-
+
@@ -78,7 +76,7 @@
-
+
@@ -117,9 +115,9 @@
-
+
-
+
java.lang.Throwable
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/edexOsgi/com.raytheon.edex.plugin.gfe/src/com/raytheon/edex/plugin/gfe/config/GFESiteActivation.java b/edexOsgi/com.raytheon.edex.plugin.gfe/src/com/raytheon/edex/plugin/gfe/config/GFESiteActivation.java
index ac19cd6994..106c4fd65f 100644
--- a/edexOsgi/com.raytheon.edex.plugin.gfe/src/com/raytheon/edex/plugin/gfe/config/GFESiteActivation.java
+++ b/edexOsgi/com.raytheon.edex.plugin.gfe/src/com/raytheon/edex/plugin/gfe/config/GFESiteActivation.java
@@ -88,7 +88,7 @@ import com.raytheon.uf.edex.site.notify.SendSiteActivationNotifications;
* activation.
* Mar 20, 2013 #1774 randerso Changed to use GFED2DDao
* May 02, 2013 #1969 randerso Moved updateDbs method into IFPGridDatabase
- *
+ * Sep 13, 2013 2368 rjpeter Used durable jms settings.
*
*
* @author njensen
@@ -115,7 +115,7 @@ public class GFESiteActivation implements ISiteActivationListener {
private boolean intialized = false;
- private ExecutorService postActivationTaskExecutor = MoreExecutors
+ private final ExecutorService postActivationTaskExecutor = MoreExecutors
.getExitingExecutorService((ThreadPoolExecutor) Executors
.newCachedThreadPool());
@@ -356,7 +356,7 @@ public class GFESiteActivation implements ISiteActivationListener {
GridDatabase db = GridParmManager.getDb(dbid);
// cluster locked since IFPGridDatabase can modify the grids
// based on changes to grid size, etc
- if (db instanceof IFPGridDatabase && db.databaseIsValid()) {
+ if ((db instanceof IFPGridDatabase) && db.databaseIsValid()) {
((IFPGridDatabase) db).updateDbs();
}
}
@@ -410,7 +410,7 @@ public class GFESiteActivation implements ISiteActivationListener {
long startTime = System.currentTimeMillis();
// wait for system startup or at least 3 minutes
while (!EDEXUtil.isRunning()
- || System.currentTimeMillis() > startTime + 180000) {
+ || (System.currentTimeMillis() > (startTime + 180000))) {
try {
Thread.sleep(15000);
} catch (InterruptedException e) {
@@ -420,7 +420,7 @@ public class GFESiteActivation implements ISiteActivationListener {
ClusterTask ct = ClusterLockUtils.lookupLock(TASK_NAME,
SMART_INIT_TASK_DETAILS + siteID);
- if (ct.getLastExecution() + SMART_INIT_TIMEOUT < System
+ if ((ct.getLastExecution() + SMART_INIT_TIMEOUT) < System
.currentTimeMillis()) {
ct = ClusterLockUtils.lock(TASK_NAME,
SMART_INIT_TASK_DETAILS + siteID,
@@ -467,7 +467,7 @@ public class GFESiteActivation implements ISiteActivationListener {
"Firing smartinit for " + id);
try {
producer.sendAsyncUri(
- "jms-generic:queue:manualSmartInit",
+ "jms-durable:queue:manualSmartInit",
id
+ ":0::"
+ SmartInitRecord.SITE_ACTIVATION_INIT_PRIORITY);
@@ -499,7 +499,7 @@ public class GFESiteActivation implements ISiteActivationListener {
long startTime = System.currentTimeMillis();
// wait for system startup or at least 3 minutes
while (!EDEXUtil.isRunning()
- || System.currentTimeMillis() > startTime + 180000) {
+ || (System.currentTimeMillis() > (startTime + 180000))) {
try {
Thread.sleep(15000);
} catch (InterruptedException e) {
diff --git a/edexOsgi/com.raytheon.edex.plugin.gfe/src/com/raytheon/edex/plugin/gfe/server/handler/SmartInitRequestHandler.java b/edexOsgi/com.raytheon.edex.plugin.gfe/src/com/raytheon/edex/plugin/gfe/server/handler/SmartInitRequestHandler.java
index 3492acf6d8..8a57825302 100644
--- a/edexOsgi/com.raytheon.edex.plugin.gfe/src/com/raytheon/edex/plugin/gfe/server/handler/SmartInitRequestHandler.java
+++ b/edexOsgi/com.raytheon.edex.plugin.gfe/src/com/raytheon/edex/plugin/gfe/server/handler/SmartInitRequestHandler.java
@@ -35,7 +35,7 @@ import com.raytheon.uf.common.serialization.comm.IRequestHandler;
import com.raytheon.uf.edex.core.EDEXUtil;
/**
- * TODO Add Description
+ * Handler for SmartInitRequest.
*
*
*
@@ -43,7 +43,7 @@ import com.raytheon.uf.edex.core.EDEXUtil;
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Oct 12, 2010 dgilling Initial creation
- *
+ * Sep 13, 2013 2368 rjpeter Used durable jms settings.
*
*
* @author dgilling
@@ -93,7 +93,7 @@ public class SmartInitRequestHandler implements
.append(SmartInitRecord.MANUAL_SMART_INIT_PRIORITY);
EDEXUtil.getMessageProducer().sendAsyncUri(
- "jms-generic:queue:manualSmartInit",
+ "jms-durable:queue:manualSmartInit",
manualInitString.toString());
} else {
sr.addMessage("No valid model data could be retrieved for model "
diff --git a/edexOsgi/com.raytheon.edex.plugin.goessounding/res/spring/goessounding-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.goessounding/res/spring/goessounding-ingest.xml
index ea38fe8764..25158070e6 100644
--- a/edexOsgi/com.raytheon.edex.plugin.goessounding/res/spring/goessounding-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.goessounding/res/spring/goessounding-ingest.xml
@@ -12,7 +12,7 @@
-
+
goessounding
-
+
-->
-
+
goessounding
diff --git a/edexOsgi/com.raytheon.edex.plugin.grib/res/spring.deprecated/grib-decode.xml b/edexOsgi/com.raytheon.edex.plugin.grib/res/spring.deprecated/grib-decode.xml
index efa2bd86a0..d3d378a061 100644
--- a/edexOsgi/com.raytheon.edex.plugin.grib/res/spring.deprecated/grib-decode.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.grib/res/spring.deprecated/grib-decode.xml
@@ -6,14 +6,10 @@
-
+
-
-
-
@@ -58,7 +54,7 @@
autoStartup="false">
-
+
diff --git a/edexOsgi/com.raytheon.edex.plugin.grib/res/spring.future/grib-decode.xml b/edexOsgi/com.raytheon.edex.plugin.grib/res/spring.future/grib-decode.xml
index 19236c7b3d..520ba0f21e 100644
--- a/edexOsgi/com.raytheon.edex.plugin.grib/res/spring.future/grib-decode.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.grib/res/spring.future/grib-decode.xml
@@ -6,14 +6,10 @@
-
+
-
-
-
@@ -57,7 +53,7 @@
autoStartup="false">
-
+
diff --git a/edexOsgi/com.raytheon.edex.plugin.ldad/res/spring/ldad-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.ldad/res/spring/ldad-ingest.xml
index 3cc4285252..6c33246a98 100644
--- a/edexOsgi/com.raytheon.edex.plugin.ldad/res/spring/ldad-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.ldad/res/spring/ldad-ingest.xml
@@ -21,11 +21,11 @@
ldad
-
+
-
+
diff --git a/edexOsgi/com.raytheon.edex.plugin.ldadhydro/res/spring/ldadhydro-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.ldadhydro/res/spring/ldadhydro-ingest.xml
index ae1cc4c127..3cfd3faf96 100644
--- a/edexOsgi/com.raytheon.edex.plugin.ldadhydro/res/spring/ldadhydro-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.ldadhydro/res/spring/ldadhydro-ingest.xml
@@ -15,7 +15,7 @@
-
+
@@ -30,7 +30,7 @@
errorHandlerRef="errorHandler"
autoStartup="false">
-
+
diff --git a/edexOsgi/com.raytheon.edex.plugin.ldadmanual/res/spring/ldadmanual-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.ldadmanual/res/spring/ldadmanual-ingest.xml
index 86f2581985..9bfdd35584 100644
--- a/edexOsgi/com.raytheon.edex.plugin.ldadmanual/res/spring/ldadmanual-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.ldadmanual/res/spring/ldadmanual-ingest.xml
@@ -14,7 +14,7 @@
-
+
-
+
diff --git a/edexOsgi/com.raytheon.edex.plugin.ldadprofiler/res/spring/ldadprofiler-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.ldadprofiler/res/spring/ldadprofiler-ingest.xml
index 18fb79835a..cdde40ba86 100644
--- a/edexOsgi/com.raytheon.edex.plugin.ldadprofiler/res/spring/ldadprofiler-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.ldadprofiler/res/spring/ldadprofiler-ingest.xml
@@ -16,7 +16,7 @@
-
+
ldadprofiler
-
+
-->
-
+
diff --git a/edexOsgi/com.raytheon.edex.plugin.modelsounding/res/spring/modelsounding-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.modelsounding/res/spring/modelsounding-ingest.xml
index d2479bf461..5a664102f7 100644
--- a/edexOsgi/com.raytheon.edex.plugin.modelsounding/res/spring/modelsounding-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.modelsounding/res/spring/modelsounding-ingest.xml
@@ -22,7 +22,7 @@
-
+
modelsounding
-
+
-->
-
+
modelsounding
diff --git a/edexOsgi/com.raytheon.edex.plugin.obs/res/spring/obs-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.obs/res/spring/obs-ingest.xml
index 493be3e3cd..cd52a3a7e1 100644
--- a/edexOsgi/com.raytheon.edex.plugin.obs/res/spring/obs-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.obs/res/spring/obs-ingest.xml
@@ -14,7 +14,7 @@
-
+
obs
-
+
-->
-
+
obs
diff --git a/edexOsgi/com.raytheon.edex.plugin.pirep/res/spring/pirep-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.pirep/res/spring/pirep-ingest.xml
index 8a3bc973bd..444d2faa3f 100644
--- a/edexOsgi/com.raytheon.edex.plugin.pirep/res/spring/pirep-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.pirep/res/spring/pirep-ingest.xml
@@ -34,12 +34,12 @@
pirep
-
+
-->
-
+
pirep
diff --git a/edexOsgi/com.raytheon.edex.plugin.poessounding/res/spring/poessounding-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.poessounding/res/spring/poessounding-ingest.xml
index 431cfa949a..b82366bf4b 100644
--- a/edexOsgi/com.raytheon.edex.plugin.poessounding/res/spring/poessounding-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.poessounding/res/spring/poessounding-ingest.xml
@@ -9,7 +9,7 @@
-
+
poessounding
-
+
-->
-
+
poessounding
diff --git a/edexOsgi/com.raytheon.edex.plugin.profiler/res/spring/profiler-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.profiler/res/spring/profiler-ingest.xml
index c7023d4244..6b15f7bfe7 100644
--- a/edexOsgi/com.raytheon.edex.plugin.profiler/res/spring/profiler-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.profiler/res/spring/profiler-ingest.xml
@@ -9,7 +9,7 @@
-
+
profiler
-
+
-->
-
+
profiler
diff --git a/edexOsgi/com.raytheon.edex.plugin.radar/res/spring/radar-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.radar/res/spring/radar-ingest.xml
index 992b1ffa71..b92ddb0a07 100644
--- a/edexOsgi/com.raytheon.edex.plugin.radar/res/spring/radar-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.radar/res/spring/radar-ingest.xml
@@ -6,12 +6,9 @@
-
+
-
-
@@ -54,7 +51,7 @@
-
+
radar-sbn
@@ -62,7 +59,7 @@
-
+
radar-local
diff --git a/edexOsgi/com.raytheon.edex.plugin.recco/res/spring/recco-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.recco/res/spring/recco-ingest.xml
index ffbb96a228..2ef0c4dbe6 100644
--- a/edexOsgi/com.raytheon.edex.plugin.recco/res/spring/recco-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.recco/res/spring/recco-ingest.xml
@@ -33,13 +33,13 @@
recco
-
+
-->
-
+
recco
diff --git a/edexOsgi/com.raytheon.edex.plugin.redbook/res/spring/redbook-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.redbook/res/spring/redbook-ingest.xml
index c040dfe92c..710cbff1f2 100644
--- a/edexOsgi/com.raytheon.edex.plugin.redbook/res/spring/redbook-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.redbook/res/spring/redbook-ingest.xml
@@ -10,7 +10,7 @@
-
+
-
+
redbook
diff --git a/edexOsgi/com.raytheon.edex.plugin.satellite/res/spring/satellite-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.satellite/res/spring/satellite-ingest.xml
index 1a7cbda284..9688ea3baf 100644
--- a/edexOsgi/com.raytheon.edex.plugin.satellite/res/spring/satellite-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.satellite/res/spring/satellite-ingest.xml
@@ -4,11 +4,9 @@
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
+
-
@@ -47,13 +45,13 @@
satellite
-
+
-->
-
+
satellite
diff --git a/edexOsgi/com.raytheon.edex.plugin.sfcobs/res/spring/sfcobs-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.sfcobs/res/spring/sfcobs-ingest.xml
index 74331b1784..a8d9d8c731 100644
--- a/edexOsgi/com.raytheon.edex.plugin.sfcobs/res/spring/sfcobs-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.sfcobs/res/spring/sfcobs-ingest.xml
@@ -13,7 +13,7 @@
-
+
sfcobs
-
+
-->
-
+
sfcobs
diff --git a/edexOsgi/com.raytheon.edex.plugin.shef/res/spring/shef-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.shef/res/spring/shef-ingest.xml
index ba744a3c9a..3c88c0e2e0 100644
--- a/edexOsgi/com.raytheon.edex.plugin.shef/res/spring/shef-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.shef/res/spring/shef-ingest.xml
@@ -4,11 +4,9 @@
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
+
-
@@ -47,13 +45,13 @@
factory-method="register">
+ value="jms-dist:queue:Ingest.Shef"/>
-
+
+ uri="jms-durable:queue:Ingest.ShefManual"/>
@@ -92,7 +90,7 @@
+ uri="jms-shef:queue:Ingest.Shef"/>
shef
@@ -103,7 +101,7 @@
+ uri="jms-shef:queue:Ingest.ShefStaged"/>
shef
@@ -119,7 +117,7 @@
-
+
@@ -134,7 +132,7 @@
+ uri="jms-durable:queue:Ingest.ShefStaged"/>
@@ -155,7 +153,7 @@
+ uri="jms-shef:queue:Ingest.ShefManual"/>
shef
diff --git a/edexOsgi/com.raytheon.edex.plugin.taf/res/spring/taf-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.taf/res/spring/taf-ingest.xml
index 6fa7bc90db..fcd1df9358 100644
--- a/edexOsgi/com.raytheon.edex.plugin.taf/res/spring/taf-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.taf/res/spring/taf-ingest.xml
@@ -9,13 +9,13 @@
-
+
-
+
taf
-
+
-->
-
+
taf
@@ -69,7 +69,5 @@
-
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.edex.plugin.text/res/spring/text-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.text/res/spring/text-ingest.xml
index 7a14ef86cb..e6ea9dc3a6 100644
--- a/edexOsgi/com.raytheon.edex.plugin.text/res/spring/text-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.text/res/spring/text-ingest.xml
@@ -11,13 +11,13 @@
-
+
-
+
@@ -28,12 +28,9 @@
-
+
-
-
@@ -61,7 +58,7 @@
text
-
+
-->
@@ -115,7 +112,7 @@
-
+
text
@@ -142,7 +139,7 @@
-
+
@@ -151,7 +148,7 @@
-
+
diff --git a/edexOsgi/com.raytheon.edex.plugin.textlightning/res/spring/textlightning_ep-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.textlightning/res/spring/textlightning_ep-ingest.xml
index f4a6428e18..feb8c3a7a6 100644
--- a/edexOsgi/com.raytheon.edex.plugin.textlightning/res/spring/textlightning_ep-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.textlightning/res/spring/textlightning_ep-ingest.xml
@@ -9,7 +9,7 @@
-
+
textlightning
-
+
-->
-
+
textlightning
diff --git a/edexOsgi/com.raytheon.edex.plugin.warning/res/spring/warning-ingest.xml b/edexOsgi/com.raytheon.edex.plugin.warning/res/spring/warning-ingest.xml
index 85a08e2df5..1b863f3c9d 100644
--- a/edexOsgi/com.raytheon.edex.plugin.warning/res/spring/warning-ingest.xml
+++ b/edexOsgi/com.raytheon.edex.plugin.warning/res/spring/warning-ingest.xml
@@ -8,13 +8,13 @@
-
+
-
+
-
+
-
-
@@ -49,7 +46,7 @@
warning
-
+
-->
@@ -57,7 +54,7 @@
Warning routes
-->
-
+
warning
@@ -72,7 +69,7 @@
-
+
@@ -89,6 +86,5 @@
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.edex.activetable/res/spring/activetable-ingest.xml b/edexOsgi/com.raytheon.uf.edex.activetable/res/spring/activetable-ingest.xml
index 83a30388cb..0d6e84d11e 100644
--- a/edexOsgi/com.raytheon.uf.edex.activetable/res/spring/activetable-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.activetable/res/spring/activetable-ingest.xml
@@ -11,7 +11,7 @@
autoStartup="false">
-
+
diff --git a/edexOsgi/com.raytheon.uf.edex.cpgsrv/res/spring/cpgsrv-spring.xml b/edexOsgi/com.raytheon.uf.edex.cpgsrv/res/spring/cpgsrv-spring.xml
index 8e6590e032..69c5a9e7f6 100644
--- a/edexOsgi/com.raytheon.uf.edex.cpgsrv/res/spring/cpgsrv-spring.xml
+++ b/edexOsgi/com.raytheon.uf.edex.cpgsrv/res/spring/cpgsrv-spring.xml
@@ -30,9 +30,9 @@
-
-
-
+
+
+
java.lang.Throwable
@@ -42,7 +42,7 @@
-
+
diff --git a/edexOsgi/com.raytheon.uf.edex.datadelivery.bandwidth/res/spring/bandwidth-datadelivery-edex-impl.xml b/edexOsgi/com.raytheon.uf.edex.datadelivery.bandwidth/res/spring/bandwidth-datadelivery-edex-impl.xml
index 82c5961d31..290cab7094 100644
--- a/edexOsgi/com.raytheon.uf.edex.datadelivery.bandwidth/res/spring/bandwidth-datadelivery-edex-impl.xml
+++ b/edexOsgi/com.raytheon.uf.edex.datadelivery.bandwidth/res/spring/bandwidth-datadelivery-edex-impl.xml
@@ -54,7 +54,7 @@
+ uri="jms-durable:queue:matureSubscriptions"/>
diff --git a/edexOsgi/com.raytheon.uf.edex.datadelivery.event/res/spring/event-datadelivery-ingest.xml b/edexOsgi/com.raytheon.uf.edex.datadelivery.event/res/spring/event-datadelivery-ingest.xml
index b46677e860..6b0bf48923 100644
--- a/edexOsgi/com.raytheon.uf.edex.datadelivery.event/res/spring/event-datadelivery-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.datadelivery.event/res/spring/event-datadelivery-ingest.xml
@@ -6,7 +6,7 @@
+ value="jms-generic:topic:notify.msg"/>
diff --git a/edexOsgi/com.raytheon.uf.edex.datadelivery.harvester/res/spring/harvester-datadelivery.xml b/edexOsgi/com.raytheon.uf.edex.datadelivery.harvester/res/spring/harvester-datadelivery.xml
index a08888d46f..15d153514a 100644
--- a/edexOsgi/com.raytheon.uf.edex.datadelivery.harvester/res/spring/harvester-datadelivery.xml
+++ b/edexOsgi/com.raytheon.uf.edex.datadelivery.harvester/res/spring/harvester-datadelivery.xml
@@ -2,13 +2,8 @@
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">
-
-
-
-
-
+
@@ -29,11 +24,11 @@
errorHandlerRef="errorHandler">
-
+
-
+
diff --git a/edexOsgi/com.raytheon.uf.edex.dissemination/res/spring/dissemination-request.xml b/edexOsgi/com.raytheon.uf.edex.dissemination/res/spring/dissemination-request.xml
index 592aad665e..4c6ca44914 100644
--- a/edexOsgi/com.raytheon.uf.edex.dissemination/res/spring/dissemination-request.xml
+++ b/edexOsgi/com.raytheon.uf.edex.dissemination/res/spring/dissemination-request.xml
@@ -34,12 +34,12 @@
a new route and use moveFileToArchive -->
+ uri="jms-durable:queue:Ingest.handleoup"/>
+ uri="jms-durable:queue:handleoup.dropbox"/>
java.lang.Throwable
-
+
+
-
-
@@ -29,7 +27,7 @@
-
+
@@ -40,7 +38,7 @@
-
+
@@ -51,7 +49,7 @@
-
+
diff --git a/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/DPADecoder-spring.xml b/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/DPADecoder-spring.xml
index 4d75a6d347..e5e7eff311 100644
--- a/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/DPADecoder-spring.xml
+++ b/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/DPADecoder-spring.xml
@@ -9,13 +9,13 @@
-
+
-
+
dpa
-
+
-->
-
+
dpa
@@ -55,6 +55,5 @@
-
\ No newline at end of file
diff --git a/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/arealffgGenerator-spring.xml b/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/arealffgGenerator-spring.xml
index bf202ee202..1f19aed7ac 100644
--- a/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/arealffgGenerator-spring.xml
+++ b/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/arealffgGenerator-spring.xml
@@ -31,14 +31,14 @@
arealffg
-
+
-->
-
+
dhr
@@ -47,7 +47,7 @@
errorHandlerRef="errorHandler">
-
+
diff --git a/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/q2FileProcessor-spring.xml b/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/q2FileProcessor-spring.xml
index 0a6b8311c5..4c90c7a7f8 100644
--- a/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/q2FileProcessor-spring.xml
+++ b/edexOsgi/com.raytheon.uf.edex.ohd/res/spring/q2FileProcessor-spring.xml
@@ -8,7 +8,7 @@
-
+
-
+
diff --git a/edexOsgi/com.raytheon.uf.edex.ohd/src/com/raytheon/uf/edex/ohd/pproc/HPEDhrSrv.java b/edexOsgi/com.raytheon.uf.edex.ohd/src/com/raytheon/uf/edex/ohd/pproc/HPEDhrSrv.java
index 0c2b467dd2..bcdd7a2d1e 100644
--- a/edexOsgi/com.raytheon.uf.edex.ohd/src/com/raytheon/uf/edex/ohd/pproc/HPEDhrSrv.java
+++ b/edexOsgi/com.raytheon.uf.edex.ohd/src/com/raytheon/uf/edex/ohd/pproc/HPEDhrSrv.java
@@ -49,12 +49,12 @@ import com.raytheon.uf.edex.ohd.MainMethod;
* SOFTWARE HISTORY
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
- * Jan 20, 2010 4200 snaples Initial creation
- * Mar 09, 2012 417 dgilling Refactor to use two-stage queue
+ * Jan 20, 2010 4200 snaples Initial creation
+ * Mar 09, 2012 417 dgilling Refactor to use two-stage queue
* process.
* Mar 20, 2013 1804 bsteffen Switch all radar decompressing to be in
* memory.
- *
+ * Sep 13, 2013 2368 rjpeter Updated to use durable jms settings.
*
*
* @author snaples
@@ -92,9 +92,9 @@ public class HPEDhrSrv {
private static final int DT_IDX = 2;
- private static final String JMS_QUEUE_URI = "jms-generic:queue:dhrProcess";
+ private static final String JMS_QUEUE_URI = "jms-durable:queue:dhrProcess";
- private AppsDefaults appsDefaults = AppsDefaults.getInstance();
+ private final AppsDefaults appsDefaults = AppsDefaults.getInstance();
/**
* Route endpoint for "dhrIngestRoute". Takes a message, writes the file to
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.acars/res/spring/acars-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.acars/res/spring/acars-ingest.xml
index 1fdc32f63e..3970913f1b 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.acars/res/spring/acars-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.acars/res/spring/acars-ingest.xml
@@ -10,7 +10,7 @@
-
+
acars
-
+
-->
-
+
acars
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.bufrascat/res/spring/bufrascat-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.bufrascat/res/spring/bufrascat-ingest.xml
index 7b06593774..555e481851 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.bufrascat/res/spring/bufrascat-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.bufrascat/res/spring/bufrascat-ingest.xml
@@ -37,13 +37,13 @@
bufrascat
-
+
-->
-
+
bufrascat
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.bufrhdw/res/spring/bufrhdw-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.bufrhdw/res/spring/bufrhdw-ingest.xml
index 6ec50ec4c1..13c2a92577 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.bufrhdw/res/spring/bufrhdw-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.bufrhdw/res/spring/bufrhdw-ingest.xml
@@ -10,7 +10,7 @@
-
+
bufrhdw
-
+
-->
-
+
bufrhdw
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.bufrmthdw/res/spring/bufrmthdw-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.bufrmthdw/res/spring/bufrmthdw-ingest.xml
index f9ac6f6360..4e14275afa 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.bufrmthdw/res/spring/bufrmthdw-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.bufrmthdw/res/spring/bufrmthdw-ingest.xml
@@ -10,7 +10,7 @@
-
+
bufrmthdw
-
+
-->
-
+
bufrmthdw
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.bufrncwf/res/spring/bufrncwf-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.bufrncwf/res/spring/bufrncwf-ingest.xml
index 086d87414c..09d6036294 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.bufrncwf/res/spring/bufrncwf-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.bufrncwf/res/spring/bufrncwf-ingest.xml
@@ -9,7 +9,7 @@
-
+
bufrncwf
-
+
-->
-
+
bufrncwf
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.bufrquikscat/res/spring/bufrquikscat-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.bufrquikscat/res/spring/bufrquikscat-ingest.xml
index b87f4f528d..33bbe3d3ea 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.bufrquikscat/res/spring/bufrquikscat-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.bufrquikscat/res/spring/bufrquikscat-ingest.xml
@@ -16,7 +16,7 @@
-
+
bufrquikscat
-
+
-->
-
+
bufrquikscat
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.bufrsigwx/res/spring/bufrsigwx-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.bufrsigwx/res/spring/bufrsigwx-ingest.xml
index 105354db60..83a5477522 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.bufrsigwx/res/spring/bufrsigwx-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.bufrsigwx/res/spring/bufrsigwx-ingest.xml
@@ -32,13 +32,13 @@
bufrsigwx
-
+
-->
-
+
bufrsigwx
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.bufrssmi/res/spring/bufrssmi-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.bufrssmi/res/spring/bufrssmi-ingest.xml
index a6b184480e..f46b4a195a 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.bufrssmi/res/spring/bufrssmi-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.bufrssmi/res/spring/bufrssmi-ingest.xml
@@ -16,7 +16,7 @@
-->
-
-
-
+
@@ -42,7 +39,7 @@
-
+
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.preciprate/res/spring/preciprate-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.preciprate/res/spring/preciprate-ingest.xml
index 5751d3a9e6..eb49a866b7 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.preciprate/res/spring/preciprate-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.preciprate/res/spring/preciprate-ingest.xml
@@ -12,7 +12,7 @@
-
+
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.qpf/res/spring/qpf-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.qpf/res/spring/qpf-ingest.xml
index faec13e4c2..2b90e0b133 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.qpf/res/spring/qpf-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.qpf/res/spring/qpf-ingest.xml
@@ -12,7 +12,7 @@
-
+
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.satellite.mcidas/res/spring/satellite-mcidas-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.satellite.mcidas/res/spring/satellite-mcidas-ingest.xml
index f2a06df07d..6355ee2573 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.satellite.mcidas/res/spring/satellite-mcidas-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.satellite.mcidas/res/spring/satellite-mcidas-ingest.xml
@@ -4,11 +4,9 @@
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
+
-
@@ -36,7 +34,7 @@
-
+
satellite-mcidas
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.scan/res/spring/scan-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.scan/res/spring/scan-ingest.xml
index 719f851bf6..6c59176e41 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.scan/res/spring/scan-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.scan/res/spring/scan-ingest.xml
@@ -28,7 +28,7 @@
xmlns="http://camel.apache.org/schema/spring"
errorHandlerRef="errorHandler">
-
+
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.svrwx/res/spring/svrwx-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.svrwx/res/spring/svrwx-ingest.xml
index e5770ca7ba..09021bf61e 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.svrwx/res/spring/svrwx-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.svrwx/res/spring/svrwx-ingest.xml
@@ -24,7 +24,7 @@
autoStartup="false">
-
+
svrwx
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.tcg/res/spring/tcg-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.tcg/res/spring/tcg-ingest.xml
index ca50801379..113efae2fa 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.tcg/res/spring/tcg-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.tcg/res/spring/tcg-ingest.xml
@@ -10,7 +10,7 @@
-
+
-
+
tcg
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.tcs/res/spring/tcs-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.tcs/res/spring/tcs-ingest.xml
index f223e4bf0a..1583d2405b 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.tcs/res/spring/tcs-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.tcs/res/spring/tcs-ingest.xml
@@ -24,7 +24,7 @@
autoStartup="false">
-
+
tcs
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.vaa/res/spring/vaa-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.vaa/res/spring/vaa-ingest.xml
index 3a0c5dfe8a..76532eb545 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.vaa/res/spring/vaa-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.vaa/res/spring/vaa-ingest.xml
@@ -10,7 +10,7 @@
-
+
vaa
-
+
-->
-
+
vaa
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.vil/res/spring/vil-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.vil/res/spring/vil-ingest.xml
index 809da4ce6d..9044e2d523 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.vil/res/spring/vil-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.vil/res/spring/vil-ingest.xml
@@ -12,7 +12,7 @@
-
+
diff --git a/edexOsgi/com.raytheon.uf.edex.useradmin/res/spring/useradmin-request.xml b/edexOsgi/com.raytheon.uf.edex.useradmin/res/spring/useradmin-request.xml
index cb98375d92..e5fe9d1102 100644
--- a/edexOsgi/com.raytheon.uf.edex.useradmin/res/spring/useradmin-request.xml
+++ b/edexOsgi/com.raytheon.uf.edex.useradmin/res/spring/useradmin-request.xml
@@ -8,7 +8,7 @@
+ value="jms-generic:topic:user.authentication.changed?timeToLive=60000"/>
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.airmet/res/spring/airmet-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.airmet/res/spring/airmet-ingest.xml
index 4b1fe89335..867cee8113 100755
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.airmet/res/spring/airmet-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.airmet/res/spring/airmet-ingest.xml
@@ -33,13 +33,13 @@
airmet
-
+
-->
-
+
airmet
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.atcf/res/spring/atcf-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.atcf/res/spring/atcf-ingest.xml
index 2766178013..059bea827e 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.atcf/res/spring/atcf-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.atcf/res/spring/atcf-ingest.xml
@@ -21,7 +21,7 @@
-
+
@@ -42,11 +42,11 @@
atcf
-
+
-
+
atcf
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.aww/res/spring/aww-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.aww/res/spring/aww-ingest.xml
index 43e4b06517..5199c6cc78 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.aww/res/spring/aww-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.aww/res/spring/aww-ingest.xml
@@ -26,7 +26,7 @@
aww
-
+
-
+
aww
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.convsigmet/res/spring/convsigmet-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.convsigmet/res/spring/convsigmet-ingest.xml
index ce4746a203..32e0c3183f 100755
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.convsigmet/res/spring/convsigmet-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.convsigmet/res/spring/convsigmet-ingest.xml
@@ -34,13 +34,13 @@
convsigmet
-
+
-->
-
+
convsigmet
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.ffg/res/spring/ffg-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.ffg/res/spring/ffg-ingest.xml
index a215b07deb..48a11a8b6f 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.ffg/res/spring/ffg-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.ffg/res/spring/ffg-ingest.xml
@@ -34,13 +34,13 @@
ffg
-
+
-->
-
+
ffg
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.geomag/res/spring/geomag-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.geomag/res/spring/geomag-ingest.xml
index b90aa8d228..2110c6af41 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.geomag/res/spring/geomag-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.geomag/res/spring/geomag-ingest.xml
@@ -27,7 +27,7 @@
-
+
geomag
-
+
-
+
geomag
@@ -75,7 +75,7 @@
-
+
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.idft/res/spring/idft-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.idft/res/spring/idft-ingest.xml
index eb5fa71338..b45a6a1348 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.idft/res/spring/idft-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.idft/res/spring/idft-ingest.xml
@@ -29,11 +29,11 @@
idft
-
+
-
+
idft
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.intlsigmet/res/spring/intlsigmet-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.intlsigmet/res/spring/intlsigmet-ingest.xml
index 41591d2dcb..726905ee80 100755
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.intlsigmet/res/spring/intlsigmet-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.intlsigmet/res/spring/intlsigmet-ingest.xml
@@ -33,13 +33,13 @@
intlsigmet
-
+
-->
-
+
intlsigmet
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.mcidas/res/spring/mcidas-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.mcidas/res/spring/mcidas-ingest.xml
index be5ddbe708..464607cb5e 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.mcidas/res/spring/mcidas-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.mcidas/res/spring/mcidas-ingest.xml
@@ -42,11 +42,11 @@
mcidas
-
+
-
+
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.mosaic/res/spring/mosaic-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.mosaic/res/spring/mosaic-ingest.xml
index 4bba0d5c86..32178b148c 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.mosaic/res/spring/mosaic-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.mosaic/res/spring/mosaic-ingest.xml
@@ -44,12 +44,12 @@
mosaic
-
+
-
+
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.ncairep/res/spring/ncairep-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.ncairep/res/spring/ncairep-ingest.xml
index 32c07728e7..1e20119437 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.ncairep/res/spring/ncairep-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.ncairep/res/spring/ncairep-ingest.xml
@@ -35,13 +35,13 @@
ncairep
-
+
-
+
ncairep
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.ncccfp/res/spring/ncccfp-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.ncccfp/res/spring/ncccfp-ingest.xml
index 574d75d380..d6d31142c0 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.ncccfp/res/spring/ncccfp-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.ncccfp/res/spring/ncccfp-ingest.xml
@@ -32,12 +32,12 @@
ncccfp
-
+
-
+
ncccfp
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.ncgrib/res/spring/ncgrib-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.ncgrib/res/spring/ncgrib-ingest.xml
index 496b1b4dda..486939550b 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.ncgrib/res/spring/ncgrib-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.ncgrib/res/spring/ncgrib-ingest.xml
@@ -17,12 +17,9 @@
-
+
-
-
@@ -71,7 +68,7 @@
-
+
ncgrib
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.ncpafm/res/spring/ncpafm-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.ncpafm/res/spring/ncpafm-ingest.xml
index 6b00caf83f..dba9ae8fc6 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.ncpafm/res/spring/ncpafm-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.ncpafm/res/spring/ncpafm-ingest.xml
@@ -37,13 +37,13 @@
ncpafm
-
+
-->
-
+
ncpafm
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.ncpirep/res/spring/ncpirep-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.ncpirep/res/spring/ncpirep-ingest.xml
index c4d3dafb39..8c612bb468 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.ncpirep/res/spring/ncpirep-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.ncpirep/res/spring/ncpirep-ingest.xml
@@ -40,13 +40,13 @@
ncpirep
-
+
-
+
ncpirep
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.ncscat/res/spring/ncscat-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.ncscat/res/spring/ncscat-ingest.xml
index c665e79bbd..a84ff1ac4c 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.ncscat/res/spring/ncscat-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.ncscat/res/spring/ncscat-ingest.xml
@@ -36,12 +36,12 @@
ncscat
-
+
-
+
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.ncscd/res/spring/ncscd-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.ncscd/res/spring/ncscd-ingest.xml
index dfc0c0e70a..1bafa989f7 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.ncscd/res/spring/ncscd-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.ncscd/res/spring/ncscd-ingest.xml
@@ -43,11 +43,11 @@
ncscd
-
+
-
+
ncscd
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.nctaf/res/spring/nctaf-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.nctaf/res/spring/nctaf-ingest.xml
index 194b53f7bb..21366df5b5 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.nctaf/res/spring/nctaf-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.nctaf/res/spring/nctaf-ingest.xml
@@ -12,7 +12,7 @@
-
+
nctaf
-
+
-->
-
+
nctaf
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.nctext/res/spring/nctext-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.nctext/res/spring/nctext-ingest.xml
index 0dc7f8f433..3127d1f3e1 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.nctext/res/spring/nctext-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.nctext/res/spring/nctext-ingest.xml
@@ -33,12 +33,12 @@
nctext
-
+
-
+
nctext
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.ncuair/res/spring/ncuair-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.ncuair/res/spring/ncuair-ingest.xml
index 2d72057d74..8b64894fc6 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.ncuair/res/spring/ncuair-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.ncuair/res/spring/ncuair-ingest.xml
@@ -36,13 +36,13 @@
ncuair
-
-
+
+
-
+
ncuair
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.nonconvsigmet/res/spring/nonconvsigmet-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.nonconvsigmet/res/spring/nonconvsigmet-ingest.xml
index cc03e8f32c..016a8362b0 100755
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.nonconvsigmet/res/spring/nonconvsigmet-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.nonconvsigmet/res/spring/nonconvsigmet-ingest.xml
@@ -34,13 +34,13 @@
nonconvsigmet
-
+
-->
-
+
nonconvsigmet
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.ntrans/res/spring/ntrans-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.ntrans/res/spring/ntrans-ingest.xml
index b316e18903..276c1b4a9a 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.ntrans/res/spring/ntrans-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.ntrans/res/spring/ntrans-ingest.xml
@@ -36,12 +36,12 @@
ntrans
-
+
-
+
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.sgwh/res/spring/sgwh-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.sgwh/res/spring/sgwh-ingest.xml
index 815ff04049..438aa4403d 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.sgwh/res/spring/sgwh-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.sgwh/res/spring/sgwh-ingest.xml
@@ -39,11 +39,11 @@
sgwh
-
+
-
+
sgwh
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.sgwhv/res/spring/sgwhv-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.sgwhv/res/spring/sgwhv-ingest.xml
index 5b75fa5185..75a484bb3f 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.sgwhv/res/spring/sgwhv-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.sgwhv/res/spring/sgwhv-ingest.xml
@@ -39,11 +39,11 @@
sgwhv
-
+
-
+
sgwhv
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.solarimage/res/spring/solarimage-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.solarimage/res/spring/solarimage-ingest.xml
index 23eb705d94..2e55c631e8 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.solarimage/res/spring/solarimage-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.solarimage/res/spring/solarimage-ingest.xml
@@ -27,7 +27,7 @@
-
+
solarimage
-
+
-
+
solarimage
@@ -78,7 +78,7 @@
-
+
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.ssha/res/spring/ssha-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.ssha/res/spring/ssha-ingest.xml
index f34042890c..cff4c91bdd 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.ssha/res/spring/ssha-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.ssha/res/spring/ssha-ingest.xml
@@ -40,11 +40,11 @@
ssha
-
+
-
+
ssha
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.stormtrack/res/spring/stormtrack-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.stormtrack/res/spring/stormtrack-ingest.xml
index 0bed17b1bf..49d51b9aff 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.stormtrack/res/spring/stormtrack-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.stormtrack/res/spring/stormtrack-ingest.xml
@@ -21,7 +21,7 @@
-
+
@@ -42,11 +42,11 @@
stormtrack
-
+
-
+
stormtrack
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.tcm/res/spring/tcm-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.tcm/res/spring/tcm-ingest.xml
index ca51191363..ff1e6d016b 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.tcm/res/spring/tcm-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.tcm/res/spring/tcm-ingest.xml
@@ -33,11 +33,11 @@
tcm
-
+
-
+
tcm
diff --git a/ncep/gov.noaa.nws.ncep.edex.plugin.wcp/res/spring/wcp-ingest.xml b/ncep/gov.noaa.nws.ncep.edex.plugin.wcp/res/spring/wcp-ingest.xml
index dbc4032f1f..ee08113523 100644
--- a/ncep/gov.noaa.nws.ncep.edex.plugin.wcp/res/spring/wcp-ingest.xml
+++ b/ncep/gov.noaa.nws.ncep.edex.plugin.wcp/res/spring/wcp-ingest.xml
@@ -29,11 +29,11 @@
wcp
-
+
-
+
wcp
diff --git a/ost/gov.noaa.nws.ost.edex.plugin.regionalsat/res/spring/regionalsat-ingest.xml b/ost/gov.noaa.nws.ost.edex.plugin.regionalsat/res/spring/regionalsat-ingest.xml
index d1cb253f95..45d1fc0129 100644
--- a/ost/gov.noaa.nws.ost.edex.plugin.regionalsat/res/spring/regionalsat-ingest.xml
+++ b/ost/gov.noaa.nws.ost.edex.plugin.regionalsat/res/spring/regionalsat-ingest.xml
@@ -25,7 +25,7 @@
-
+
@@ -42,7 +42,7 @@
-
+
regionalsat
diff --git a/rpms/awips2.qpid/0.18/SOURCES/wrapper.conf b/rpms/awips2.qpid/0.18/SOURCES/wrapper.conf
index 9f5b7ad05b..d90ec22fb0 100644
--- a/rpms/awips2.qpid/0.18/SOURCES/wrapper.conf
+++ b/rpms/awips2.qpid/0.18/SOURCES/wrapper.conf
@@ -60,6 +60,7 @@ wrapper.java.additional.3=-Damqj.logging.level=${AMQJ_LOGGING_LEVEL}
wrapper.java.additional.4=-DQPID_HOME=${QPID_HOME}
wrapper.java.additional.5=-DQPID_WORK=${QPID_WORK}
wrapper.java.additional.6=-Damqj.read_write_pool_size=32
+wrapper.java.additional.7=-Dqpid.broker.exceptionHandler.continue=true
# Maximum Java Heap Size (in MB)
wrapper.java.maxmemory=2048