1 files changed, 6 insertions, 0 deletions
diff --git a/branches/sca-java-1.x/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/ObjectMessageProcessor.java b/branches/sca-java-1.x/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/ObjectMessageProcessor.java
index 781d9fc93c..73a822a622 100644
--- a/branches/sca-java-1.x/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/ObjectMessageProcessor.java
+++ b/branches/sca-java-1.x/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/ObjectMessageProcessor.java
@@ -19,6 +19,7 @@
 package org.apache.tuscany.sca.binding.jms.provider;
 
 import java.io.Serializable;
+import java.util.logging.Logger;
 
 import javax.jms.JMSException;
 import javax.jms.Message;
@@ -34,6 +35,7 @@ import org.apache.tuscany.sca.binding.jms.impl.JMSBindingException;
  * @version $Rev$ $Date$
  */
 public class ObjectMessageProcessor extends AbstractMessageProcessor {
+    private static final Logger logger = Logger.getLogger(ObjectMessageProcessor.class.getName());
 
     public ObjectMessageProcessor(JMSBinding jmsBinding) {
         super(jmsBinding);
@@ -52,6 +54,10 @@ public class ObjectMessageProcessor extends AbstractMessageProcessor {
 
     @Override
     protected Message createJMSMessage(Session session, Object o) {
+        if (session == null) {
+            logger.fine("no response session to create message: " + String.valueOf(o));
+            return null;
+        }
         try {
 
             ObjectMessage message = session.createObjectMessage();