TXTimeOutBean


1   /*
2    * JBoss, Home of Professional Open Source
3    * Copyright 2005, JBoss Inc., and individual contributors as indicated
4    * by the @authors tag. See the copyright.txt in the distribution for a
5    * full listing of individual contributors.
6    *
7    * This is free software; you can redistribute it and/or modify it
8    * under the terms of the GNU Lesser General Public License as
9    * published by the Free Software Foundation; either version 2.1 of
10   * the License, or (at your option) any later version.
11   *
12   * This software is distributed in the hope that it will be useful,
13   * but WITHOUT ANY WARRANTY; without even the implied warranty of
14   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15   * Lesser General Public License for more details.
16   *
17   * You should have received a copy of the GNU Lesser General Public
18   * License along with this software; if not, write to the Free
19   * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
20   * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
21   */
22  package org.jboss.ejb3.test.dd.mdb;
23  
24  import javax.ejb.MessageDrivenBean  ;
25  import javax.ejb.MessageDrivenContext  ;
26  import javax.ejb.EJBException  ;
27  
28  import javax.jms.JMSException  ;
29  import javax.jms.MessageListener  ;
30  import javax.jms.Message  ;
31  
32  /**
33   * The TXTimeOutBean simulates when the onMessage() takes
34   * a long time to process the message.  When this happens,
35   * the TM might time-out the transaction.  This bean 
36   * can be used to see if the TX times outs occur.
37   *
38   * @author Hiram Chirino
39   */
40  
41  public class TXTimeOutBean implements MessageDrivenBean  , MessageListener  
42  {
43  
44     org.jboss.logging.Logger log = org.jboss.logging.Logger.getLogger(getClass());
45  
46     long PROCESSING_DELAY = 10; // simulate 10 seconds of processing
47  
48     public void setMessageDrivenContext(MessageDrivenContext   ctx)
49     {
50     }
51  
52     public void ejbCreate()
53     {
54     }
55  
56     public void ejbRemove()
57     {
58     }
59  
60     public void onMessage(Message   message)
61     {
62        try
63        {
64           log.debug("Simulating " + PROCESSING_DELAY + " second(s) of message processing ");
65           TestStatusBean.addDestination(message.getJMSDestination());
66           Thread.sleep(PROCESSING_DELAY * 1000);
67           log.debug("Message processing simulation done.");
68        }
69        catch (Throwable   ignore)
70        {
71        }
72     }
73  }
74
A to Z: JavaDoc & Examples Daily Java News & Articles Open Source Projects Open Source Codes Free Computer Books Remove Frame
Popular Tags