[JBoss Seam] - How to avoid transaction Timeouts for long running MDB
by jfrankman
If I have a single SLSB with method A and Method B which are called sequentially (first A then B) by a MDB how do I keep Method B from getting a transaction timeout error when method A takes a very long time to complete?
I have a MDB which firsts downloads some files from a FTP site and processes the files. The download can take several minutes depending upon the size of the file and the network speed. Once the download is complete I use hibernate to read the contents of the text file downloaded from the FTP site. The problem I am having is that after 5 minutes or so while the file is still downloading I get:
16:55:48,266 WARN [TransactionImpl] Transaction TransactionImpl:XidImpl[FormatId=257, GlobalId=fbmis011/19, BranchQual=, localId=19] timed out. status=STATUS_ACTIVE
At first I tried to up the timeout limit, by using
"@TransactionTimeout(1800)" on the MDB. However, this is a poor workaround since a download could take a very long time depending upon the size of the file. What I would like to do is not have the transaction begin until after the download has completed. Both the download and the hibernate query happen in the same SLSB. Despite my efforts, I still get a transaction time out error in the method that uses hibernate to query the file (getIndexFileDetailRecords()). Here is my code in its current state:
MDB:
@MessageDriven(activationConfig =
| {
| @ActivationConfigProperty(propertyName="destinationType",
| propertyValue="javax.jms.Queue"),
| @ActivationConfigProperty(propertyName="destination",
| propertyValue="queue/KeyBankCheckImageQueue")
| })
|
|
| @Name("keybankCheckImagesMessageHandler")
| public class KeyBankCheckImagesMessageHandler implements MessageListener{
|
| @In(create=true) KeyBankServices keybankServices;
|
| public void onMessage (Message msg) {
|
| MapMessage mapMessage=(MapMessage)msg;
| try {
| System.out.println("process checks.");
| //mapMessage.getInt("lower");
| InitialContext ctx = new InitialContext();
| //JNDI tests. I settled with using the jboss-services.xml, but the SystemPropertiesService could have been used.
| //String text = (String) ctx.lookup("keybankchecks/path");
| //SystemPropertiesService abc = new SystemPropertiesService();
| //text=abc.get("aaa");
|
| try {
| //keySrv.cleanRemoteBackups();
| keybankServices.cleanRemoteBackups();
| } catch (Exception e) {
| e.printStackTrace();
| }
| keybankServices.downloadKeyBankFiles();
| keybankServices.processKeyBankFiles();
| }
| catch (NamingException e) {
|
| e.printStackTrace();
| }
| }
|
| }
Here is the SLSB with the method that times out (getIndexFileDetailRecords()).
@Stateless
| @Name("keybankServices")
| public class KeyBankServicesImpl implements KeyBankServices
| {
|
| @PersistenceContext()
| private EntityManager em;
|
| private KeyBankConfiguration keyBankConfig;
| //private File batchDirectory;
| private static Logger logger;
| //(a)org.jboss.seam.annotations.Logger
| //private Log logger;
|
| private static final String DOWNLOADING="downloading_";
|
|
|
| public KeyBankServicesImpl()
| {
| init();
|
| }
|
| //@Create
| public void init()
| {
| System.setProperty("line.separator", "\r\n");
|
| //enable logger
| logger=Logger.getLogger(KeyBankServicesImpl.class.getName());
| logger.info("KeyBankServicesImpl class instantiated.");
|
|
| try {
| keyBankConfig=new KeyBankConfiguration();
| } catch (NamingException e) {
| logger.error(e.getStackTrace());
| //e.printStackTrace();
| }
| logger.info("KeyBankServicesImpl configuration:" + keyBankConfig);
| cleanupBackups();
|
| }
|
| @Begin(join=true)
| @TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED)
| public void downloadKeyBankFiles()
| {
| ...stuff.
|
| }
|
| @Begin(join=true)
| @TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED)
| public void processKeyBankFiles()
| {
| stuff....
| }
|
| @Begin(join=true)
| @TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED)
| private Collection<IndexDetail> getIndexFileDetailRecords()
| {
| Collection<IndexDetail> returnCollection;
| String query = "from IndexDetail";
| Query hqlQuery =em.createQuery(query);
| returnCollection =hqlQuery.getResultList();
| return returnCollection;
| }
Any help would be appreciated.
Thanks
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4095437#4095437
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4095437
18Â years, 9Â months
[JBoss Seam] - Re: @DataModelSelection doesn't work in Restful
by dhinojosa
Sweet! No ever asked to elaborate my idiocy;) Just kidding
What I had done (with simple but not the same example) was I created a bean just to try things out
| @Stateful
| @Name("searchEmployeesByState")
| @Scope(ScopeType.SESSION)
| public void SearchEmployeesByState ... {
|
| private List<Employee> employees;
|
| /**
| * Getters and setters, em finders, etc here
| */
| }
|
I then produced a page to view just to try things out
| <h:dataTable value="#{searchEmployeesByState.employees}" var="employee">
| ....
| </h:dataTable>
|
Note, the value in my data table....Because that's where my problem occured.
I then decided that I wanted to select the model....so like a good citizen I changed my bean...
| @Stateful
| @Name("searchEmployeesByState")
| @Scope(ScopeType.SESSION)
| public void SearchEmployeesByState ... {
|
| @DataModel
| private List<Employee> employees;
|
| @DataModelSelection
| private Employee employee;
|
| /**
| * Getters and setters, em finders, etc here
| */
| }
|
Now that I did that, I didn't change my web page like I should've. That's when an angry mind and a keyboard can go a long way to ruin your day. I was trying different combos with factory, etc, and I couldn't figure out why my one item wasn't being selected. Finally, after a while and came back and realized I had to make my web page into the following. Basic seam stuff, but I just missed it. :(
| <h:dataTable value="#{employees}" var="employee">
| ....
| </h:dataTable>
|
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4095429#4095429
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4095429
18Â years, 9Â months