You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2016/03/02 21:51:07 UTC
svn commit: r1733365 -
/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java
Author: cwiklik
Date: Wed Mar 2 20:51:07 2016
New Revision: 1733365
URL: http://svn.apache.org/viewvc?rev=1733365&view=rev
Log:
UIMA-4813 white listed packages needed to deserialize ObjectMessages
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java
Modified: uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java?rev=1733365&r1=1733364&r2=1733365&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java (original)
+++ uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java Wed Mar 2 20:51:07 2016
@@ -22,6 +22,7 @@ package org.apache.uima.adapter.jms.acti
import java.lang.reflect.Method;
import java.net.ConnectException;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
@@ -182,7 +183,8 @@ public class UimaDefaultMessageListenerC
doLogFailureMsg = false;
}
}
- sleepInbetweenRecoveryAttempts();
+ // sleepInbetweenRecoveryAttempts();
+ setRecoveryInterval(10);
}
}
} catch( IllegalStateException e ) {
@@ -848,6 +850,16 @@ public class UimaDefaultMessageListenerC
public void setConnectionFactory(ConnectionFactory aConnectionFactory) {
connectionFactory = aConnectionFactory;
+ ((ActiveMQConnectionFactory)connectionFactory).
+ setTrustedPackages(new ArrayList<String>(
+ Arrays.asList("org.apache.uima.aae.error",
+ "org.apache.uima.analysis_engine",
+ "org.apache.activemq",
+ "org.fusesource.hawtbuf",
+ "com.thoughtworks.xstream.mapper",
+ "java.lang",
+ "java.util")));
+
super.setConnectionFactory(connectionFactory);
}