EntityBean Transcation inside UserTranscation

[jigara shah]

I have a method in java class which uses UserTransaction and within transaction it calls enitiy bean create() (It creates a row in database). Now just incase if i roll back this transaction then it does not rollback entity created in entity bean.

structure of the code is something like this....

method () {
try {
userTransaction.begin()
 
entitybean1.create()
entitybean2.create()
 
} catch (e) {
userTransaction.setrollbackonly()
} finally {
 
if (userTransaction == ROLLBACK )
userTransaction.rollback()
else
userTransaction.commit()
}
 
}

Transaction attribute for entity bean is Required.

<container-transaction>
<method>
<ejb-name>Subscriber</ejb-name> (Entity Bean)
<method-name>*</method-name>
</method>
<trans-attribute>*Required*</trans-attribute>
</container-transaction> 

[Scott Selikoff]

The transactional XML attributes only come into play if you are using Container Management Transactions (CMT). If you are creating/starting transactions on your own, or bean managed transaction (BMT), the behavior is completely up to you.

[jigara shah]

Originally posted by Scott Selikoff:
The transactional XML attributes only come into play if you are using Container Management Transactions (CMT). If you are creating/starting transactions on your own, or bean managed transaction (BMT), the behavior is completely up to you.

Yes i get that. But my question is, I am calling a method which has CMT inside a method (in a separate class) which is under Usertransaction. Then it should join User transaction right ?

In summary i am trying to figureout "Will calling EnitiyBean create() method which is under CMT; will join User transaction if its called from that transaction ?"


ClassA {
UT.begin
ejbCreate();
UT.end
}




//Under CMT
EntityBeanClassB {
ejbCreate();
}
[ July 10, 2008: Message edited by: jigara shah ]

[Scott Selikoff]

It should join the transaction, although depending on your ejb version and server it may throw an exception. Why don't you try and see for yourself? Best way to learn is to try it out.

[jigara shah]

I tried but it does not join. so i am trying to figure out some test which can explain me why this has happened.

[jigara shah]

 public void handleServiceSubscription(List<ServiceSubscriptionRequest> requests) throws ServiceHandlerException
{
    UserTransactionentityTransaction = null;
    SubscriberHome subscriberEntity = null;
ServiceSubscriptionHome subscriptionEntity = null;
try {
subscriberEntity = getSubscriberEntity();
subscriptionEntity = getSubscriptionEntity();
entityTransaction = getUserTransaction();
} catch (Exception e) {
logger.error("Unable to get Subscriber entity bean for Service persistence", e);
throw new ServiceHandlerException(
"Unable to get Subscriber bean for Service persistence",
"No Subscriber entity in Service", "Unable to find entity bean",
true);
}
 
try {
[B]entityTransaction.begin();[/B]
for (ServiceSubscriptionRequest request: requests) {
inteventType = IProvisioningEventHandler.PROVISION_MODIFY_EVENT;
Subscriber foundSubscriber = null;
ServiceSubscriptionfoundService = null;
SubscriberDatasubscriber = request.getSubscriberData();
ServiceSubscriptionData subscription = request.getSubscriptionData();

try { // Find existing subscriber and update
foundSubscriber = subscriberEntity.findByPrimaryKey(subscriber.getSubscriberId());
subscriber.setDirty();
foundSubscriber.setData(subscriber);
} catch (FinderException e) { // If the subscriber is new create it
logger.debug("Subscriber does not exist - must create it - subscriberId/accountId=" + subscriber.getSubscriberId() + "/" + subscriber.getAccountId(), e);
SubscribernewSubscriber = null;
try {
[B]newSubscriber = subscriberEntity.create(subscriber);[/B]
updateSubscriberId(subscriber.getSubscriberId(), newSubscriber.getData().getSubscriberId());
throw new Exception();
} catch (CreateException createEx) {
logger.error("Unable to create account record for subscriberId/accountId=" + subscriber.getSubscriberId() + "/" + subscriber.getAccountId(), createEx);
}
eventType = IProvisioningEventHandler.PROVISION_ADD_EVENT;
}

try { // Find existing subscription and update
foundService = subscriptionEntity.findByPrimaryKey(subscription.getServiceSubscriptionId());
subscription.setDirty();
foundService.setData(subscription);
} catch (FinderException e) { // If the subscription is new create it
logger.debug("Subscription does not exist - must create it - subscriberId/accountId=" + subscriber.getSubscriberId() + "/" + subscriber.getAccountId(), e);
ServiceSubscriptionnewSubscription = null;

try {
newSubscription = subscriptionEntity.create(subscription);
updateSubscriptionId(subscription.getServiceSubscriptionId(), newSubscription.getData().getServiceSubscriptionId());
} catch (CreateException createEx) {
logger.error("Unable to create subscription record for subscriberId/accountId=" + subscriber.getSubscriberId() + "/" + subscriber.getAccountId(), createEx);
}
eventType = IProvisioningEventHandler.PROVISION_ADD_EVENT;
}

//
// Forward events to service specific handlers
forwardEventToService(eventType, subscriber, subscription);
}
} catch (Exception e) {
logger.error("Unable update Subscriber and ServiceSubscription change events to sync database, transaction will be marked for rolledback", e);
try {
[B] entityTransaction.setRollbackOnly();[/B]
 } catch (SystemException se) {
 logger.error("Error while setting transaction for rollback", se);
 }
 
throw new ServiceHandlerException(
"Unable update Subscriber and ServiceSubscription change events to sync database",
"Transaction failure", "Transaction failure",
true);
} finally {
try {
[B]if (entityTransaction.getStatus() == Status.STATUS_MARKED_ROLLBACK)[/B] {
logger.error("handleServiceSubscription::rollingback transaction [" + entityTransaction + "]");
[B]entityTransaction.rollback();[/B]
} else {[B]
entityTransaction.commit();[/B]
}
} catch(Exception e) {
logger.error("Unable commit Subscriber and ServiceSubscription change events to sync database", e);
}
}
}
    

[ July 10, 2008: Message edited by: jigara shah ]