[jboss-user] [JBoss Seam] - How to avoid transaction Timeouts for long running MDB

[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;
  | 	//@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