diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.text.subscription/res/spring/text-subscription-ingest.xml b/edexOsgi/com.raytheon.uf.edex.plugin.text.subscription/res/spring/text-subscription-ingest.xml
index c5d7d5a4fe..0bec0485f2 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.text.subscription/res/spring/text-subscription-ingest.xml
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.text.subscription/res/spring/text-subscription-ingest.xml
@@ -12,7 +12,7 @@
         <property name="type" value="timer" />
     </bean>
 
-    <camelContext id="clustered-text-subscription-camel"
+    <camelContext id="text-subscription-camel"
         xmlns="http://camel.apache.org/schema/spring"
         errorHandlerRef="errorHandler">
 
diff --git a/edexOsgi/com.raytheon.uf.edex.plugin.text.subscription/src/com/raytheon/uf/edex/plugin/text/subscription/AutoFaxManager.java b/edexOsgi/com.raytheon.uf.edex.plugin.text.subscription/src/com/raytheon/uf/edex/plugin/text/subscription/AutoFaxManager.java
index 8f396bfbd2..104129db0d 100644
--- a/edexOsgi/com.raytheon.uf.edex.plugin.text.subscription/src/com/raytheon/uf/edex/plugin/text/subscription/AutoFaxManager.java
+++ b/edexOsgi/com.raytheon.uf.edex.plugin.text.subscription/src/com/raytheon/uf/edex/plugin/text/subscription/AutoFaxManager.java
@@ -71,26 +71,22 @@ public class AutoFaxManager {
         }
     }
 
-    public void processEvent(Object event) throws EdexException {
+    public void processEvent(PluginDataObject[] pdos) throws EdexException {
         List<String> trigger = new ArrayList<String>();
-        if (event instanceof PluginDataObject[]) {
-            PluginDataObject[] pdos = (PluginDataObject[]) event;
-            for (PluginDataObject pdo : pdos) {
-                try {
-                    if (pdo instanceof TextRecord) {
-                        TextRecord tr = (TextRecord) pdo;
-                        String prodID = tr.getProductId();
-                        if (logger.isDebugEnabled()) {
-                            logger.debug("Processing trigger: " + prodID
-                                    + ", class = "
-                                    + pdo.getClass().getSimpleName());
-                        }
-                        trigger.add(prodID);
+        for (PluginDataObject pdo : pdos) {
+            try {
+                if (pdo instanceof TextRecord) {
+                    TextRecord tr = (TextRecord) pdo;
+                    String prodID = tr.getProductId();
+                    if (logger.isDebugEnabled()) {
+                        logger.debug("Processing trigger: " + prodID
+                                + ", class = " + pdo.getClass().getSimpleName());
                     }
-                } catch (Exception e) {
-                    logger.warn("Unable to extract product information from ["
-                            + pdo.toString() + "] skipping...");
+                    trigger.add(prodID);
                 }
+            } catch (Exception e) {
+                logger.warn("Unable to extract product information from ["
+                        + pdo.toString() + "] skipping...");
             }
         }
         sendFaxes(trigger);
@@ -113,10 +109,14 @@ public class AutoFaxManager {
                         // Shove it out to all the autofax subscribers to this
                         // PIL.
                         try {
-                            FaxSender.sendFax(faxRecord.getCompany(), faxRecord
-                                    .getId().getFaxNumber(), faxRecord
-                                    .getRecipient(), faxText, faxRecord.getId()
-                                    .getAfosPil());
+                            logger.info("Sending fax to '"
+                                    + faxRecord.getCompany()
+                                    + "' for AFOS PIL: " + afosPil);
+                            String status = FaxSender.sendFax(faxRecord
+                                    .getCompany(), faxRecord.getId()
+                                    .getFaxNumber(), faxRecord.getRecipient(),
+                                    faxText, faxRecord.getId().getAfosPil());
+                            logger.info(status);
                         } catch (IOException e) {
                             logger.warn("Error sending fax for AFOS PIL: "
                                     + afosPil);