svn commit: r1071332 - /uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java

[cwiklik]

Author: cwiklik
Date: Wed Feb 16 17:59:38 2011
New Revision: 1071332

URL: http://svn.apache.org/viewvc?rev=1071332&view=rev
Log:
UIMA-2055 Modified to set content of a message in produceByteMessage and 
produceTextMessage

Modified:
    
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java

Modified: 
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java
URL: 
http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java?rev=1071332&r1=1071331&r2=1071332&view=diff
==============================================================================
--- 
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java
 (original)
+++ 
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java
 Wed Feb 16 17:59:38 2011
@@ -385,7 +385,7 @@ public class JmsEndpointConnection_impl 
                    }
                    try {
                       if (aTextMessage == null) {
-                         return producerSession.createTextMessage();
+                         return producerSession.createTextMessage("");
                       } else {
                          return 
producerSession.createTextMessage(aTextMessage);
                       }
@@ -412,17 +412,20 @@ public class JmsEndpointConnection_impl 
        }
   }
 
-  public BytesMessage produceByteMessage() throws AsynchAEException {
+  public BytesMessage produceByteMessage(byte[] aSerializedCAS) throws 
AsynchAEException {
     synchronized( lock ) {
         if ( producerSession == null ) {
             throw new 
AsynchAEException("Controller:"+controller.getComponentName()+" Unable to 
create JMS Message. Producer Session Not Initialized (Null)");
           }
-          boolean done = false;
-          int retryCount = 4;
+          int retryCount = 1;
           while (retryCount > 0) {
             try {
               retryCount--;
-              return producerSession.createBytesMessage();
+              BytesMessage bm = producerSession.createBytesMessage();
+              bm.writeBytes(aSerializedCAS);
+
+              return bm;
+
             } catch (javax.jms.IllegalStateException e) {
               try {
                 open();