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 2009/09/15 19:05:48 UTC

svn commit: r815402 - in /incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client: ActiveMQMessageSender.java BaseUIMAAsynchronousEngine_impl.java

Author: cwiklik
Date: Tue Sep 15 17:05:48 2009
New Revision: 815402

URL: http://svn.apache.org/viewvc?rev=815402&view=rev
Log:
UIMA-1565 Fixes NPE when running with AMQ 5.2 and using empty TextMessage

Modified:
    incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/ActiveMQMessageSender.java
    incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java

Modified: incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/ActiveMQMessageSender.java
URL: http://svn.apache.org/viewvc/incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/ActiveMQMessageSender.java?rev=815402&r1=815401&r2=815402&view=diff
==============================================================================
--- incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/ActiveMQMessageSender.java (original)
+++ incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/ActiveMQMessageSender.java Tue Sep 15 17:05:48 2009
@@ -145,7 +145,7 @@
       throw new JMSException(
               "Unable To Create JMS TextMessage. Reason: JMS Session Not Initialized");
     }
-    return session.createTextMessage();
+    return session.createTextMessage("");
   }
 
   public BytesMessage createBytesMessage() throws Exception {

Modified: incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java
URL: http://svn.apache.org/viewvc/incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java?rev=815402&r1=815401&r2=815402&view=diff
==============================================================================
--- incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java (original)
+++ incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java Tue Sep 15 17:05:48 2009
@@ -955,6 +955,7 @@
     try {
       if (clientCachedRequest.getFreeCasNotificationQueue() != null) {
         TextMessage msg = createTextMessage();
+        msg.setText("");
         msg.setIntProperty(AsynchAEMessage.Payload, AsynchAEMessage.None);
         msg
                 .setStringProperty(AsynchAEMessage.CasReference, clientCachedRequest