[jbpm-commits] JBoss JBPM SVN: r6693 - jbpm3/branches/jbpm-3.2-soa/enterprise-jee5/src/main/java/org/jbpm/jms.

[do-not-reply at jboss.org]

Author: bradsdavis
Date: 2010-09-28 08:28:49 -0400 (Tue, 28 Sep 2010)
New Revision: 6693

Modified:
   jbpm3/branches/jbpm-3.2-soa/enterprise-jee5/src/main/java/org/jbpm/jms/JmsConnectorService.java
Log:
Moved the JMS connection.

Modified: jbpm3/branches/jbpm-3.2-soa/enterprise-jee5/src/main/java/org/jbpm/jms/JmsConnectorService.java
===================================================================
--- jbpm3/branches/jbpm-3.2-soa/enterprise-jee5/src/main/java/org/jbpm/jms/JmsConnectorService.java	2010-09-28 12:21:22 UTC (rev 6692)
+++ jbpm3/branches/jbpm-3.2-soa/enterprise-jee5/src/main/java/org/jbpm/jms/JmsConnectorService.java	2010-09-28 12:28:49 UTC (rev 6693)
@@ -51,8 +51,6 @@
 
   private final JobSession jobSession;
 
-  private final Connection connection;
-  
   private final JmsConnectorServiceFactory factory;
   
   public JmsConnectorService(JmsConnectorServiceFactory factory) throws JMSException {
@@ -61,7 +59,6 @@
     jobSession = jbpmContext.getJobSession();
     
     this.factory = factory;
-    this.connection = factory.getConnectionFactory().createConnection();    
   }
 
   public void send(Job job) {
@@ -70,10 +67,12 @@
   }
 
   void sendWithoutSaving(Job job) {
+	  Connection connection = null;
 	  MessageProducer messageProducer = null;
 	  Session session = null;
     try {
-      session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+      connection = factory.getConnectionFactory().createConnection();
+      session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
       messageProducer = session.createProducer(factory.getDestination());
       Message message = session.createMessage();
       populateMessage(message, job);
@@ -85,6 +84,7 @@
     finally {
     	JmsUtil.closeSilently(messageProducer);
     	JmsUtil.closeSilently(session);
+    	JmsUtil.closeSilently(connection);
     }
   }
 
@@ -118,8 +118,4 @@
   public void deleteTimersByProcessInstance(ProcessInstance processInstance) {
     jobSession.deleteJobsForProcessInstance(processInstance);
   }
-
-  public void close() {
-	JmsUtil.closeSilently(connection);
-  }
 }