EJB3 Transaction Propagation
Asked Answered
S

8

26

I have a stateless bean something like:

@Stateless
public class MyStatelessBean implements MyStatelessLocal, MyStatelessRemote {
    @PersistenceContext(unitName="myPC")
    private EntityManager mgr;

    @TransationAttribute(TransactionAttributeType.SUPPORTED)
    public void processObjects(List<Object> objs) {
        // this method just processes the data; no need for a transaction
        for(Object obj : objs) {
            this.process(obj);
        }
    }

    @TransationAttribute(TransactionAttributeType.REQUIRES_NEW)
    public void process(Object obj) {
        // do some work with obj that must be in the scope of a transaction

        this.mgr.merge(obj);
        // ...
        this.mgr.merge(obj);
        // ...
        this.mgr.flush();
    }
}

The typically usage then is the client would call processObjects(...), which doesn't actually interact with the entity manager. It does what it needs to do and calls process(...) individually for each object to process. The duration of process(...) is relatively short, but processObjects(...) could take a very long time to run through everything. Therefore I don't want it to maintain an open transaction. I do need the individual process(...) operations to operate within their own transaction. This should be a new transaction for every call. Lastly I'd like to keep the option open for the client to call process(...) directly.

I've tried a number of different transaction types: never, not supported, supported (on processObjects) and required, requires new (on process) but I get TransactionRequiredException every time merge() is called.

I've been able to make it work by splitting up the methods into two different beans:

@Stateless
@TransationAttribute(TransactionAttributeType.NOT_SUPPORTED)
public class MyStatelessBean1 implements MyStatelessLocal1, MyStatelessRemote1 {
    @EJB
    private MyStatelessBean2 myBean2;

    public void processObjects(List<Object> objs) {
        // this method just processes the data; no need for a transaction
        for(Object obj : objs) {
            this.myBean2.process(obj);
        }
    }
}

@Stateless
public class MyStatelessBean2 implements MyStatelessLocal2, MyStatelessRemote2 {
    @PersistenceContext(unitName="myPC")
    private EntityManager mgr;

    @TransationAttribute(TransactionAttributeType.REQUIRES_NEW)
    public void process(Object obj) {
        // do some work with obj that must be in the scope of a transaction

        this.mgr.merge(obj);
        // ...
        this.mgr.merge(obj);
        // ...
        this.mgr.flush();
    }
}

but I'm still curious if it's possible to accomplish this in one class. It looks to me like the transaction manager only operates at the bean level, even when individual methods are given more specific annotations. So if I mark one method in a way to prevent the transaction from starting calling other methods within that same instance will also not create a transaction, no matter how they're marked?

I'm using JBoss Application Server 4.2.1.GA, but non-specific answers are welcome / preferred.

Schreiber answered 19/9, 2008 at 23:43 Comment(0)
B
24

Another way to do it is actually having both methods on the same bean - and having an @EJB reference to itself! Something like that:

// supposing processObjects defined on MyStatelessRemote1 and process defined on MyStatelessLocal1
@Stateless
@TransationAttribute(TransactionAttributeType.NOT_SUPPORTED)
public class MyStatelessBean1 implements MyStatelessLocal1, MyStatelessRemote1 {
    @EJB
    private MyStatelessLocal1 myBean2;

    public void processObjects(List<Object> objs) {
        // this method just processes the data; no need for a transaction
        for(Object obj : objs) {
            this.myBean2.process(obj);
        }
    }


    @TransationAttribute(TransactionAttributeType.REQUIRES_NEW)
    public void process(Object obj) {
        // do some work with obj that must be in the scope of a transaction

        this.mgr.merge(obj);
        // ...
        this.mgr.merge(obj);
        // ...
        this.mgr.flush();
    }
}

This way you actually 'force' the process() method to be accessed via the ejb stack of proxies, therefore taking the @TransactionAttribute in effect - and still keeping only one class. Phew!

Bigeye answered 4/2, 2009 at 15:46 Comment(2)
Just thought I'd drop by and share that since asking this question this problem has come up a number of times (incidentally, my boss said he found this question via Google once while trying to solve it himself.) We have used this solution a number of times, so thanks again.Schreiber
I think this is a good question to know. You expect these semantics if you ever had to do anything from the EJB2 world, but they may seem a little foreign if you've only worked in EJB3. Another way to look at things is that you need to make sure the method you're calling is called through the EJB interface.Woman
E
4

Matt, the question you ask is a pretty classic one, I think the self-reference solution by Herval/Pascal is neat. There is a more general solution not mentioned here.

This is a case for EJB "user" transactions. Since you are in a session bean you can get the user transaction from the session context. Here's how your code will look with user transactions:

// supposing processObjects defined on MyStatelessRemote1 and process defined on MyStatelessLocal1
@Stateless
@TransationAttribute(TransactionAttributeType.NOT_SUPPORTED)
public class MyStatelessBean1 implements MyStatelessLocal1, MyStatelessRemote1 {

    @Resource
    private SessionContext ctx;

    @EJB
    private MyStatelessLocal1 myBean2;

    public void processObjects(List<Object> objs) {
        // this method just processes the data; no need for a transaction
        for(Object obj : objs) {
            this.myBean2.process(obj);
        }
    }


    public void process(Object obj) {

        UserTransaction tx = ctx.getUserTransaction();

        tx.begin();

        // do some work with obj that must be in the scope of a transaction

        this.mgr.merge(obj);
        // ...
        this.mgr.merge(obj);
        // ...
        this.mgr.flush();

        tx.commit();
    }
}
Erratum answered 17/4, 2010 at 22:6 Comment(1)
I don't like this solution. It defeats one of the advantages of EJBs container managed TXs, namely reducing manual TX management and the associated boilerplate code. There's no need for this in this case. Simply follow the accepted answer, OR, you can use the session context like so: ctx.getBusinessObject(MyStatelessLocal1.class).process(obj); and you will have the same effect as injecting yourself.Matejka
M
2

I think the thing is each bean is wrapped in a proxy that controls the transactional behaviour. When you call from one bean to another, you're going via that bean's proxy and the transaction behaviour can be changed by the proxy.

But when a bean calls a method on itself with a different transaction attribute, the call doesn't go via the proxy, so the behaviour doesn't change.

Meaghan answered 4/12, 2008 at 16:32 Comment(1)
By that, the bean could call itself to get that behavior, as if it was from another bean.Directions
R
1

Matt, for what it's worth I've come to exactly the same conclusion as you.

TransactionAttributeTypes are only taken into consideration when crossing Bean boundaries. When calling methods within the same bean TransactionAttributeTypes have no effect, no matter what Types are put on the methods.

As far as I can see there is nothing in the EJB Persistence Spec that specifies what the behaviour should be under these circumstances.

I've also experienced this in Jboss. I'll also give it a try in Glassfish and let you know the results.

Roselba answered 4/12, 2008 at 16:15 Comment(0)
W
1

In case someone comes across this one day:

to avoid circular dependencies (allowing self reference for example) in JBoss use the annotation 'IgnoreDependency' for example:

@IgnoreDependency @EJB MySelf myselfRef;

Weinstein answered 7/5, 2010 at 19:9 Comment(1)
This was a workaround for JBoss only. It went away as of AS6.Matejka
P
1

I haven't tried it yet (I'm about to), but an alternative to injecting a self-reference via the @EJB annotation is the SessionContext.getBusinessObject() method. This would be another way to avoid the possibility of a circular reference blowing things up on you - although at least for stateless beans injection does seem to work.

I'm working on a large system in which both techniques are employed (presumably by different developers), but I'm not sure which is the "correct" way to do it.

Pradeep answered 11/4, 2012 at 15:25 Comment(0)
W
0

I think has to do with the @TransationAttribute(TransactionAttributeType.Never) on method processObjects.

TransactionAttributeType.Never

http://docs.sun.com/app/docs/doc/819-3669/6n5sg7cm3?a=view

If the client is running within a transaction and invokes the enterprise bean’s method, the container throws a RemoteException. If the client is not associated with a transaction, the container does not start a new transaction before running the method.

I assume that you are client the method processObjects from the client code. Because probably your client is not associated with a transaction the method call with TransactionAttributeType.Never is happy in the first place. Then you call the process method from processObjects that altough having the TransactionAttributeType.Required annotation was not a bean method call and the transaction policy is not enforced. When you call merge you get the exception because you are still not associated with a transaction.

Try using TransactionAttributeType.Required for both bean methods to see if it does the trick.

Wavelength answered 20/9, 2008 at 0:1 Comment(1)
As I understand it smink you miss the point. Matt doesn't want processObjects to run in a transation (which would be the case if he set TransactionAttributeType.Required on processObjects), he wants many individual transactions for the process method.Roselba
S
0

I had these circular dependency issues which Kevin mentioned. However, the proposed annotation @IgnoreDependency is a jboss-specific annotation and there is no counterpart in e.g Glassfish.

Since it does not work with default EJB reference, I felt a bit uncomfortable with this solution.

Therefore, I gave bluecarbon's solution a chance, thus starting the inner transaction "by hand".

Beside this, I see no solution but to implement the inner process() in another bean which is also ugly because we simply want to disturb our class model for such technical details.

Sensorimotor answered 26/9, 2011 at 14:31 Comment(1)
@IgnoreDependency no longer applies to JBoss, it was kind of a hack workaround and is no longer needed as of AS6. Glassfish never had this problem and never needed such a workaround.Matejka

© 2022 - 2024 — McMap. All rights reserved.