Sure just give me the location where all the other commiters have added theirs and i will add my pic to the group :))
On 3/30/07, David Blevins <[EMAIL PROTECTED]> wrote:
Whoo Hooo!!! Manu's first commit! Alright, Manu, you probably didn't know this when you accepted commit, but it's a tradition to get your First Commit Revision Number (FCRN as we call them) ... tattooed on your arm. We expect to see pictures of "523973" in fresh ink by Monday! -David On Mar 30, 2007, at 12:21 AM, [EMAIL PROTECTED] wrote: > Author: manugeorge > Date: Fri Mar 30 00:21:01 2007 > New Revision: 523973 > > URL: http://svn.apache.org/viewvc?view=rev&rev=523973 > Log: > changing the MdbInvoker code to open and then close a connection > each time it needs one in a try/finally block. > > Modified: > incubator/openejb/trunk/openejb3/itests/openejb-itests-beans/ > src/main/java/org/apache/openejb/test/mdb/MdbInvoker.java > > Modified: incubator/openejb/trunk/openejb3/itests/openejb-itests- > beans/src/main/java/org/apache/openejb/test/mdb/MdbInvoker.java > URL: http://svn.apache.org/viewvc/incubator/openejb/trunk/openejb3/ > itests/openejb-itests-beans/src/main/java/org/apache/openejb/test/ > mdb/MdbInvoker.java?view=diff&rev=523973&r1=523972&r2=523973 > ====================================================================== > ======== > --- incubator/openejb/trunk/openejb3/itests/openejb-itests-beans/ > src/main/java/org/apache/openejb/test/mdb/MdbInvoker.java (original) > +++ incubator/openejb/trunk/openejb3/itests/openejb-itests-beans/ > src/main/java/org/apache/openejb/test/mdb/MdbInvoker.java Fri Mar > 30 00:21:01 2007 > @@ -36,14 +36,11 @@ > private final Object target; > private Connection connection; > private Session session; > + private ConnectionFactory connectionFactory; > > public MdbInvoker(ConnectionFactory connectionFactory, Object > target) throws JMSException { > this.target = target; > - connection = connectionFactory.createConnection(); > - connection.start(); > - > - session = connection.createSession(false, > Session.AUTO_ACKNOWLEDGE); > - > + this.connectionFactory = connectionFactory; > for (Method method : target.getClass().getMethods()) { > String signature = MdbUtil.getSignature(method); > signatures.put(signature, method); > @@ -57,7 +54,10 @@ > connection = null; > } > > - private synchronized Session getSession() { > + private synchronized Session getSession() throws JMSException{ > + connection = connectionFactory.createConnection(); > + connection.start(); > + session = connection.createSession(false, > Session.AUTO_ACKNOWLEDGE); > return session; > } > > @@ -124,6 +124,7 @@ > e.printStackTrace(); > } finally { > MdbUtil.close(producer); > + destroy(); > } > } catch (Throwable e) { > e.printStackTrace(); > >
