Hi Tom,

As I said, currently I am not looking into the remote call part. Now I am just accessing different datasources in a single transaction. So I don't have any remote call. I am directly calling the service method of another module which is in the same instance but uses another datasource.

@Autowired
private ModuleService moduleService;
@Transactional
public void testModularFlow(LocalVO localVO) {
    ModuleVO vo = new ModuleVO();
    vo.setId("1");
    vo.setNumberField(121);
    vo.setStringField("aaa");
    moduleService.addModule(vo); //this will insert data in another datasource
    localDAO.addLocal(localVO);
}

Now if I throw some exception in the addLocal() method, data inserted in addModule() is always getting persisted.

Also, sorry to say I am not aware of jbossts-properties.xml. It was not mentioned in the server-integration-guide.

We are trying to implement some jts mechanism which can be used irrespective of the jee container. That is why we are trying out this in the Tomee container.

Edit: Actually I tested in now without the moduleService.addModule() call and added an exception in the service method. Now localVO object is getting persisted no matter what. So @Transactional is not working in a single method itself. I am really confused now.

@Transactional
public void testModularFlow(LocalVO localVO) {
    ModuleVO vo = new ModuleVO();
    vo.setId("1");
    vo.setNumberField(121);
    vo.setStringField("aaa");
    localDAO.addLocal(localVO); //This is always persisted. @Transactional is having no effect.
    throw new Exception("test");
}

So I think the problem is with my datasource definition itself. How to integrate the TransactionalDriver mentioned by Michael in this configuration?

Hi Michael,

Do you mean to say I have to define another datasource and not the one I have defined in the Resource tag?

I have seen the jts remotebank trailmap ( quickstart/ArjunaJTS/trailmap/src/main/java/com/arjuna/demo/jts/remotebank at master · jbosstm/quickstart · GitHub ) but don't know how to use a similar setup with spring.

Hi Amos,

Thanks for the configuration. Using TransactionalDriver I was able to make jta work. Thanks tomjenkinson and mmusgrov for the suggestions.

As I was using jndi, I had to set the jtaManaged property in my Resource to false and added the datasource configuration using  TransactionalDriver and there I referenced the jndi resource. This is my config which finally made it work.

Resource in context.xml

<Resource name="jdbc/NGADataSourceAppln" auth="Container"
  type="javax.sql.DataSource" maxActive="100" maxIdle="30" maxWait="10000"
  description="Newgen sample application" username="app"
  password="a" driverClassName="org.apache.derby.jdbc.ClientXADataSource" JtaManaged="false" databaseName="GEMSDB"
  url="jdbc:derby://localhost:1527/GEMSDB;create=true" />

Datasource config as spring bean

<bean id="dataSource1"
  class="org.springframework.jdbc.datasource.DriverManagerDataSource">
  <property name="driverClassName">
  <value>com.arjuna.ats.jdbc.TransactionalDriver</value>
  </property>
  <property name="url" value="jdbc:arjuna:java:comp/env/jdbc/NGADataSourceAppln" />
  <property name="username" value="app" />
  <property name="password" value="a" />
 </bean>

As single instance multi-datasource jta is working fine, I am moving on to try jts across multiple instances. As we already have spring remoting over rmi in our application, we were hoping we could make this work using spring remoting over rmi-iiop. Am I right in thinking that way?
Is there any suggestions/examples from your part on how to integrate spring remoting with iiop so that jts will work?

Also can we continue this discussion here?

Hi Tom,

So I continued with my research and using spring rmi remoting and taking ideas from the trailmap I made jts in multiple instances work. But I am not sure whether it is the correct approach or not. In the client, I took the org.omg.CosTransactions.Control object from the current transaction(OTSManager.get_current()), converted it to IOR string and passed to the server using spring rmi. At the server side, I converted the string back to Control object and called OTSManager.get_current().resume() method passing the control. That approach seems to work. But as this is an explicit way of control propagation, I don't know what more need to be done(like suspend etc..). Can you please check and give some pointers.

This is my code and configs:

Client

bean

<bean id="helloService" class="org.springframework.remoting.rmi.RmiProxyFactoryBean">
  <property name="serviceUrl" value="rmi://localhost:2222/helloWorldService" />
  <property name="serviceInterface"
  value="com.test.remote.IRemote" />
 </bean>

Calling code

@Autowired
 private IRemote helloService;
public void callingMethod(){
     ORB myORB = com.arjuna.orbportability.ORB.getInstance("ClientSide");
     Control controlObj = OTSManager.get_current().get_control();

     String control = myORB.orb().object_to_string(controlObj);

     System.out.println(helloService.getMsg(control));
}

Server

Spring bean

<bean class="org.springframework.remoting.rmi.RmiServiceExporter">
  <property name="serviceName" value="helloWorldService" />
  <property name="service" ref="helloWorldService" />
  <property name="serviceInterface"
  value="com.test.remote.IRemote" />
  <property name="registryPort" value="2222" />
</bean>

Interface

public interface IRemote {
  public String getMsg(String control);
}

Implementation

public class RemoteImpl implements IRemote {
    @Autowired
    RemoteService service; //service interface having mandatory transactional method
    @Override
    public String getMsg(String control) {
          ORB myORB = com.arjuna.orbportability.ORB.getInstance("ServerSide");
          Control controlObj = ControlHelper.narrow(myORB.orb().string_to_object(control));
          OTSManager.get_current().resume(controlObj);
          service.invokeService("test"); //method with @Transactional set as mandatory
          return "success";
    }
}

So our idea is to explicitly transfer Control object and make use of jts.

In this setup, spring as such is not using any specific ORB afaik because spring is used only for RMI. The only ORB part written by me is in the setup code(as part of an initializing bean).

com.arjuna.orbportability.ORB myORB = com.arjuna.orbportability.ORB.getInstance("ClientSide");
com.arjuna.orbportability.RootOA myOA = com.arjuna.orbportability.OA.getRootOA(myORB);
myORB.initORB(new String[]{}, null);
myOA.initOA();
ORBManager.setORB(myORB);
ORBManager.setPOA(myOA);

Similar for the server with name "ServerSide". This orb is used for IOR conversion and back of the Control object.

Initially I tried using implicit propagation using spring rmi-iiop taking clues from this book. But I had to start a separate orbd service as a name server as mentioned in the book(I couldn't find a way without starting a name server). But even after that, implicit propagation didn't happen. Maybe because I didn't register the interceptors. But I don't know what ORB interceptors are used by spring internally. Because of all these issues, I went with the explicit propagation. So is there some issue with my current explicit propagation code?

Hi Micheal and tomjenkinson,

As specified in that thread, implicit propagation using spring rmi iiop is not clear. So we are thinking of moving on with the explicit propagation.

Even though my current code using explicitly propagating Control IOR is working fine, I am not sure whether I am missing something extra. So can anyone of you please tell me whether I am right in propagating the Control object and resuming the transaction it in the server side using Current and Control. If not, please tell me what more should I do.