midsuit
/
core-jgi
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[ 2195051 ] Implementing Message Transaction 

http://sourceforge.net/tracker/index.php?func=detail&aid=2195051&group_id=176962&atid=879335
This commit is contained in:
vpj-cd 2008-10-25 19:09:01 +00:00
parent dee3c8bf79
commit 909caca701
1 changed files with 20 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
extend/src/org/adempiere/process/rpl/exp/TopicExportProcessor.java
View File

@ -21,7 +21,8 @@
* MA 02110-1301, USA. * * MA 02110-1301, USA. *
* * * *
* Contributors: * * Contributors: *
* - Trifon Trifonov (trifonnt@users.sourceforge.net) * * - Trifon Trifonov (trifonnt@users.sourceforge.net)
* - Antonio Cañaveral, e-Evolution
* * * *
* Sponsors: * * Sponsors: *
* - E-evolution (http://www.e-evolution.com) * * - E-evolution (http://www.e-evolution.com) *
@ -57,6 +58,10 @@ import org.w3c.dom.Document;
/** /**
* @author Trifon N. Trifonov * @author Trifon N. Trifonov
* @author Antonio Cañaveral, e-Evolution
* <li>[ 2195051 ] Implementing Message Transaction
* <li>http://sourceforge.net/tracker/index.php?func=detail&aid=2195051&group_id=176962&atid=879335
*/ */
public class TopicExportProcessor implements IExportProcessor { public class TopicExportProcessor implements IExportProcessor {
@ -154,8 +159,8 @@ public class TopicExportProcessor implements IExportProcessor {
connection.start(); connection.start();
// Create a Session // Create a Session
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //TODO - Trifon could be EXP_ProcessorParameter session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE); //TODO - Trifon could be EXP_ProcessorParameter
// Create the destination (Topic or Queue) // Create the destination (Topic or Queue)
Destination destination = session.createTopic(topicName); Destination destination = session.createTopic(topicName);
@ -177,8 +182,18 @@ public class TopicExportProcessor implements IExportProcessor {
TextMessage message = session.createTextMessage( msg ); TextMessage message = session.createTextMessage( msg );
// Tell the producer to send the message // Tell the producer to send the message
log.info("JMS Message sent!"); try
producer.send(message); {
producer.send(message);
session.commit();
log.info("JMS Message sent!");
}catch(JMSException ex)
{
session.rollback();
log.info("JMS Can't send the message!");
throw ex;
}
} finally { } finally {
// Clean up // Clean up
if (session != null) { if (session != null) {