StatefulSessionBean


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.test.dtmusertx.ejb;
23  
24  import javax.ejb.SessionSynchronization  ;
25  
26  import org.jboss.logging.Logger;
27  import org.jboss.test.util.ejb.SessionSupport;
28  
29  
30  /** The stateful session ejb implementation
31   *
32   *   @author Scott.Stark@jboss.org
33   *   @version $Revision: 58115 $
34   */
35  public class StatefulSessionBean
36     extends SessionSupport
37     implements SessionSynchronization  
38  {
39     private static transient Logger log = Logger.getLogger(StatefulSessionBean.class);
40     private transient int counterAtTxStart;
41     private String   testName;
42     private int counter;
43  
44     public void ejbCreate(String   testName)
45     {
46        this.testName = testName;
47        log = Logger.getLogger(StatefulSessionBean.class.getName()+"#"+testName);
48        log.debug("ejbCreate("+testName+"), ctx="+sessionCtx);
49     }
50  
51     public void afterBegin ()
52     {
53        log.debug("afterBegin()..., counter="+counter);
54        counterAtTxStart = counter;
55     }
56     public void afterCompletion (boolean isCommited)
57     {
58        log.debug("afterCompletion(), isCommited="+isCommited
59           +", counter="+counter+", counterAtTxStart="+counterAtTxStart);
60        if( isCommited == false )
61        {
62           counter = counterAtTxStart;
63           log.debug("Rolling counter back to: "+counter);
64        }
65        else
66        {
67           log.debug("Committed updated counter: "+counter);         
68        }
69     }
70     public void beforeCompletion ()
71     {
72        log.debug("beforeCompletion(), counter="+counter
73           +", counterAtTxStart="+counterAtTxStart);
74     }
75  
76     public void incCounter ()
77     {
78        counter++;
79     }
80  
81     public void decCounter ()
82     {
83        counter--;
84     }
85  
86     public int getCounter ()
87     {
88        return counter;
89     }
90  
91     public void setCounter (int value)
92     {
93        counter = value;
94     }
95  
96     public String   txMandatoryMethod(String   msg)
97     {
98        log.debug("txMandatoryMethod( ), msg="+msg);
99        return msg;
100    }
101 
102 }
103
A to Z: JavaDoc & Examples Daily Java News & Articles Open Source Projects Open Source Codes Free Computer Books Remove Frame
Popular Tags