Java / Oracle SOA blog

EJB Session Bean Security in Weblogic

2009-12-22T15:58:00.013+01:00

With Weblogic it is relative easy to protect your deployed EJB's by adding roles. These roles are mapped to WLS groups or users. In this blog I will show you, how you can protect for example the EJB Session beans.
I will start with securing an EJB3 Session Bean and later on in this article I will do the same only then in 2.1 way ( ejb-jar ).

First we create the Remote interface ( JDeveloper can create the EJB Session bean and remote or local interface for you )


package nl.whitehorses.ejb.security.services;

import java.util.List;
import javax.ejb.Remote;

import nl.whitehorses.ejb.security.entities.Departments;

@Remote
public interface HrModelSessionEJB {
  Departments mergeDepartments(Departments departments);

  List<Departments> getDepartmentsFindAll();
}

Create the EJB Session Bean. First we can optional add the @Resource annotation ( SessionContext ctx ) so we can retrieve the principal ( ctx.getCallerPrincipal) or check if the principal has the right role ( ctx.isCallerInRole )
To protect the Session bean methods we can add the @RolesAllowed or @PermitAll annotation ( @RolesAllowed({"adminsEJB"}) )


package nl.whitehorses.ejb.security.services;

import java.security.Principal;

import java.util.List;

import javax.annotation.Resource;

import javax.annotation.security.RolesAllowed;

import javax.ejb.Remote;
import javax.ejb.SessionContext;
import javax.ejb.Stateless;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;

import nl.whitehorses.ejb.security.entities.Departments;


@Stateless(name = "HrModelSessionEJB", mappedName = "EJB_Security-HrModel-HrModelSessionEJB")
@Remote
public class HrModelSessionEJBBean implements HrModelSessionEJB {
  @PersistenceContext(unitName="HrModel")
  private EntityManager em;

  public HrModelSessionEJBBean() {
  }

  @Resource SessionContext ctx;

  @RolesAllowed({"adminsEJB"})
  public Departments mergeDepartments(Departments departments) {
      return em.merge(departments);
  }

  @RolesAllowed({"adminsEJB","usersEJB"})
  public List<Departments> getDepartmentsFindAll() {
      Principal cp = ctx.getCallerPrincipal();
      System.out.println("getname:" + cp.getName());
      if ( ctx.isCallerInRole("adminsEJB")) {
          System.out.println("user has admins role");
      }
      return em.createNamedQuery("Departments.findAll").getResultList();
  }
}

The last thing we need to do is to add the weblogic ejb deployment descriptor ( weblogic-ejb-jar ) , This maps the EJB roles to users or groups in Weblogic Security Realm ( myrealm ). Do manually or use JDeveloper 11g R1 PS1, this version has a nice visual editor for the weblogic descriptors files.
The role-name must match with the roles names used in RolesAllowed annotation and the principal-name must match with a user or role in Weblogic Security Realm.


<?xml version = '1.0' encoding = 'windows-1252'?>
<weblogic-ejb-jar xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
                xsi:schemaLocation="http://www.bea.com/ns/weblogic/weblogic-ejb-jar http://www.bea.com/ns/weblogic/weblogic-ejb-jar/1.0/weblogic-ejb-jar.xsd"
                xmlns="http://www.bea.com/ns/weblogic/weblogic-ejb-jar">
<weblogic-enterprise-bean>
  <ejb-name>HrModelSessionEJB</ejb-name>
  <stateless-session-descriptor/>
  <enable-call-by-reference>true</enable-call-by-reference>
</weblogic-enterprise-bean>
<security-role-assignment>
  <role-name>usersEJB</role-name>
  <principal-name>scott</principal-name>
</security-role-assignment>
<security-role-assignment>
  <role-name>adminsEJB</role-name>
  <principal-name>edwin</principal-name>
</security-role-assignment>
</weblogic-ejb-jar>

Deploy your Session Bean to the Weblogicserver. In the Weblogic console we can check the permissions by going to the EJB deployment.
Check the EJB roles
Which WLS users or groups are connected to the EJB role

check the permissions of the Session methods.

Now we only have to make a test client and change the java.naming.security.principal property.


package nl.whitehorses.ejb.security.test;

import java.util.List;

import java.util.Properties;

import javax.naming.Context;
import javax.naming.InitialContext;

import nl.whitehorses.ejb.security.entities.Departments;
import nl.whitehorses.ejb.security.services.HrModelSessionEJB;

public class HrClient {
   public HrClient() {
       try {
           Properties parm = new Properties();
           parm.setProperty("java.naming.factory.initial","weblogic.jndi.WLInitialContextFactory");
           parm.setProperty("java.naming.provider.url","t3://localhost:7101");
           parm.setProperty("java.naming.security.principal","edwin");
           parm.setProperty("java.naming.security.credentials","weblogic1");
           final Context context =  new InitialContext(parm);

           HrModelSessionEJB hr = (HrModelSessionEJB)context.lookup("EJB_Security-HrModel-HrModelSessionEJB#nl.whitehorses.ejb.security.services.HrModelSessionEJB");

           for (Departments departments : (List<Departments>)hr.getDepartmentsFindAll()) {
               System.out.println( "departmentId = " + departments.getDepartmentId() );
               System.out.println( "departmentName = " + departments.getDepartmentName() );
               System.out.println( "locationId = " + departments.getLocationId() );
           }
       } catch (Exception ex) {
           ex.printStackTrace();
       }
   }

   public static void main(String[] args) {
       HrClient hrClient = new HrClient();
   }
}

The EJB 2.1 way is a bit different, now we need the use the ebj-jar.xml and this requires an remote home interface. So first we need to create this.


package nl.whitehorses.ejb.security.services;

import java.rmi.RemoteException;

import javax.ejb.CreateException;
import javax.ejb.EJBHome;

public interface HrModelSessionEJBHome extends EJBHome {
  HrModelSessionEJB create() throws RemoteException, CreateException;
}

The remote interface is also different then its 3.0 version.


package nl.whitehorses.ejb.security.services;

import java.rmi.RemoteException;
import java.util.List;
import javax.ejb.EJBObject;

import nl.whitehorses.ejb.security.entities.Departments;

public interface HrModelSessionEJB extends EJBObject {
    Departments mergeDepartments(Departments departments) throws RemoteException;

    List<Departments> getDepartmentsFindAll() throws RemoteException;
}

The EJB Session Bean


package nl.whitehorses.ejb.security.services;

import java.security.Principal;

import java.util.List;
import javax.annotation.Resource;

import javax.ejb.EJBHome;
import javax.ejb.EJBObject;
import javax.ejb.Handle;
import javax.ejb.Init;
import javax.ejb.Remote;
import javax.ejb.RemoteHome;
import javax.ejb.Remove;
import javax.ejb.SessionContext;
import javax.ejb.Stateless;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;


import nl.whitehorses.ejb.security.entities.Departments;

@Stateless(name = "HrModelSessionEJB", mappedName = "EJB_Security-HrModel-HrModelSessionEJB")
@Remote({HrModelSessionEJB.class})
@RemoteHome(HrModelSessionEJBHome.class)
public class HrModelSessionEJBBean implements HrModelSessionEJB {
    @PersistenceContext(unitName="HrModel")
    private EntityManager em;

    public HrModelSessionEJBBean() {
    }

    @Resource SessionContext ctx;


    public Departments mergeDepartments(Departments departments) {
        return em.merge(departments);
    }

    /** <code>select o from Departments o</code> */
    public List<Departments> getDepartmentsFindAll() {
        Principal cp = ctx.getCallerPrincipal();
        System.out.println("getname:" + cp.getName());
        if ( ctx.isCallerInRole("adminsEJB")) {
            System.out.println("user has admins role");
        }
        return em.createNamedQuery("Departments.findAll").getResultList();
    }

    @Init
    public void create(){};
    
    @Remove
    public void remove(){};


    public EJBHome getEJBHome() {
        return null;
    }

    public Object getPrimaryKey() {
        return null;
    }

    public Handle getHandle() {
        return null;
    }

    public boolean isIdentical(EJBObject ejbObject) {
        return false;
    }
}

We can use the same weblogic-ejb-jar.xml, now we only need to create ebj-jar.xml descriptor. This descriptor does the same as the RolesAllowed annotation


<?xml version = '1.0' encoding = 'windows-1252'?>
<ejb-jar xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://java.sun.com/xml/ns/javaee/ejb-jar_3_0.xsd"
         version="3.0" xmlns="http://java.sun.com/xml/ns/javaee">
  <enterprise-beans>
    <session>
      <ejb-name>HrModelSessionEJB</ejb-name>
      <home>nl.whitehorses.ejb.security.services.HrModelSessionEJBHome</home>
      <remote>nl.whitehorses.ejb.security.services.HrModelSessionEJB</remote>
      <ejb-class>nl.whitehorses.ejb.security.services.HrModelSessionEJBBean</ejb-class>
      <session-type>Stateless</session-type>
      <transaction-type>Container</transaction-type>
      <security-role-ref>
        <role-name>usersEJB</role-name>
      </security-role-ref>
      <security-role-ref>
        <role-name>adminsEJB</role-name>
      </security-role-ref>
    </session>
  </enterprise-beans>
  <assembly-descriptor>
    <security-role>
      <role-name>usersEJB</role-name>
    </security-role>
    <security-role>
      <role-name>adminsEJB</role-name>
    </security-role>
    <method-permission>
      <role-name>usersEJB</role-name>
      <role-name>adminsEJB</role-name>
      <method>
        <ejb-name>HrModelSessionEJB</ejb-name>
        <method-name>getDepartmentsFindAll</method-name>
      </method>
    </method-permission>
    <method-permission>
      <role-name>adminsEJB</role-name>
      <method>
        <ejb-name>HrModelSessionEJB</ejb-name>
        <method-name>mergeDepartments</method-name>
      </method>
    </method-permission>
  </assembly-descriptor>
</ejb-jar>

And the test client.


package nl.whitehorses.ejb.security.test;

import java.util.List;

import java.util.Properties;

import javax.naming.Context;
import javax.naming.InitialContext;

import nl.whitehorses.ejb.security.entities.Departments;
import nl.whitehorses.ejb.security.services.HrModelSessionEJB;
import nl.whitehorses.ejb.security.services.HrModelSessionEJBHome;

public class HrClient {
    public HrClient() {
        try {
            Properties parm = new Properties();
            parm.setProperty("java.naming.factory.initial","weblogic.jndi.WLInitialContextFactory");
            parm.setProperty("java.naming.provider.url","t3://localhost:7101");
            parm.setProperty("java.naming.security.principal","edwin");
            parm.setProperty("java.naming.security.credentials","weblogic1");
            final Context context =  new InitialContext(parm);

            HrModelSessionEJBHome hRSessionEJB = (HrModelSessionEJBHome)context.lookup("EJB_Security-HrModel-HrModelSessionEJB#nl.whitehorses.ejb.security.services.HrModelSessionEJBHome");
            HrModelSessionEJB hr = hRSessionEJB.create();

            for (Departments departments : (List<Departments>)hr.getDepartmentsFindAll()) {
                System.out.println( "departmentId = " + departments.getDepartmentId() );
                System.out.println( "departmentName = " + departments.getDepartmentName() );
                System.out.println( "locationId = " + departments.getLocationId() );
            }


        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    public static void main(String[] args) {
        HrClient hrClient = new HrClient();
    }

}

Here is the example workspace

SCA Spring in Weblogic 10.3.2 & Soa Suite 11g Part 2

2009-12-14T21:38:00.007+01:00

In my previous post I made a SCA Spring example and deployed this on Weblogic 10.3.2 Now it is time to use the same spring context and java sources in a Soa Suite 11g composite ( without any changes) . Keep in mind SCA Spring in WLS and the Spring Component in Soa Suite is still in preview and will be supported in Patch Set2 of Soa Suite 11g.
In this example I use the java Logger and BPEL component of Clemens OTN article.

First I copied the java sources from my Weblogic SCA Spring project to the Soa project and created for demo purposes two Spring Bean configurations.
The first has a bean with a service and a reference and the second one has only a bean with a service. ( Off course I can combine these two together in one spring bean configuration, but this is more fun)

The first spring bean configuration will just passthrough the java call. We need to remove the WS and EJB binding in the service and reference. ( Soa Suite don't need this )


<?xml version="1.0" encoding="windows-1252" ?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:util="http://www.springframework.org/schema/util"
    xmlns:jee="http://www.springframework.org/schema/jee"
    xmlns:lang="http://www.springframework.org/schema/lang"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:sca="http://xmlns.oracle.com/weblogic/weblogic-sca">
<!--Spring 2.5 Bean defintions go here-->
<sca:service target="loggerPassThrough" name="LogServiceWS"
            type="nl.whitehorses.wls.sca.spring.ILoggerComponent">
</sca:service>

<bean class="nl.whitehorses.wls.sca.spring.LoggerPassThrough" name="loggerPassThrough">
  <property name="reference" ref="loggerEJBReference" />
</bean>

<sca:reference name="loggerEJBReference"
 type="nl.whitehorses.wls.sca.spring.ILoggerComponent">
</sca:reference>

</beans>

The second spring bean configuration is the java logger. Here we also have to remove the WS binding in the service


<?xml version="1.0" encoding="windows-1252" ?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:util="http://www.springframework.org/schema/util"
    xmlns:jee="http://www.springframework.org/schema/jee"
    xmlns:lang="http://www.springframework.org/schema/lang"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:sca="http://xmlns.oracle.com/weblogic/weblogic-sca">
<!--Spring 2.5 Bean defintions go here-->
<sca:service target="logger" name="LogServiceEJB"
            type="nl.whitehorses.wls.sca.spring.ILoggerComponent">
</sca:service>

<bean class="nl.whitehorses.wls.sca.spring.LoggerComponentImpl" name="logger">
  <property name="output" ref="loggerOutput" />
</bean>

<bean id="loggerOutput" class="nl.whitehorses.wls.sca.spring.LoggerOutput"></bean>

</beans>

Now the composite application looks like this. We need to add some wires between the BPEL and Spring Components.

Open the BPEL component and add an invoke to call the partnerlink and create the input and output variables.

Deploy the composite and test it in the Soa Suite. With this as result.
Conclusion: With the new SoaSuite Spring component it is relative easy to do a java call outs and you can exchange your SCA spring application from Weblogic to Soa Suite without any changes.

Here is my Soa Suite example workspace

SCA Spring in Weblogic 10.3.2 & Soa Suite 11g

2009-12-13T21:31:00.006+01:00

With Weblogic 10.3.2 ( part of Patch Set 1 of Fusion Middleware R1 ) Oracle released a preview of SCA Spring. For more info about this announcement see the blog of Raghav.
This is great news because everything what works in SCA Spring can be used without any problem in Soa Suite 11g. With Patch Set 2 SCA Spring will be supported in WLS or Soa Suite. For a Soa Suite Spring example see this blog of Clemens

To test this I made a small example based on the blog of Clemens. In this test I will call a logging webservice and this service will pass the call to a passthrough bean which has a reference to an logging EJB service which calls a logging bean and this bean has an other bean injected which does the output.

First deploy the weblogic-sca war as a library to the WLS server, you can find this war in wlserver_10.3/common/deployable-libraries/ folder and is called weblogic-sca-1.0.war

Create in JDeveloper a new web project ( no need for ADF ) . We don't need the spring jar or add some config in the web.xml ( this can be empty , don't need to add spring listener )

Add a library reference in your webapp to the weblogic-sca library, Do this in the weblogic.xml or weblogic-application.xml file


<?xml version = '1.0' encoding = 'windows-1252'?>
<weblogic-web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
                 xsi:schemaLocation="http://www.bea.com/ns/weblogic/weblogic-web-app http://www.bea.com/ns/weblogic/weblogic-web-app/1.0/weblogic-web-app.xsd"
                 xmlns="http://www.bea.com/ns/weblogic/weblogic-web-app">
   <library-ref>
       <library-name>weblogic-sca</library-name>
   </library-ref>
</weblogic-web-app>

Create a spring from jdeveloper and call this file spring-context.xml and put this in META-INF/jsca folder ( in the src folder )
When you got experience with Apache Tuscany then this spring configuration is not so difficult.


<?xml version="1.0" encoding="windows-1252" ?>
<beans xmlns="http://www.springframework.org/schema/beans"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xmlns:sca="http://xmlns.oracle.com/weblogic/weblogic-sca"
      xmlns:wlsb="http://xmlns.oracle.com/weblogic/weblogic-sca-binding"
      xmlns:wsp="http://schemas.xmlsoap.org/ws/2004/09/policy"
      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://xmlns.oracle.com/weblogic/weblogic-sca http://xmlns.oracle.com/weblogic/weblogic-sca/1.0/weblogic-sca.xsd http://xmlns.oracle.com/weblogic/weblogic-sca-binding http://xmlns.oracle.com/weblogic/weblogic-sca-binding/1.0/weblogic-sca-binding.xsd">
 <!--Spring 2.5 Bean defintions go here-->
 <sca:service target="loggerPassThrough" name="LogServiceWS"
              type="nl.whitehorses.wls.sca.spring.ILoggerComponent">
   <wlsb:binding.ws xmlns="http://xmlns.oracle.com/sca/1.0"
               name="LoggerService_WS" uri="/LoggerService_Uri"
               port="LoggerService_PORT"/>
 </sca:service>

 <sca:reference name="loggerEJBReference"
 type="nl.whitehorses.wls.sca.spring.ILoggerComponent">
   <wlsb:binding.ejb uri="LoggerService_EJB30_JNDI" />
 </sca:reference>

 <bean class="nl.whitehorses.wls.sca.spring.LoggerPassThrough" name="loggerPassThrough">
    <property name="reference" ref="loggerEJBReference" />
 </bean>

 <sca:service target="logger" name="LogServiceEJB"
              type="nl.whitehorses.wls.sca.spring.ILoggerComponent">
   <wlsb:binding.ejb uri="LoggerService_EJB30_JNDI" remote="true"
                     name="LoggerService_EJB"/>
 </sca:service>

 <bean class="nl.whitehorses.wls.sca.spring.LoggerComponentImpl" name="logger">
    <property name="output" ref="loggerOutput" />
 </bean>

 <bean id="loggerOutput" class="nl.whitehorses.wls.sca.spring.LoggerOutput"></bean>

</beans>

Now we need to create a logger interface, this will be use by the WS & EJB services and references.


package nl.whitehorses.wls.sca.spring;

public interface ILoggerComponent
{
   
    /**
     * Log a message, including the originating component, its instance id and
     * a message.
     * @param pComponentName the name of the component that sends this log msg
     * @param pInstanceId the instanceId of the component instance
     * @param pMessage the message to be logged
     */
    public void log (String pComponentName,
                     String pInstanceId, String pMessage);
}

Create a passthrough class this will pass on the logger call to the ejb service.


package nl.whitehorses.wls.sca.spring;

public class LoggerPassThrough implements ILoggerComponent {
    public LoggerPassThrough() {
        super();
    }

    @Override
    public void log(String pComponentName, String pInstanceId,
                    String pMessage)  {
    
       reference.log(pComponentName, pInstanceId, pMessage);
    }

    private ILoggerComponent reference;

    public void setReference(ILoggerComponent reference) {
        this.reference = reference;
    }

    public ILoggerComponent getReference() {
        return reference;
    }

}

Create the logger implementation class.


package nl.whitehorses.wls.sca.spring;

public class LoggerComponentImpl implements ILoggerComponent {
    public LoggerComponentImpl() {
        super();
    }

    @Override
    public void log(String pComponentName, String pInstanceId,
                    String pMessage)  {
       output.logToConsole(pComponentName, pInstanceId, pMessage);
    }

    private LoggerOutput output;

    public void setOutput(LoggerOutput output) {
        this.output = output;
    }

    public LoggerOutput getOutput() {
        return output;
    }
}

The last class prints the console output


package nl.whitehorses.wls.sca.spring;

public class LoggerOutput {
    public LoggerOutput() {
        super();
    }
    
    public void logToConsole(String pComponentName, String pInstanceId,  String pMessage)
    {
        StringBuffer logBuffer = new StringBuffer ();
        logBuffer.append("[").append(pComponentName).append("] [Instance: ").
            append(pInstanceId).append("] ").append(pMessage);
        
        System.out.println(logBuffer.toString());
    }
}

Deploy the web application the weblogic server and use soapui to test the service. The wsdl url is in my case http://laptopedwin.wh.lan:7001/WlsSpring-ScaSpring-context-root/LoggerService_Uri?WSDL or make a EJB test client and use this ILoggerComponent logger = (ILoggerComponent)context.lookup("LoggerService_EJB30_JNDI");

Here you can download my example workspace.

ADF Data push with Active Data Service

2009-12-05T23:34:00.010+01:00

With Patch Set 1 of JDeveloper 11G we can push data to the JSF page. This is called Active Data Service and this works with the following JSF component

activeCommandToolbarButton
activeImage
activeOutputText
table
tree
All DVT components

One requirement for this feature is you need to have a Datasource who supports data push. For example the BAM server of the Soa Suite support this. For other cases you need to use the Active Data Proxy framework. In this blog I made a demo with 3 different working examples , The first is an example of Oracle this in the fusion demo and can be downloaded here , the second is the one of Matthias Wessendorf and the last is the one of the Oracle ADS documentation example which works with a EJB datacontol.

In the next weeks I will make an ADS example with EJB and JMS, The ADS Page components will then listen on a topic for EJB data change events and refreshes the page with push .

But first let me show what you need to do.
Configure the adf-config.xml , located in the .adf\META-INF folder ( workspace level). With this ADF file you can configure the push parameters, study these parameters because they can influence the application performance.


<?xml version="1.0" encoding="windows-1252" ?>
<adf-config xmlns="http://xmlns.oracle.com/adf/config"
       xmlns:sec="http://xmlns.oracle.com/adf/security/config"
       xmlns:ads="http://xmlns.oracle.com/adf/activedata/config">
<sec:adf-security-child xmlns="http://xmlns.oracle.com/adf/security/config">
<CredentialStoreContext credentialStoreClass="oracle.adf.share.security.providers.jps.CSFCredentialStore"
                       credentialStoreLocation="../../src/META-INF/jps-config.xml"/>
</sec:adf-security-child>
<ads:adf-activedata-config xmlns="http://xmlns.oracle.com/adf/activedata/config">
<!--
 transport allows three settings:
 * streaming (default)
 * polling
 * long-polling
-->
<transport>long-polling</transport>
<latency-threshold>10000</latency-threshold>
<keep-alive-interval>10000</keep-alive-interval>
<polling-interval>3000</polling-interval>
<max-reconnect-attempt-time>1800000</max-reconnect-attempt-time>
<reconnect-wait-time>10000</reconnect-wait-time>
</ads:adf-activedata-config>
</adf-config>

Then create in the .adf\META-INF folder a new folder called services and put a new file in called adf-config.properties and add the following content.
http\://xmlns.oracle.com/adf/activedata/config=oracle.adfinternal.view.faces.activedata.ActiveDataConfiguration$ActiveDataConfigCallback

Go to your JSF page and drag and drop for example departments from your datacontrol to your page. Choose a readonly table ( when you want to use inputtext instead of outputtext JSF components then keep in mind you need to reset the uicomponent else it won't get the new value ) and don't use Filtering on the table.
This is how your JSF can look like.


           <af:table value="#{bindings.departmentsFindAll.collectionModel}"
                     var="row"
                     rows="#{bindings.departmentsFindAll.rangeSize}"
                     emptyText="#{bindings.departmentsFindAll.viewable ? 'No data to display.' : 'Access Denied.'}"
                     fetchSize="#{bindings.departmentsFindAll.rangeSize}"
                     rowBandingInterval="0"
                     selectedRowKeys="#{bindings.departmentsFindAll.collectionModel.selectedRow}"
                     selectionListener="#{bindings.departmentsFindAll.collectionModel.makeCurrent}"
                     rowSelection="single" id="t3">
             <af:column sortProperty="departmentId" sortable="true"
                        headerText="#{bindings.departmentsFindAll.hints.departmentId.label}"
                        id="c8">
               <af:outputText value="#{row.departmentId}" id="ot9">
                 <af:convertNumber groupingUsed="false"
                                   pattern="#{bindings.departmentsFindAll.hints.departmentId.format}"/>
               </af:outputText>
             </af:column>
             <af:column sortProperty="departmentName" sortable="true"
                        headerText="#{bindings.departmentsFindAll.hints.departmentName.label}"
                        id="c9">
               <af:outputText value="#{row.departmentName}" id="ot8"/>
             </af:column>
           </af:table>

Here the pagedef of the page ,we need to have a handle to the departmentsFindAll tree in our Active Data Proxy framework.


<?xml version="1.0" encoding="UTF-8" ?>
<pageDefinition xmlns="http://xmlns.oracle.com/adfm/uimodel"
            version="11.1.1.55.36" id="ADStablePageDef"
            Package="nl.whitehorses.app.view.pageDefs">
<parameters/>
<executables>
<iterator Binds="root" RangeSize="25" DataControl="CountrySessionEJBLocal"
          id="CountrySessionEJBLocalIterator"/>
<accessorIterator MasterBinding="CountrySessionEJBLocalIterator"
                  Binds="departmentsFindAll" RangeSize="25"
                  DataControl="CountrySessionEJBLocal"
                  BeanClass="nl.whitehorses.model2.Departments"
                  id="departmentsFindAllIterator"/>
</executables>
<bindings>

<tree IterBinding="departmentsFindAllIterator" id="departmentsFindAll">
  <nodeDefinition DefName="nl.whitehorses.model2.Departments"
                  Name="departmentsFindAll0">
    <AttrNames>
      <Item Value="departmentId"/>
      <Item Value="departmentName"/>
    </AttrNames>
  </nodeDefinition>
</tree>
</bindings>
</pageDefinition>

Now we can make our own DepartmentModel where we add Active Data Service to it. We need the departmentsFindAll tree attribute from the pagedef.


package nl.whitehorses.app.ads;

import oracle.adf.model.BindingContext;
import oracle.adf.model.binding.DCBindingContainer;
import oracle.adf.view.rich.model.ActiveCollectionModelDecorator;

import oracle.adf.view.rich.model.ActiveDataModel;

import oracle.adfinternal.view.faces.model.binding.FacesCtrlHierBinding;


import org.apache.myfaces.trinidad.model.CollectionModel;

public class DepartmentModel   extends ActiveCollectionModelDecorator {

 private MyActiveDataModel _activeDataModel = new MyActiveDataModel();
 private CollectionModel _model = null;


 public CollectionModel getCollectionModel() {
    if (_model == null) {
        DCBindingContainer dcBindings = (DCBindingContainer)BindingContext.getCurrent().getCurrentBindingsEntry();
        FacesCtrlHierBinding treeData = (FacesCtrlHierBinding)dcBindings.getControlBinding("departmentsFindAll");
        _model = treeData.getCollectionModel();
    }
    return _model;
  }

 public ActiveDataModel getActiveDataModel() {
      return _activeDataModel;
 }

 public MyActiveDataModel getMyActiveDataModel() {
     return _activeDataModel;
 }

}

Make your own active ActiveDataModel in which we start a thread where we fire change events.


package nl.whitehorses.app.ads;

import java.util.Collection;

import java.util.concurrent.atomic.AtomicInteger;
import oracle.adf.view.rich.activedata.BaseActiveDataModel;
import oracle.adf.view.rich.event.ActiveDataUpdateEvent;

public class MyActiveDataModel extends BaseActiveDataModel
  {
    protected void startActiveData(Collection<Object> rowKeys, int startChangeCount)
    {
      _listenerCount.incrementAndGet();
      if (_listenerCount.get() == 1)
      {
        System.out.println("start up");
 
        Runnable dataChanger = new Runnable()
        {
          public void run()
          {
            System.out.println("MyThread starting.");
            try
            {
              Thread.sleep(2000);
              System.out.println("thread running");
              Change chg = new Change();  
              chg.triggerDataChange(MyActiveDataModel.this);
            }
            catch (Exception exc)
            {
              System.out.println("MyThread exceptioned out.");
            }
            System.out.println("MyThread terminating.");
          }
        };
        Thread newThrd = new Thread(dataChanger);
        newThrd.start();
      }
    }
 
    protected void stopActiveData(Collection<Object> rowKeys)
    {
      _listenerCount.decrementAndGet();
      if (_listenerCount.get() == 0)
      {
        System.out.println("tear down");
      }
    }
 
    public int getCurrentChangeCount()
    {
      return _currEventId.get();
    }
 
    public void bumpChangeCount()
    {
      _currEventId.incrementAndGet();
    }
 
    public void dataChanged(ActiveDataUpdateEvent event)
    {
      fireActiveDataUpdate(event);
    }
 
    private final AtomicInteger _listenerCount = new AtomicInteger(0);
    private final AtomicInteger _currEventId = new AtomicInteger();
}

For demo purposes we send some change events. For this we need to know the Key of the department iterator and the attribute which changed. See the ADS help page for other events like insert ,delete etc..


package nl.whitehorses.app.ads;

import oracle.adf.view.rich.event.ActiveDataEntry;

import oracle.adf.view.rich.event.ActiveDataUpdateEvent;

import oracle.adfinternal.view.faces.activedata.ActiveDataEventUtil;
import oracle.adfinternal.view.faces.activedata.JboActiveDataEventUtil;


public class Change {
    public Change() {

    }

    public void triggerDataChange(MyActiveDataModel model) throws Exception {


      for ( int i = 0 ; i < 10 ; i++) {
        try {
            Thread.sleep(4000);
        } catch (InterruptedException ie) {
            ie.printStackTrace();
        }

        
        model.bumpChangeCount();
        
        ActiveDataUpdateEvent event =
            ActiveDataEventUtil.buildActiveDataUpdateEvent(ActiveDataEntry.ChangeType.UPDATE,
                                                           model.getCurrentChangeCount(),
                                                           JboActiveDataEventUtil.convertKeyPath(new Object[] { new Long(10) , new Integer(0)  }),
                                                           null,
                                                           new String[] { "departmentName" },
                                                           new Object[] { "Administration" });

        model.dataChanged(event);

        try {
            Thread.sleep(2000);
        } catch (InterruptedException ie) {
            ie.printStackTrace();
        }
    
        model.bumpChangeCount();
        event =
            ActiveDataEventUtil.buildActiveDataUpdateEvent(ActiveDataEntry.ChangeType.UPDATE,
                                                           model.getCurrentChangeCount(),
                                                           JboActiveDataEventUtil.convertKeyPath(new Object[] {  new Long(30), new Integer(0) }),
                                                           null,
                                                           new String[] { "departmentName" },
                                                           new Object[] { "Purchasing" });

        model.dataChanged(event);
        
    }
  }    
}

We need to add the DepartmentModel class as backing bean in the adfc-config or faces-config xml.


<managed-bean>
 <managed-bean-name>DepartmentModel</managed-bean-name>
 <managed-bean-class>nl.whitehorses.app.ads.DepartmentModel</managed-bean-class>
 <managed-bean-scope>session</managed-bean-scope>
</managed-bean>

And at last change the value attribute of the af:table to our managed bean
af:table value="#{DepartmentModel}" var="row"

Here you can download my demo workspace

Find and Expand all nodes of an ADF Tree

2009-11-19T21:33:00.003+01:00

I want to find and expand all nodes of an ADF Tree and I saw an Oracle Forum post of Kenyatta which gave me a nice solution.
First some usefull methods.


private void expandTreeChildrenNode(  RichTree rt
                                   ,  FacesCtrlHierNodeBinding node
                                   ,  List<Key> parentRowKey) {
     ArrayList children = node.getChildren();
     List<Key> rowKey;

     if ( children != null )    {
       for (int i = 0; i < children.size(); i++) {
          rowKey = new ArrayList<Key>();
          rowKey.addAll(parentRowKey);
          rowKey.add(((FacesCtrlHierNodeBinding)children.get(i)).getRowKey());
          rt.getDisclosedRowKeys().add(rowKey);
          if (((FacesCtrlHierNodeBinding)(children.get(i))).getChildren() == null)
            continue;
            expandTreeChildrenNode(rt
                                  ,(FacesCtrlHierNodeBinding)(node.getChildren().get(i))
                                  , rowKey);
          }
     } 
}

 // find a jsf component
private UIComponent getUIComponent(String name) {
     FacesContext facesCtx = FacesContext.getCurrentInstance();
     return facesCtx.getViewRoot().findComponent(name) ;
}

private UIComponent getUIComponent(UIComponent component,String name ){
     List<UIComponent> items = component.getChildren(); 
     for ( UIComponent item : items ) { 
       UIComponent found = getUIComponent(item,name);
       if ( found != null ) {
         return found; 
       }
       if ( item.getId().equalsIgnoreCase(name)  ) { 
         return item;
       }; 
     }
     return null;
}

Now find the ADF tree in a region and expand the main and child nodes of this tree


// get the dymamic region of the main page
RichRegion region = (RichRegion)getUIComponent("dynam1");

if ( region != null) {
   // find tree 2 and expand this tree 
   RichTree rt = (RichTree)getUIComponent(region,"t2");
   if ( rt != null ) {
      int rowCount = rt.getRowCount();
      List<Key> rowKey;
      for (int j = 0; j < rowCount; j++) {
         // expand the main nodes
         FacesCtrlHierNodeBinding node = (FacesCtrlHierNodeBinding)rt.getRowData(j);
         rowKey = new ArrayList<Key>();
         rowKey.add(node.getRowKey());
         rt.getDisclosedRowKeys().add(rowKey);
         rt.setRowKey(rowKey);
         // expand the child nodes of the main nodes
         expandTreeChildrenNode(rt , node, rowKey);
       }   
    }
}

Find an UIComponent in an ADF Task Flow Region

2009-11-19T21:04:00.005+01:00

When you want to find an UIComponent (like a Tree) inside an ADF Region you can not use findComponent on the ViewRoot because this will only search for the component in the JSF page and not in the JSF page fragments ( Task Flows). And off course you can use a backing bean to make a binding but I want to find the component by first searching for the right Region in the JSF page and then searching the component inside the Region.

First I need to have some common methods.


// find a jsf component inside the JSF page
private UIComponent getUIComponent(String name) {
     FacesContext facesCtx = FacesContext.getCurrentInstance();
     return facesCtx.getViewRoot().findComponent(name) ;
}

// find a UIComponent inside a UIComponent 
private UIComponent getUIComponent(UIComponent component,String name ){
  List items = component.getChildren(); 
  for ( UIComponent item : items ) { 
     UIComponent found = getUIComponent(item,name);
     if ( found != null ) {
        return found; 
      }
     if ( item.getId().equalsIgnoreCase(name)  ) { 
        return item;
     } 
  }
  return null;
}

Now we can find the right Region and then search inside the Region for the ADF Tree


// get the dymamic region of the main page
RichRegion region = (RichRegion)getUIComponent("dynam1");

if ( region != null) {
  // find tree 2 
  RichTree rt = (RichTree)getUIComponent(region,"t2");
  if ( rt != null ) {
  // do your thing
  }   
}

Soa Suite 11g MDS deploy and removal ANT scripts

2009-11-17T22:08:00.009+01:00

With the release of Soa Suite 11g R1 Patch Set 1 Oracle improved the standard ant scripts for MDS deployment and removal. Before PS1 we had an ant example of Clemens.
Basically this is how my ANT scripts works. First add your own metadata folders under the apps folder ( do this in jdeveloper\integration\seed\apps ).

My ANT script will do the following steps for every metadata folder under apps

optionally remove the metadata folder from the remote Soa Suite Database MDS repository
Make a zip file of the metadata files ( Local MDS file repository) .
Make a new Soa Bundle zip with this metadata zip
Deploy this soa bundle to the Soa Suite Server, The server will add this to the Database MDS

When you want to use the MDS files in your own project read this blog

To make this work copy the antcontrib jar to the jdeveloper\ant\lib folder ( because of the foreach and the propertycopy fucntion )
Here is my build.properties



# global
wn.bea.home=C:/oracle/MiddlewareJdev11gR1PS1
oracle.home=${wn.bea.home}/jdeveloper
java.passed.home=${wn.bea.home}/jdk160_14_R27.6.5-32
wl_home=${wn.bea.home}/wlserver_10.3

# temp
tmp.output.dir=c:/temp

mds.reposistory=C:/oracle/MiddlewareJdev11gR1PS1/jdeveloper/integration/seed/apps/
mds.applications=usarmy
mds.undeploy=true

deployment.plan.environment=dev

# dev deployment server weblogic
dev.serverURL=http://laptopedwin:8001
dev.overwrite=true
dev.user=weblogic
dev.password=weblogic1
dev.forceDefault=true

# acceptance deployment server weblogic
acc.serverURL=http://laptopedwin:8001
acc.overwrite=true
acc.user=weblogic
acc.password=weblogic1
acc.forceDefault=true

The build.xml


<?xml version="1.0" encoding="iso-8859-1"?>
<project name="soaDeployAll" default="deployMDS">
   <echo>basedir ${basedir}</echo>

   <property environment="env"/>
   <echo>current folder ${env.CURRENT_FOLDER}</echo>

   <property file="${env.CURRENT_FOLDER}/build.properties"/> 
   <taskdef resource="net/sf/antcontrib/antcontrib.properties"/>
   <import file="${basedir}/ant-sca-deploy.xml"/>

   <target name="unDeployMDS">
       <echo>undeploy MDS</echo>
       <foreach list="${mds.applications}" param="mds.application" target="undeployMDSApplication" inheritall="true" inheritrefs="false"/>
   </target>

   <target name="deployMDS">
       <echo>undeploy and deploy MDS</echo>
       <if>
         <equals arg1="${mds.undeploy}" arg2="true"/>
         <then>
           <foreach list="${mds.applications}" param="mds.application" target="undeployMDSApplication" inheritall="true" inheritrefs="false"/>
         </then>
       </if>
       <foreach list="${mds.applications}" param="mds.application" target="deployMDSApplication" inheritall="true" inheritrefs="false"/>
   </target>

   <target name="deployMDSApplication">
       <echo>deploy MDS application ${mds.application}</echo>

       <echo>remove and create local MDS temp</echo>
       <property name="mds.deploy.dir" value="${tmp.output.dir}/${mds.application}"/>
    
       <delete dir="${mds.deploy.dir}"/>
       <mkdir dir="${mds.deploy.dir}"/>

       <echo>create zip from file MDS store</echo>
      <zip destfile="${mds.deploy.dir}/${mds.application}_mds.jar" compress="false">
       <fileset dir="${mds.reposistory}" includes="${mds.application}/**"/>
     </zip>

       <echo>create zip with MDS jar</echo>
      <zip destfile="${mds.deploy.dir}/${mds.application}_mds.zip" compress="false">
       <fileset dir="${mds.deploy.dir}" includes="*.jar"/>
     </zip>

       <propertycopy name="deploy.serverURL"    from="${deployment.plan.environment}.serverURL"/>
       <propertycopy name="deploy.overwrite"    from="${deployment.plan.environment}.overwrite"/>
       <propertycopy name="deploy.user"         from="${deployment.plan.environment}.user"/>
       <propertycopy name="deploy.password"     from="${deployment.plan.environment}.password"/>
       <propertycopy name="deploy.forceDefault" from="${deployment.plan.environment}.forceDefault"/>

       <echo>deploy MDS app</echo>

       <echo>deploy on ${deploy.serverURL} with user ${deploy.user}</echo>
       <echo>deploy sarFile ${mds.deploy.dir}/${mds.application}_mds.zip</echo>

       <antcall target="deploy" inheritall="false">
            <param name="wl_home" value="${wl_home}"/>
            <param name="oracle.home" value="${oracle.home}"/>
            <param name="serverURL" value="${deploy.serverURL}"/>
            <param name="user" value="${deploy.user}"/>
            <param name="password" value="${deploy.password}"/>
            <param name="overwrite" value="${deploy.overwrite}"/>
            <param name="forceDefault" value="${deploy.forceDefault}"/>
            <param name="sarLocation" value="${mds.deploy.dir}/${mds.application}_mds.zip"/>
       </antcall> 
   </target>

   <target name="undeployMDSApplication">
       <echo>undeploy MDS application ${mds.application}</echo>

       <propertycopy name="deploy.serverURL"    from="${deployment.plan.environment}.serverURL"/>
       <propertycopy name="deploy.overwrite"    from="${deployment.plan.environment}.overwrite"/>
       <propertycopy name="deploy.user"         from="${deployment.plan.environment}.user"/>
       <propertycopy name="deploy.password"     from="${deployment.plan.environment}.password"/>
       <propertycopy name="deploy.forceDefault" from="${deployment.plan.environment}.forceDefault"/>

        <echo>undeploy MDS app folder apps/${mds.application} </echo>
        <antcall target="removeSharedData" inheritall="false">
             <param name="wl_home" value="${wl_home}"/>
             <param name="oracle.home" value="${oracle.home}"/>
             <param name="serverURL" value="${deploy.serverURL}"/>
             <param name="user" value="${deploy.user}"/>
             <param name="password" value="${deploy.password}"/>
             <param name="folderName" value="${mds.application}"/>
        </antcall>
   </target>

</project>

and at last the deployMDS.bat file


set ORACLE_HOME=C:\oracle\MiddlewareJdev11gR1PS1
set ANT_HOME=%ORACLE_HOME%\jdeveloper\ant
set PATH=%ANT_HOME%\bin;%PATH%
set JAVA_HOME=%ORACLE_HOME%\jdk160_14_R27.6.5-32

set CURRENT_FOLDER=%CD%

ant -f build.xml deployMDS -Dbasedir=%ORACLE_HOME%\jdeveloper\bin

Calling a Soa Suite Direct Binding Service from Java & OSB

2009-11-16T22:09:00.011+01:00

I was trying to connect Oracle Soa Suite 11G R1 PS1 with the OSB when I saw this new Direct Binding Service in the Soa Suite 11G. This direct binding make it possible to start this RMI service from OSB or Java. In a previous blog I already called a Soa Service from Java using the ADF binding but this direct binding makes it also possible to call this also from OSB using the SB transport . In this Blog I will call this RMI synchronous service from Java, I can not use this binding in OSB 10.3.1, probably in the next version of the OSB I can.

First we add the Direct Binding Service to exposed Services side of the composite and use the WSDL of one of the other exposed services and add a Wire to the Component.
In the source view of the composite xml you can see that this service uses the direct binding.


<service name="RMIService" ui:wsdlLocation="BPELProcess1.wsdl">
<interface.wsdl interface="http://xmlns.oracle.com/HelloWorld/Helloworld/BPELProcess1#wsdl.interface(BPELProcess1)"/>
<binding.direct/>
</service>

To see the WSDL of this service go to http://localhost:8001/soa-infra/ and select your RMI service.


package nl.whitehorses.soa.client;

import java.io.StringWriter;
import java.io.StringReader;

import java.util.Hashtable;
import java.util.Map;
import java.util.HashMap;

import javax.naming.Context;

import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;

import oracle.soa.api.PayloadFactory;
import oracle.soa.api.XMLMessageFactory;
import oracle.soa.api.invocation.DirectConnection;
import oracle.soa.api.message.Message;
import oracle.soa.api.message.Payload;

import oracle.soa.management.CompositeDN;
import oracle.soa.management.facade.Locator;
import oracle.soa.management.facade.LocatorFactory;

import org.w3c.dom.Element;
import org.w3c.dom.Node;
import org.w3c.dom.Document;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;

import org.xml.sax.InputSource;


public class StartRMIProcess {

 public StartRMIProcess() {
     super();

     Hashtable jndiProps = new Hashtable();
     jndiProps.put(Context.PROVIDER_URL, "t3://localhost:8001/soa-infra");
     jndiProps.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
     jndiProps.put(Context.SECURITY_PRINCIPAL, "weblogic");
     jndiProps.put(Context.SECURITY_CREDENTIALS, "weblogic1");
     jndiProps.put("dedicated.connection", "true");

     Locator locator = null;
     try {
         // connect to the soa server
         locator = LocatorFactory.createLocator(jndiProps);

         // find composite  default domain,  Helloworld Composite, version 1.0
         CompositeDN compositedn = new CompositeDN("default", "Helloworld", "1.0");

         // call the direct binding of the Helloworld composite
         DirectConnection conn = locator.createDirectConnection(compositedn,"RMIService");


         String inputPayload =
         "<client:process xmlns:client=\"http://xmlns.oracle.com/HelloWorld/Helloworld/BPELProcess1\">\n" +
         "   <client:input>hello</client:input>\n" +
         "</client:process>\n" ;
      
         DocumentBuilderFactory docBuilderFactory = DocumentBuilderFactory.newInstance();
         DocumentBuilder builder = docBuilderFactory.newDocumentBuilder();
         Document doc =  builder.parse(new InputSource(new StringReader(inputPayload)));
         Element  root = doc.getDocumentElement();

         //<wsdl:message name="BPELProcess1RequestMessage">
         //        <wsdl:part name="payload" element="client:process"/>
         //</wsdl:message>

         Map<String, Element> partData = new HashMap<String,Element>();
         // have to use payload see BPELProcess1RequestMessage
         partData.put("payload", root);

         Payload<Element> payload = PayloadFactory.createXMLPayload(partData);

         //Messages are created using the MessageFactory
         Message<Element> request = XMLMessageFactory.getInstance().createMessage();
         request.setPayload(payload);

         //<wsdl:portType name="BPELProcess1">
         //        <wsdl:operation name="process">
         //                <wsdl:input  message="client:BPELProcess1RequestMessage" />
         //                <wsdl:output message="client:BPELProcess1ResponseMessage"/>
         //        </wsdl:operation>
         //</wsdl:portType>
         // this is a request-reply service so we need to use conn.request else use conn.post
         // need to provide operation name so we need to use process
         Message<Element> response = conn.request("process", request);

         TransformerFactory tFactory = TransformerFactory.newInstance();
         Transformer transformer = tFactory.newTransformer();
         transformer.setOutputProperty("indent", "yes");
         StringWriter sw = new StringWriter();
         StreamResult result = new StreamResult(sw);

         //<wsdl:message name="BPELProcess1ResponseMessage">
         //        <wsdl:part name="payload" element="client:processResponse"/>
         //</wsdl:message>
         // need to use payload again
         DOMSource source =  new DOMSource((Node)response.getPayload().getData().get("payload"));

         transformer.transform(source, result);
         System.out.println("Result\n"+sw.toString());
  
     } catch (Exception e) {
         e.printStackTrace();
     }
 }

 public static void main(String[] args) {
     StartRMIProcess startRMIProcess = new StartRMIProcess();
 }
}

ADF Contextual Events in 11G R1 PS1

2009-11-14T13:54:00.023+01:00

In a previous blog I already talked about ADF events and how you can use it in the Task Flow interaction communication. With the new JDeveloper 11g Patch Set 1, Oracle really improved this event mechanism and the JDeveloper IDE support for these events.
In this blog entry I will show you the new features and give you examples of a tree and table selection Event and inputtext change Event.
First we start by adding events to the ADF application. The first way we can do it, is by selecting an af:inputtext, af:tree or af:table component . Here an example of how you can add an event to an inputtext. Contextual Events is now part of the component property window.
The second big difference is that you can change the payload of the event. You can return now what you want, for example an binding or a backing bean method. In the previous release the payload was fixed ( return of the MethodAction or the new value of an attribute). If you don't specify a payload then this is the default.
And you can restrict the events by adding a condition to the event. In this case it only fires when the value is hello
The events are registered in the pagedef of the page or fragment. This is how it can looks like.
In this case the attributeValue got a restricted event and in the bottom the default payload is changed for this event.
The pagedef editor got a Contextual Events tab, where we can add producers or subscription to an event.

Lets subscribe to this attribute event. First we need to add an MethodAction to a page or fragment. We can call this method and pass on the attribute payload. I made a java class with this method and generate a DataControl on this class.
Open the page definition and go the Subscribers tab where we add a new one subscription. We need to select the event and the publisher ( or use any ) and the handler, this is the ADF MethodAction which has 3 parameters. And we need to provide the required values for these parameters.

That's all for the Inputtext. The value is now passed on to a other page fragment.

ADF Table selection Event
We can do the same with the ADF Table component, just select the table and go to the Contextual Events part of the property window. You can now select a class and in my case is that the Department class.
To do something usefull with this Table selection event I add a method to the Java datacontrol and add this as a MethodAction to a pagedef of a page or fragment


public String tableEvent( Object payload) {
 if ( payload != null) {
   System.out.println("handle tableEvent");
   DCBindingContainerCurrencyChangeEvent event = (DCBindingContainerCurrencyChangeEvent)payload;
   DCDataRow row = (DCDataRow)event.getRow();
   if ( row.getDataProvider() instanceof Department ) {
     // do department stuff like displaying the department task flow
     Department dept = (Context.Department)row.getDataProvider();
     return "handle tableEvent for Department "+dept.getName();
   }
 } else {
      return "empty payload tableEvent";
 }
 return null;
}

Now we can add a subscription to this event and we call the above method as handler of this event.

ADF Tree Selection Event
This is almost the same as an ADF Table but now we can define more events because a tree can have different levels , In my case I made a department / employee example so I can have a department and employee event and do different things with this. For example show a department or employee Task Flow.
Here you see two events in the property window of the ADF tree. One for the department selection and one for the employees

This is how it looks like in the page defintion with an event on every level of the tree.

Here is my example workspace with Task Flows who produces these different event and the index page who pass the events on to the output Task Flow.

New features of the EJB Datatcontrol, Query panel and Range size

2009-11-12T19:48:00.008+01:00

With Patch Set 1 of JDeveloper 11G R1 Oracle improved the ADF EJB Datacontrol with two important features. We can now use this EJB Datacontrol in a Querypanel, this makes searching with EJB's a lot easier and the second big improvement is the range size option, so you don't get all the rows in one time, this can improve the performance of your ADF application and will generate less network traffic.
With JDeveloper you can generate an EJB datacontol on an EJB session bean and this Datacontol can be used in ADF. In this blog entry I will show you what the new features are and how you can do it yourself.

First we start with an entity, this is a normal entity on the country table in the HR schema ( I use the eclipselink persistence implementation, which supported very well in JDeveloper )

Next step is to create a Session Bean where we add some Facade Methods.

Here you can see that JDeveloper adds a queryByRange Facade method which we be used by ADF for the range size option.

Here you can see the Session Bean code with the queryByRange method

Generate a Datacontrol on this Session Bean,

If we now go the viewcontroller project we can use this Country EJB datacontrol ( add the EJB model project to the viewcontroller project dependency or add the EJB ADF library to the project) . In the Data Controls window you can see the Named Criteria folder in the countriesFindAll method. Drag the All Queriable Attributes on the JSF page and select the Query Panel option.
With this as result, a customizable search panel and when you configure MDS you can even save the user queries in the MDS repository.

The last feature of the EJB Datacontrol is the Range Set option. Default the ADF iterator get the data in set of 25 records ( this is a pagedef option on the iterator ). When the ADF table on the JSF view is full with rows then it won't get the rest of the rows unles you use the scrollbar or use the Next Set Operation. The Next and Previous Set are new options for the EJB Datacontrol.

Use the scrollbar or the next / previous Set button to get all the rows.

Here some eclipselink logging to let you see that is really works.

[EL Fine]: 2009-11-12 14:03:47.375--ServerSession(22965561)--SELECT COUNT(COUNTRY_ID) FROM COUNTRIES

[EL Fine]: 2009-11-12 14:03:47.39 --SELECT * FROM (SELECT /*+ FIRST_ROWS */ a.*, ROWNUM rnum FROM (SELECT COUNTRY_ID AS COUNTRY_ID1
, COUNTRY_NAME AS COUNTRY_NAME2, REGION_ID AS REGION_ID3 FROM COUNTRIES) a WHERE ROWNUM <= ?) WHERE rnum > ?
bind => [5, 0]
[EL Fine]: 2009-11-12 14:03:49.953 --SELECT * FROM (SELECT /*+ FIRST_ROWS */ a.*, ROWNUM rnum FROM (SELECT COUNTRY_ID AS COUNTRY_ID1
, COUNTRY_NAME AS COUNTRY_NAME2, REGION_ID AS REGION_ID3 FROM COUNTRIES) a WHERE ROWNUM <= ?) WHERE rnum > ?
bind => [10, 5]
[EL Fine]: 2009-11-12 14:04:39.281 --SELECT * FROM (SELECT /*+ FIRST_ROWS */ a.*, ROWNUM rnum FROM (SELECT COUNTRY_ID AS COUNTRY_ID1
, COUNTRY_NAME AS COUNTRY_NAME2, REGION_ID AS REGION_ID3 FROM COUNTRIES) a WHERE ROWNUM <= ?) WHERE rnum > ?
bind => [15, 10]

Installing Soa Suite 10.1.3.5.1 on Weblogic

2009-11-06T20:28:00.010+01:00

Yesterday Oracle released Soa Suite 10.1.3.5.1, the version which you can install on Weblogic 10.3.1 ( FMW11g version ). This is a full version so you don't early versions or extra patches to makes this work.

We need to download Weblogic 10.3.1 and Soa Suite 10.1.3.5.1

first step is to install Weblogic 10.3.1, I use C:\oracle\Soa10gWls as my wls middleware home folder

Now we can go to the Soa suite part, first we need to create a bpel, esb and wsm repository.

Extract the soa suite install zip and go to the rca folder located in ias_windows_x86_101351\Disk1\install\soa_schemas\irca

We need to set a database home for the jdbc driver.
set ORACLE_HOME=C:\oracle\product\11.1.0\db_1
We can use the jdk of the new weblogic install
set JAVA_HOME=C:\oracle\Soa10gWls\jdk160_11

Now we can start irca.bat

After a succesfull install of the repository we can start the soa suite installer in this folder ias_windows_x86_101351\Disk1

Very important the destination path must be in a folder of the just created wls middleware home so I use C:\oracle\Soa10gWls\soa10g

As weblogic home location use C:\oracle\Soa10gWls\wlserver_10.3

We are ready with the install

Now we to start script for wsm go to the C:\oracle\Soa10gWls\soa10g\config\ folder and start
configureSOA.bat

Last step is to create a Soa domain just like Soa Suite 11g and select the Soa Suite 10.1.3.5.1 option

Provide the orabpel and oraesb schema passwords.

Start the admin server and go to http://localhost:7001/console where we can take a look at the server. The soa suite server is called soa10g_server1

When we want to start the soa server we need to go the soa domain bin folder
C:\oracle\Soa10gWls\user_projects\domains\soa1013_domain\bin
and use "startManagedWebLogic.cmd soa10g_server1" to start the server.

This are the default installation url's of the Soa Suite applications
http://localhost:9700/esb
http://localhost:9700/BPELConsole
http://localhost:9700/ccore

And we need to use soaadmin as username to log in and use weblogic1 as password.

The issues that I had and luckily also solved.

Asynchronous routing fails with this error oracle.tip.esb.server.common.exceptions.BusinessEventRetriableException: Failed to enqueue deferred event "oracle.tip.esb.server.dispatch.QueueHandlerException: Publisher not exist for system "{0}"

Thanks to Juan Pablo

change the ESB_PARAMETER table on ORAESB schema the following parameters:

PROP_NAME_CONTROL_TCF_JNDI OracleASjms/ControlTCF
PROP_NAME_MONITOR_TCF_JNDI OracleASjms/MonitorTCF
PROP_NAME_ERROR_TCF_JNDI OracleASjms/ErrorTCF
PROP_NAME_ERROR_RETRY_TCF_JNDI OracleASjms/ErrorRetryTCF
PROP_NAME_DEFERRED_TCF_JNDI OracleASjms/DeferredTCF
PROP_NAME_ERROR_XATCF_JNDI OracleASjms/ErrorTCF
PROP_NAME_DEFERRED_XATCF_JNDI OracleASjms/DeferredTCF

to

PROP_NAME_CONTROL_TCF_JNDI ESB_CONTROL
PROP_NAME_MONITOR_TCF_JNDI ESB_MONITOR
PROP_NAME_ERROR_TCF_JNDI ESB_ERROR
PROP_NAME_ERROR_RETRY_TCF_JNDI ESB_ERROR_RETRY
PROP_NAME_DEFERRED_TCF_JNDI ESB_JAVA_DEFERRED
PROP_NAME_ERROR_XATCF_JNDI ESB_ERROR
PROP_NAME_DEFERRED_XATCF_JNDI ESB_JAVA_DEFERRED

and in the ESB console change the Property of Topic Location of every system to ESB_JAVA_DEFERRED

and see the comments for more fixes

Invoking Soa Suite 11g Service from java

2009-11-04T22:24:00.006+01:00

In Soa Suite 11g we can not call the composite service directly from java. We need to copy the service in the composite, change its binding to adf and wire this service to the component. All the credits goes to Jay's Blog and Clemens, Great work.

The first step is to open the composite xml and find your service.


<?xml version="1.0" encoding="UTF-8" ?>
<!-- Generated by Oracle SOA Modeler version 1.0 at [8/25/09 3:01 PM]. -->
<composite name="Helloworld"
          revision="1.0"
          label="2009-08-25_15-01-51_078"
          mode="active"
          state="on"
          xmlns="http://xmlns.oracle.com/sca/1.0"
          xmlns:xs="http://www.w3.org/2001/XMLSchema"
          xmlns:wsp="http://schemas.xmlsoap.org/ws/2004/09/policy"
          xmlns:orawsp="http://schemas.oracle.com/ws/2006/01/policy"
          xmlns:ui="http://xmlns.oracle.com/soa/designer/">
 <import namespace="http://xmlns.oracle.com/HelloWorld/Helloworld/BPELProcess1"
         location="BPELProcess1.wsdl" importType="wsdl"/>

  <service name="bpelprocess1_client_ep" ui:wsdlLocation="BPELProcess1.wsdl">
    <interface.wsdl interface="http://xmlns.oracle.com/HelloWorld/Helloworld/BPELProcess1#wsdl.interface(BPELProcess1)"/>
     <binding.ws port="http://xmlns.oracle.com/HelloWorld/Helloworld/BPELProcess1#wsdl.endpoint(bpelprocess1_client_ep/BPELProcess1_pt)">
     </binding.ws>
  </service>

Copy this service and give it a unique name and now we need to add the binding.adf binding to this service instead of the binding.ws


  <service name="bpelprocess1_client_ep" ui:wsdlLocation="BPELProcess1.wsdl">
    <interface.wsdl interface="http://xmlns.oracle.com/HelloWorld/Helloworld/BPELProcess1#wsdl.interface(BPELProcess1)"/>
     <binding.ws port="http://xmlns.oracle.com/HelloWorld/Helloworld/BPELProcess1#wsdl.endpoint(bpelprocess1_client_ep/BPELProcess1_pt)">
     </binding.ws>
  </service>

  <service name="bpelprocess1_client_ep2" ui:wsdlLocation="BPELProcess1.wsdl">
    <interface.wsdl interface="http://xmlns.oracle.com/HelloWorld/Helloworld/BPELProcess1#wsdl.interface(BPELProcess1)"/>
   <binding.adf serviceName="{http://xmlns.oracle.com/HelloWorld/Helloworld/BPELProcess1}bpelprocess1_client_ep2"
                registryName=""/>
  </service>

Go back to the design mode and open the new adf binding service and select the same wsdl as your other service ( this will correct the serviceName ) and at last we need to wire the new service to the component

Now we only need to call this service from java


package nl.whitehorses.bpel.unit;

import java.util.Hashtable;
import java.util.UUID;
import java.util.List;

import javax.naming.Context;

import oracle.soa.management.facade.Locator;
import oracle.soa.management.facade.LocatorFactory;
import oracle.soa.management.facade.Composite;
import oracle.soa.management.facade.Service;
import oracle.soa.management.facade.CompositeInstance;
import oracle.soa.management.facade.ComponentInstance;


import oracle.fabric.common.NormalizedMessage;
import oracle.fabric.common.NormalizedMessageImpl;

import oracle.soa.management.util.CompositeInstanceFilter;
import oracle.soa.management.util.ComponentInstanceFilter;


import java.util.Map;

import javax.xml.transform.*;
import javax.xml.transform.dom.*;
import javax.xml.transform.stream.*;
import org.w3c.dom.Element;
import java.io.*;



public class StartProcess {
   public StartProcess() {
       super();

       Hashtable jndiProps = new Hashtable();
       jndiProps.put(Context.PROVIDER_URL, "t3://localhost:8001/soa-infra");
       jndiProps.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
       jndiProps.put(Context.SECURITY_PRINCIPAL, "weblogic");
       jndiProps.put(Context.SECURITY_CREDENTIALS, "weblogic1");
       jndiProps.put("dedicated.connection", "true");

       String inputPayload =
       "<process xmlns=\"http://xmlns.oracle.com/HelloWorld/Helloworld/BPELProcess1\">\n" +
       "   <input>hello</input>\n" +
       "</process>\n" ;


       Locator locator = null;
       try {
           // connect to the soa server
           locator = LocatorFactory.createLocator(jndiProps);
           String compositeDN = "default/Helloworld!1.0";

           // find composite
           Composite composite = locator.lookupComposite("default/Helloworld!1.0");
           System.out.println("Got Composite : "+ composite.toString());

           // find exposed service of the composite
           Service service = composite.getService("bpelprocess1_client_ep2");
           System.out.println("Got serviceName : "+ service.toString());

           // make the input request and add this to a operation of the service
           NormalizedMessage input = new NormalizedMessageImpl();
           String uuid = "uuid:" + UUID.randomUUID();
           input.addProperty(NormalizedMessage.PROPERTY_CONVERSATION_ID,uuid);

           // payload is the partname of the process operation
           input.getPayload().put("payload",inputPayload);

           // process is the operation of the employee service
           NormalizedMessage res = null;
           try {
              res = service.request("process", input);
           } catch(Exception e) {
              e.printStackTrace();
           }


           Map payload = res.getPayload();
           Element element = (Element)payload.get("payload");

           TransformerFactory tFactory = TransformerFactory.newInstance();
           Transformer transformer = tFactory.newTransformer();
           transformer.setOutputProperty("indent", "yes");
           StringWriter sw = new StringWriter();
           StreamResult result = new StreamResult(sw);


           DOMSource source =  new DOMSource(element);

           transformer.transform(source, result);
           System.out.println("Result\n"+sw.toString());

           System.out.println("instances");
          
          
           CompositeInstanceFilter filter = new CompositeInstanceFilter();
           filter.setMinCreationDate(new java.util.Date((System.currentTimeMillis() -  2000000)));
           // get composite instances by filter ..
           List<CompositeInstance> obInstances = composite.getInstances(filter);
           // for each of the returned composite instances..
           for (CompositeInstance instance : obInstances) {
               System.out.println(" DN: " + instance.getCompositeDN() +
                                  " Instance: " + instance.getId() +
                                  " creation-date: " + instance.getCreationDate() +
                                  " state (" + instance.getState() + "): " + getStateAsString(instance.getState())
                                  );
                                
               // setup a component filter
               ComponentInstanceFilter cInstanceFilter = new ComponentInstanceFilter();
               // get child component instances ..
               List<ComponentInstance> childComponentInstances = instance.getChildComponentInstances(cInstanceFilter);

               // for each child component instance (e.g. a bpel process)
               for (ComponentInstance cInstance : childComponentInstances) {
                   System.out.println("  -> componentinstance: " + cInstance.getComponentName() +
                                      " type: " + cInstance.getServiceEngine().getEngineType() +
                                      " state: " +getStateAsString(cInstance.getState())
                                      );
                   System.out.println("State: "+cInstance.getNormalizedStateAsString()  );                
               }
           }

       } catch (Exception e) {
           e.printStackTrace();
       }
   }



   private String getStateAsString(int state)
   {
       // note that this is dependent on wheter the composite state is captured or not
       if (state == CompositeInstance.STATE_COMPLETED_SUCCESSFULLY)
           return ("success");
       else if (state == CompositeInstance.STATE_FAULTED)
           return ("faulted");
       else if (state == CompositeInstance.STATE_RECOVERY_REQUIRED)
           return ("recovery required");
       else if (state == CompositeInstance.STATE_RUNNING)
           return ("running");
       else if (state == CompositeInstance.STATE_STALE)
           return ("stale");
       else
           return ("unknown");
   }


   public static void main(String[] args) {
       StartProcess startUnitProcess = new StartProcess();
   }
}

Working with Apache Tuscany, The Java SCA based platform part 1

2009-11-03T21:19:00.021+01:00

In this blogpost and future blogposts I will try to give you a jumpstart with Apache Tuscany Java SCA. If you follow my blog you may already know that I also work and make blogsposts over an other Service Component Architecture (SCA)-based SOA platform ( Oracle Soa Suite 11g). Soa Suite 11g has a different SCA approach and has much better designer support. But it is nice to take a look at Tuscany and see how this java SCA implementation works.

I will explain how you can make some composite applications. In this blogpost we start easy with building a composite application with

Simple java Component
Jax-ws component
Component with references to other components ( wires )
Service on a component
Using a second composite

Here a overview of my test project.

First we need to download Apache Tuscany Java SCA

We start with a simple java component with its interface.


package nl.whitehorses.tuscany.step1;

public interface JavaService {
    public String getData();
}

package nl.whitehorses.tuscany.step1;

public class JavaServiceImpl implements  JavaService {

    public String getData()  {
        return "Hello from java component";
    }
}

We can add this component in the step1 composite file and provide the java implementation class.


<?xml version="1.0" encoding="UTF-8"?>
<composite xmlns="http://www.osoa.org/xmlns/sca/1.0"
     targetNamespace="http://whitehorses" 
     name="step1">

    <component name="JavaCp">
        <implementation.java class="nl.whitehorses.tuscany.step1.JavaServiceImpl" />
    </component>

</composite>

Last part of step 1 is to run this composite application, now we have to load and test the composite application.


package nl.whitehorses.tuscany.step1;

import org.apache.tuscany.sca.host.embedded.SCADomain;

public class ClientStep1 {

    public final static void main(String[] args) throws Exception {

        SCADomain scaDomain = SCADomain.newInstance("step1.composite");
        JavaService javaService = scaDomain.getService(JavaService.class, "JavaCp");

        System.out.println("java: " + javaService.getData());

        scaDomain.close();
    }
}

In step 2 we will call a jax-ws webservice. In this step we also need to add a reference to the component.

To make this work I created first a jax-ws service and deploy this to an application server.


package nl.whitehorses.soa.ws;

import javax.jws.WebService;

@WebService
public class Helloworld {

    public String getResponse( String message){
      return message;
    
    }
}

In the tuscany client project we need to generate a webservice proxy client for this webservice.
Create an implemention class for this ws proxy client. In this class we need to add a reference with the name jaxws and a setter. We will use this in the composite xml


package nl.whitehorses.tuscany.step2;

import nl.whitehorses.soa.ws.proxy.Helloworld;
import org.osoa.sca.annotations.Reference;

public class HelloworldServiceImpl implements Helloworld{

        private Helloworld jaxws;
    
        @Reference 
        public void setJaxws(Helloworld jaxws) {
            this.jaxws = jaxws;
        }
        
        public String getResponse( String message){
          return jaxws.getResponse(message);
        
        }
}

create a new composite file where we will add this component and its reference. In the reference we need to provide the web service binding


<?xml version="1.0" encoding="UTF-8"?>
<composite xmlns="http://www.osoa.org/xmlns/sca/1.0"
     targetNamespace="http://whitehorses" 
     name="step2">

   <component name="HelloworldCp">
        <implementation.java class="nl.whitehorses.tuscany.step2.HelloworldServiceImpl" />
        <reference name="jaxws">
           <binding.ws wsdlElement="http://ws.soa.whitehorses.nl/#wsdl.port(HelloworldService/HelloworldPort)" 
            uri="http://localhost:7101/jaxws/HelloworldPort?wsdl#wsdl.interface(HelloworldService)"/>
        </reference>
    </component>

</composite>

And at last the test client


package nl.whitehorses.tuscany.step2;


import org.apache.tuscany.sca.host.embedded.SCADomain;
import nl.whitehorses.soa.ws.proxy.Helloworld;

public class ClientStep2 {

    public final static void main(String[] args) throws Exception {

        SCADomain scaDomain = SCADomain.newInstance("step2.composite");
        Helloworld helloworld = scaDomain.getService(Helloworld.class, "HelloworldCp");

        System.out.println("ws: " + helloworld.getResponse("hello"));

        scaDomain.close();
    }
}

In step 3 we will expose an component as a service. First step is to make an interface with the methods which we want to expose in this web service. We have to add Remotable annotation.


package nl.whitehorses.tuscany.step3;

import org.osoa.sca.annotations.Remotable;

@Remotable
public interface TuscanyService {

    public String getJaxwsResponse( String message);

    public String getJavaData();

    public String getJavaData2();
 
}

The implementatation of this component with the Service annotation and off course the references to the other components.


package nl.whitehorses.tuscany.step3;

import nl.whitehorses.soa.ws.proxy.Helloworld;

import org.osoa.sca.annotations.Reference;
import org.osoa.sca.annotations.Service;
import nl.whitehorses.tuscany.step1.JavaService;

@Service(TuscanyService.class)
public class TuscanyServiceImpl implements TuscanyService {

    private Helloworld helloworldComponent;
    private JavaService javaComponent;
    private JavaService javaComponent2;
    
    @Reference 
    public void setHelloworldComponent(Helloworld helloworldComponent) {
        this.helloworldComponent = helloworldComponent;
    }

    @Reference 
    public void setJavaComponent(JavaService javaComponent) {
        this.javaComponent = javaComponent;
    }

    @Reference 
    public void setJavaComponent2(JavaService javaComponent2) {
        this.javaComponent2 = javaComponent2;
    }


    public String getJaxwsResponse(String message) {
        return helloworldComponent.getResponse(message) ;
    }

    public String getJavaData() {
        return javaComponent.getData();
    }
    
    public String getJavaData2() {
        return javaComponent2.getData();
    }
}

The step3 composite file has a TuscanyServiceComponent with 3 references to the step 1 and 2 components and this component has also a service. In this service we have to provide the ws url.


<?xml version="1.0" encoding="UTF-8"?>
<composite xmlns="http://www.osoa.org/xmlns/sca/1.0"
     targetNamespace="http://whitehorses" 
     name="step3">

    <component name="TuscanyServiceComponent">
        <implementation.java class="nl.whitehorses.tuscany.step3.TuscanyServiceImpl" />
        <reference name="helloworldComponent" target="HelloworldCp" />
        <reference name="javaComponent" target="JavaCp" />
        <reference name="javaComponent2" target="JavaCp2" />
        <service name="TuscanyService">
           <binding.ws uri="http://localhost:8085/TuscanyService"/>
        </service>
    </component>

    <component name="JavaCp">
        <implementation.java class="nl.whitehorses.tuscany.step1.JavaServiceImpl" />
    </component>

    <component name="JavaCp2">
        <implementation.java class="nl.whitehorses.tuscany.step1.JavaServiceImpl" />
    </component>

    <component name="HelloworldCp">
        <implementation.java class="nl.whitehorses.tuscany.step2.HelloworldServiceImpl" />
        <reference name="jaxws">
           <binding.ws wsdlElement="http://ws.soa.whitehorses.nl/#wsdl.port(HelloworldService/HelloworldPort)" 
            uri="http://localhost:7101/jaxws/HelloworldPort?wsdl#wsdl.interface(HelloworldService)"/>
        </reference>
    </component>

</composite>

The client code which tests the main component and start the service on this component


package nl.whitehorses.tuscany.step3;

import java.io.IOException;
import org.apache.tuscany.sca.host.embedded.SCADomain;

public class ClientStep3 {

    public final static void main(String[] args) throws Exception {

        SCADomain scaDomain = SCADomain.newInstance("step3.composite");
        TuscanyService tuscanyService =  scaDomain.getService(TuscanyService.class, "TuscanyServiceComponent");

        System.out.println("ws: "+tuscanyService.getJaxwsResponse("hello"));
        System.out.println("java: "+tuscanyService.getJavaData());
        System.out.println("java2: "+tuscanyService.getJavaData2());

        try {
             System.out.println("ws service started (press enter to shutdown)");
             System.in.read();
         } catch (IOException e) {
             e.printStackTrace();
         }

        scaDomain.close();
    }    
}

Now we can use soapui to test this web service.

In the last step in this blog I will use a second composite which will be called by the first composite.
First we create a new composite xml. We will copy a java component from the step3 composite to this composite. Give this composite a new name and target namespace. We will use these values to import this composite. This component needs a service else we can not call it from the main composite.


<?xml version="1.0" encoding="UTF-8"?>
<composite xmlns="http://www.osoa.org/xmlns/sca/1.0"
     targetNamespace="http://whitehorses2" 
     name="step4_2">

    <service name="JavaCpService" promote="JavaCp"> 
        <interface.java interface="nl.whitehorses.tuscany.step1.JavaService"/>
    </service>

    <component name="JavaCp">
        <implementation.java class="nl.whitehorses.tuscany.step1.JavaServiceImpl" />
    </component>

</composite>

The main composite called step4_1 need the namespace of the second composite. The JavaCp2 component import the second composite by using the target namespace of the second composite and with its name. In the javaComponent2 reference of the TuscanyServiceComponent will call JavaCp2 component followed by the service name of the second composite.


<?xml version="1.0" encoding="UTF-8"?>
<composite xmlns="http://www.osoa.org/xmlns/sca/1.0"
     targetNamespace="http://whitehorses" 
     xmlns:whitehorses2="http://whitehorses2"
     name="step4_1">

    <component name="TuscanyServiceComponent">
        <implementation.java class="nl.whitehorses.tuscany.step3.TuscanyServiceImpl" />
        <reference name="helloworldComponent" target="HelloworldCp" />
        <reference name="javaComponent" target="JavaCp" />
        <reference name="javaComponent2" target="JavaCp2/JavaCpService" />
        <service name="TuscanyService">
           <binding.ws uri="http://localhost:8085/TuscanyService"/>
        </service>
    </component>

    <component name="JavaCp">
        <implementation.java class="nl.whitehorses.tuscany.step1.JavaServiceImpl" />
    </component>

    <component name="HelloworldCp">
        <implementation.java class="nl.whitehorses.tuscany.step2.HelloworldServiceImpl" />
        <reference name="jaxws">
           <binding.ws wsdlElement="http://ws.soa.whitehorses.nl/#wsdl.port(HelloworldService/HelloworldPort)" 
            uri="http://localhost:7101/jaxws/HelloworldPort?wsdl#wsdl.interface(HelloworldService)"/>
        </reference>
    </component>

    <component name="JavaCp2">
        <implementation.composite name="whitehorses2:step4_2"/>
    </component>
</composite>

and at last the step 4 test client.


package nl.whitehorses.tuscany.step4;

import nl.whitehorses.tuscany.step3.TuscanyService;
import java.io.IOException;
import org.apache.tuscany.sca.host.embedded.SCADomain;

public class ClientStep4 {

    public final static void main(String[] args) throws Exception {

        SCADomain scaDomain = SCADomain.newInstance("step4_1.composite");
        TuscanyService tuscanyService =  scaDomain.getService(TuscanyService.class, "TuscanyServiceComponent");

        System.out.println("ws: "+tuscanyService.getJaxwsResponse("hello"));
        System.out.println("java: "+tuscanyService.getJavaData());
        System.out.println("java2: "+tuscanyService.getJavaData2());

        try {
             System.out.println("ws service started (press enter to shutdown)");
             System.in.read();
         } catch (IOException e) {
             e.printStackTrace();
         }

        scaDomain.close();
    }    
}

Here you can download my jdeveloper 11G test project.

Securing Web Services with SAML Sender Vouches

2009-10-29T20:36:00.024+01:00

After securing you web applications with SAML is the next step to secure your web services with SAML Sender Vouches ws-security policy, this can be complex because you need to know a lot over the weblogic server configuration and its java security frameworks. For example you need to configure two Weblogic servers, the first is the Web Service server and the second server is the Secure Token Service ( STS ). After that you need to add some client credential providers to the generated web service proxy client. Thanks to Vishal Jain of Oracle who provided me a working example.
This is how SAML Sender Vouches works and what we need to do in weblogic / java.
The short version is, the web service proxy client call the STS server to get an SAML assertion on behalf of the User to call the Web Service.

The long version, the user provides its credentials to the ws proxy client and the ws proxy client calls the STS server and provides the username / password of the user and the client key.
The STS validates the user and the ws proxy client certificate and the STS returns the STS identity assertion to the ws proxy client. The ws proxy client uses this STS assertion together with the ws client and ws server certificate to call the web service.

First we need to have 3 certificates, the first is alice, this will be used in the ws proxy client and the second certificate is bob, this will be used in the Weblogic web service server and the last we use wssipsts certificate for the Weblogic STS server. Add these keys into a java keystore.

Setting up the Secure Token Service (STS)
Create a new Weblogic 10.3.1 domain and start the admin server. First we need to enable SSL in the general tab of the server and then add our keystores in the keystore tab.
Provide the STS certificate alias, in my case wssipprv

Go the myrealm security where we add the Alice user and provide a password, Very important the username must match with the CN of the Alice certificate. The user provides the credentials and must match with user in WLS and the ws proxy client provides the Alice certificate and this must match with the PKI Credential mapping.

Go to the Credential mapping tab of the Provider tab and add a PKI Credential Mapping where we import the keystore and Add a SAML Credential Mapping version 2 where we add the Web Service URL.

Open the just created PKI credential mapping and add the keystore.

Next we open the SAML Credential Mapping version 2 and provide the Issuer URL and Name Qualifier.

Add the public key of the wssipsts

Add a WSS/Sender-Vouches Relying Party

Enable this and provide the target url of the Web Service Url and assign assertions and include key info

That is all for the STS server and now we can deploy the STS web service.


package nl.whitehorses.sts;

import weblogic.jws.Policy;
import weblogic.wsee.security.saml.SAMLTrustTokenProvider;
import weblogic.wsee.security.wst.framework.TrustTokenProviderRegistry;

import javax.jws.WebMethod;
import javax.jws.WebService;

@WebService
@Policy(uri="policy:Wssp1.2-2007-Wssc1.3-Bootstrap-Https-UNT.xml")
public class StsUnt {

static {
init();
}

@WebMethod
@Policy(uri="policy:Wssp1.2-2007-SignBody.xml")
public String dummyMethod(String s) {
return s;
}

static void init() {
TrustTokenProviderRegistry reg = TrustTokenProviderRegistry.getInstance();
SAMLTrustTokenProvider provider = new MySAMLTrustTokenProvider();
reg.registerProvider("http://docs.oasis-open.org/wss/2004/01/oasis-2004-01-saml-token-profile-1.0#SAMLAssertionID", provider);
reg.registerProvider("http://docs.oasis-open.org/wss/oasis-wss-saml-token-profile-1.0#SAMLAssertionID", provider);
reg.registerProvider("http://docs.oasis-open.org/wss/oasis-wss-saml-token-profile-1.1#SAMLV2.0",  provider);
reg.registerProvider("http://docs.oasis-open.org/wss/oasis-wss-saml-token-profile-1.1#SAMLV1.0",  provider);
reg.registerProvider("http://docs.oasis-open.org/wss/oasis-wss-saml-token-profile-1.1#SAMLV1.1",  provider);
}

static class MySAMLTrustTokenProvider extends SAMLTrustTokenProvider {

}
}

Configure the Weblogic server for the Web Services
Create a new Weblogic domain and use the same keystore, we don't need to setup SSL on this server.

Go the myrealm security and go to providers tab where we add a new PKI Credential Mapping in the credentials tab. ( Use the same setting as the STS server )
We need to add 2 authentication providers and change the 2 default providers.
Create a SAML Authentication and SAML Identity Assertion provider.

Every authentication provider need to have the SUFFICIENT control flag.

Change the SAML Identity Assertion by adding an asserting party and the STS public certificate

Import the STS certificate

Change the just create Sender-Vouches asserting party. Enable this and provide the target url of the web service and add the issuer url, signature required and expect the STS certificate and allow virtual user.

Change the defaultIdentityAsserter and add wsse:PasswordDigest and X.509 as active types.
In the provider specific tab we need to set CN in the Default User Name Mapper Attribute Type and enable Use Default User Name Mapper.

In the DefaultAuthenticator we need to set control flag to SUFFICIENT
And in the provider specific tab. Enable Password Digests and Minimum Password Length to 1.

That's all for the Web Service server. Now we can deploy the webservice.


package nl.whitehorses.sts.ws;

import weblogic.jws.Policies;
import weblogic.jws.Policy;
import javax.jws.WebService;

@Policies(
  {
    @Policy(uri = "policy:Wssp1.2-2007-Saml1.1-SenderVouches-Wss1.0.xml"),
    @Policy(uri = "policy:Wssp1.2-2007-SignBody.xml"),
    @Policy(uri = "policy:Wssp1.2-2007-EncryptBody.xml")
  }
)

@WebService
public class EchoService {
  public String echo( String hello){
    return hello;
  }
}

Generating the Web Service Proxy Client
The last step we need to generate a web service proxy client and add the username and the client credentials mappings.


package nl.whitehorses.sts.ws.client;

import java.io.InputStream;
import java.io.ByteArrayInputStream;

import java.security.cert.X509Certificate;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import java.net.URL;
import javax.xml.namespace.QName;


import javax.xml.ws.BindingProvider;
import javax.xml.ws.WebServiceRef;

import weblogic.security.SSL.TrustManager;

import weblogic.wsee.message.WlMessageContext;
import weblogic.wsee.security.bst.ClientBSTCredentialProvider;
import weblogic.wsee.security.saml.SAMLTrustCredentialProvider;
import weblogic.wsee.security.unt.ClientUNTCredentialProvider;

import weblogic.xml.crypto.wss.WSSecurityContext;
import weblogic.xml.crypto.wss.provider.CredentialProvider;

public class EchoServicePortClient
{
 @WebServiceRef
 private static EchoServiceService echoServiceService;

   private static String stsUntPolicy =
   "<?xml version=\"1.0\"?>\n" +
   "<wsp:Policy\n" +
   "  xmlns:wsp=\"http://schemas.xmlsoap.org/ws/2004/09/policy\"\n" +
   "  xmlns:sp=\"http://docs.oasis-open.org/ws-sx/ws-securitypolicy/200702\"\n" +
   "  >\n" +
   "  <sp:TransportBinding>\n" +
   "    <wsp:Policy>\n" +
   "      <sp:TransportToken>\n" +
   "        <wsp:Policy>\n" +
   "          <sp:HttpsToken/>\n" +
   "        </wsp:Policy>\n" +
   "      </sp:TransportToken>\n" +
   "      <sp:AlgorithmSuite>\n" +
   "        <wsp:Policy>\n" +
   "          <sp:Basic256/>\n" +
   "        </wsp:Policy>\n" +
   "      </sp:AlgorithmSuite>\n" +
   "      <sp:Layout>\n" +
   "        <wsp:Policy>\n" +
   "          <sp:Lax/>\n" +
   "        </wsp:Policy>\n" +
   "      </sp:Layout>\n" +
   "      <sp:IncludeTimestamp/>\n" +
   "    </wsp:Policy>\n" +
   "  </sp:TransportBinding>\n" +
   "  <sp:SupportingTokens>\n" +
   "    <wsp:Policy>\n" +
   "      <sp:UsernameToken\n" +
   "        sp:IncludeToken=\"http://docs.oasis-open.org/ws-sx/ws-securitypolicy/200702/IncludeToken/AlwaysToRecipient\">\n" +
   "        <wsp:Policy>\n" +
   "          <sp:WssUsernameToken10/>\n" +
   "        </wsp:Policy>\n" +
   "      </sp:UsernameToken>\n" +
   "    </wsp:Policy>\n" +
   "  </sp:SupportingTokens>\n" +
   "</wsp:Policy>";

   public static void main(String[] args) {
       System.setProperty("com.sun.xml.ws.transport.http.client.HttpTransportPipe.dump", "true");
       try {

           String wsURL = "http://10.10.10.10:7011/saml-ws-context-root/EchoServicePort?WSDL";

           echoServiceService = new EchoServiceService(    new URL(wsURL) 
                                                        ,  new QName("http://ws.sts.whitehorses.nl/", "EchoServiceService"));
           EchoService echoService = echoServiceService.getEchoServicePort();

           System.setProperty("javax.net.ssl.trustStore", "C:/projecten/workspace/11g_prod/saml1.1_ws/wsttest1/certs/cacerts");

           Map<String, Object> requestContext = ((BindingProvider)echoService).getRequestContext();

           List<CredentialProvider> credList = new ArrayList<CredentialProvider>();

           // Add the necessary credential providers to the list
           InputStream policy = new ByteArrayInputStream(stsUntPolicy.getBytes("UTF-8"));
           requestContext.put(WlMessageContext.WST_BOOT_STRAP_POLICY, policy );

           String stsURL = "https://localhost:7022/sts/StsUntPort";
          
          
           requestContext.put(WlMessageContext.STS_ENDPOINT_ADDRESS_PROPERTY, stsURL);
           requestContext.put(WSSecurityContext.TRUST_MANAGER,
                              new TrustManager() {
                                   public boolean certificateCallback(X509Certificate[] chain, int validateErr) {
                                   // need to validate if the server cert can be trusted
                                       return true;
                                   }
                               });

           credList.add(new SAMLTrustCredentialProvider());

           String username = "Alice";
           String password = "weblogic1";
           credList.add(new ClientUNTCredentialProvider(username.getBytes(), password.getBytes()));

           // ClientBSTCredentialProvider
           String defaultClientcert = "C:/projecten/workspace/11g_prod/saml1.1_ws/wsttest1/certs/Alice.cer";
           String clientcert = System.getProperty("target.clientcert", defaultClientcert);
           String defaultClientkey =  "C:/projecten/workspace/11g_prod/saml1.1_ws/wsttest1/certs/Alice.prv";
           String clientkey = System.getProperty("target.clientkey", defaultClientkey);
              
           String defaultServerCert = "C:/projecten/workspace/11g_prod/saml1.1_ws/wsttest1/certs/Bob.cer";
           String serverCert = System.getProperty("target.serverCert", defaultServerCert);

           credList.add(new ClientBSTCredentialProvider(clientcert, clientkey, serverCert));

           requestContext.put(WSSecurityContext.CREDENTIAL_PROVIDER_LIST, credList);

           // Add your code to call the desired methods.
           System.out.println(echoService.echo("Hello"));

       } catch (Exception ex) {
           ex.printStackTrace();
       }
   }

   }

JMS Request Reply Interaction Pattern in Soa Suite 11g

2009-10-20T23:05:00.010+02:00

In Soa Suite 11g the JMS adapter has support for request reply operations. You can use this operation in synchronous or asynchronous mode. In this blog I will show you both modes. I start with a Asynchronous example and at the end I describe the synchronous mode.

Asynchronous Request / Reply
First we start with a simple Asychronous request and reply JMS adapter. Add a JMS adapter to the references site of the composite.

Choose Request/ Reply and off course asynchronous

Select a request queue ( need to create this in the wls console ) and provide the jndi name of jms resource adapter ( define this in the jms resource adapter ) . Very important use a xa transacted jms connection factory in the jms resource adapter and leave the rest as default.

In the Reply we provide the response queue and use the same jms resource adapter jndi name of the request

Provide the request and response element.

With this as result.

Now we can use this jms adapter in a asynchronous Mediator or in a synchronous BPEL process.
First we start with the mediator. Add a Mediator with the same input and output as the jms adapter
Wire the JMS adapter to this Mediator so we can define the routing rules.

With this as result.

Because this asynchronous service is hard to test, so I will also make a synchronous BPEL process which calls this asynchronous jms adapter with a invoke and receive activity.
Add a BPEL process with the same input and output as the jms adapter

Here an overview of the BPEL process with the invoke and receive activity

Picture of my test composite

For testing we need to transfer the jms message from the request queue to the reply queue. So I add a mediator with a consume and produce jms adapter.

Very important, we need to assign the message id of the jms message to the correlation id of the reply jms message. Do this in the assign of the routing rule.

Last thing is to test the BPEL process in the enterprise manager

With this as result.

Synchronous Request / Reply
The synchronous request reply jms adapter works a bit different then asynchronous.
In step 6 we now select synchronous

In step 7 we can provide the request and reply queue. But very important we to provide the jndi name of a jms resource adapter which has transacted on true and use a jms connection factory which is not xa transacted.
With synchronous jms adapter I had to switch the request and response element. Very strange ( is it a bug ).

This synchronous jms message is a bit different, this message has the JCA_JMSReplyTo field which contains the reply queue name.

Now for testing we also need to add an extra mediator with reads the request queue , set the correlation id and put the message in the reply queue.

Add a synchronous mediator and wire to the synchronous jms adapter, complete the routing rule and finally test this in the enterprise manager.

Oracle OpenWorld 2009 Fusion middleware highlights

2009-10-15T22:53:00.005+02:00

The most important news is that Oracle plans to release JDeveloper 11g R1 PS1 in November. This so called patch set is more a new release ( more then 550+ new features ) then a patch
Here is my quick overview of the features and products I noticed at OOW.

ADF
- Oracle improved the ADF Event mechanism, so the Task Flow fragment regions can communicate much better, You can define the event on a JSF item and not manually in the pagedef, define your own payload. For example in an ADF tree with employees and departments you can send an event when the user select an item in the tree and this number will be passed on to the right task flow. And you even can fire events with drag and drop. For more info buy the coming book of Frank Nimphius, he wrote a whole chapter about this subject.
- ADS active data services pushing the data to the page, Frank N. and Matthias W. made a great demo
- Maybe Maven support.
- Better EJB support in ADF

ADF Mobile
Build your web application just like a normal ADF web application on deploy this on weblogic server. These mobile jsf pages which work on every phone in the native look of the phone, the so called the browser version. With mobile you can also build native applications for blackberry and windows mobile ( just make the right deployment profile ) and this will work with the black berry and windows mobile services and these services will sync with the oracle lite server. So this technology makes it possible to make an offline ADF application, when there are enough customers who wants this feature then Oracle will build this. ADF mobile is now only supported with ADF BC and the next versions will have also have web services support.
For more info see the Amis blog

Soa Suite 11G
-The soa suite is becoming more and more complete, the next version will have a spring context component, this component is in this version only available as technical preview. But this is a good start and there are talks about supporting C code in the composite.
- EDN Event Delivery Network now only works with AQ but there will be also a JMS implementation.
For more info see the blog of Torsten and Hajo

BPM 11G
In one of the hands-on sessions we could play with BPM 11g and it is really great. You can now use JDeveloper to configure it and BPM is an composite component in the Soa Suite. So you can take a look or change it at the BPM level or go to the composite level. BPM uses the human task flows components of the soa suite for the human interaction, Next we can import this human task in jdeveloper to create an task flow which can be deployed in the worklist application. And BPM introduces the BPM composer which is a web application ( don't need jdeveloper ) where you can change your process. Oracle thinks to release it early 2010.

Continuous build with Soa Suite 11g and Hudson

2009-10-04T23:12:00.010+02:00

With Soa Suite 11g we can add unit tests (test suites) to our composite applications and start these tests with the ant scripts provided by Oracle. The soa test ant script can start and generate an junit xml which can be read for the result of the test. For more info see my previous blogpost about the ant scripts and the testsuite option in Soa Suite 11g.

So the last step is to combine the test suite feature and the ant scripts of mine and Oracle so we can use it in a continuous build system. I will use Hudson for this.

We start by downloading the lastest hudson war.

Start hudson by setting the java home and path
set JAVA_HOME=c:\java\jdk160_05
set PATH=%JAVA_HOME%\bin;%PATH
java -jar hudson.war

this will start Hudson and open a browser and go to http://localhost:8080.

First we install Hudson as a windows service. Just provide the location. I will use c:\java\hudson

This will restart hudson. Now we can configure Hudson

Provide the ant and java location of the jdeveloper 11g R1 home.

Put the soa projects and ant scripts in subversion, so Hudson can check this out

This is how it looks. Very important my ant scripts need this folder paths.

Now we can create a new job.

Configure this new job. We start by adding the svn url.

Then add the ant script ( build.xml ) and fill the target ( deployAll) and for the oracle ant scripts we need to set the basedir java parameter to the jdeveloper bin folder.

And provide the location where Hudson can find the junit xml files.

Now we have to add ant-contrib-1.0XXXX.jar the to the jdeveloper\ant\lib folder and add a environment variable to the ant.bat

set CURRENT_FOLDER=%CD%

I need this for the ant scripts so I can use relative paths.

Let's press build now and look at the result. My example composite application contains two tests, in my case they are both succesfull.

Look at the test.
And the performance.

That's all. This will save you a lot of testing time and off course Hudson can blame the person who checked in as last.
Here is my test project and ant scripts

Deploy Soa Suite 11g composite applications with Ant scripts

2009-09-26T13:06:00.021+02:00

With Soa Suite 11g you can deploy your composite applications from JDeveloper or with Ant. In this blog I will do this with the soa 11g Ant scripts. These ant scripts can only deploy one project so I made an Ant script around the soa ant scripts which can deploy more composites applications to different Soa enviroments. So now you can use it to automate your deployment or use it in your build tool. In my ant script I will deploy to the MDS, compile, build and package the composite application and deploy this to the soa server, after this I use an ant script to start the unit tests and generate a junit result xml and at last I can optional disable the composite.
This junit xml can be used in your continious build system. You can easily extend this build script so you use it to manage the composite applications.
For more info over ant deployment see the official deployment documentation .
The official ant scripts are located in the jdeverloper\bin folder. Here is a summary what are and can do

ant-sca-test.xml, This script can start the test suites of the composite and generates a juinit report and not Attaches, extracts, generates, and validates configuration plans for a SOA composite application, The official documentation description is not correct.
ant-sca-compile.xml, Compiles a SOA composite application ,this script is also called in the package scrip, so we don't need to call this directly.
ant-sca-package.xml, Packages a SOA composite application into a composite SAR file and also validates and build the composite application.
ant-sca-deploy.xml, Deploys a SOA composite application.
ant-sca-mgmt.xml, Manages a SOA composite application, including starting, stopping, activating, retiring, assigning a default revision version, and listing deployed SOA composite applications.

Here is the main build.properties where you have to define the jdeveloper and your application home, which composite applications you want to deploy and to which environment dev or acc.



# global
wn.bea.home=C:/oracle/MiddlewareJdev11gR1PS1
oracle.home=${wn.bea.home}/jdeveloper
java.passed.home=${wn.bea.home}/jdk160_14_R27.6.5-32
wl_home=${wn.bea.home}/wlserver_10.3

# temp
tmp.output.dir=c:/temp
junit.output.dir=../../

applications.home=../../applications
applications=HelloWorld

mds.enabled=true
mds.reposistory=C:/oracle/MiddlewareJdev11gR1PS1/jdeveloper/integration/seed/apps/
mds.applications=Woningnet-Test
mds.undeploy=true


deployment.plan.environment=dev

# dev deployment server weblogic
dev.serverURL=http://laptopedwin:8001
dev.overwrite=true
dev.user=weblogic
dev.password=weblogic1
dev.forceDefault=true
dev.server=laptopedwin
dev.port=8001

# acceptance deployment server weblogic
acc.serverURL=http://laptopedwin:8001
acc.overwrite=true
acc.user=weblogic
acc.password=weblogic1
acc.forceDefault=true
acc.server=laptopedwin
acc.port=8001

Every application can have one or more soa projects so the main ant script will load the application properties file which contains all the project with its revision number.
Here is a example of SoaEjbReference.properties file


projects=Helloworld

Helloworld.revision=1.0
Helloworld.enabled=false

Because in my example I have two soa environments so I need to create two configuration plans. With this plan ( which look the wls plan ) can change the url of endpoints so it matches with the environment.
Select the composite application xml and generate a configuration plan.
Add the dev or acc extension to the file name.
Here you see how the plan looks like.

And here is the main ant build script which can do it all and calls the Oracle Ant scripts.


<?xml version="1.0" encoding="iso-8859-1"?>
<project name="soaDeployAll" default="deployAll">
   <echo>basedir ${basedir}</echo>

   <property environment="env"/>
   <echo>current folder ${env.CURRENT_FOLDER}</echo>

   <property file="${env.CURRENT_FOLDER}/build.properties"/> 

   <taskdef resource="net/sf/antcontrib/antcontrib.properties"/>

   <import file="${basedir}/ant-sca-deploy.xml"/>
   <import file="${basedir}/ant-sca-package.xml"/>
   <import file="${basedir}/ant-sca-test.xml"/>
   <import file="${basedir}/ant-sca-test.xml"/>
   <import file="${basedir}/ant-sca-mgmt.xml"/>


   <target name="deployAll">
     <if>
         <equals arg1="${mds.enabled}" arg2="true"/>
         <then>
            <antcall target="deployMDS" inheritall="true"/>
         </then>
     </if>     
     <foreach list="${applications}" param="application" target="deployApplication" inheritall="true" inheritrefs="false"/>
   </target>


   <target name="unDeployMDS">
       <echo>undeploy MDS</echo>
       <foreach list="${mds.applications}" param="mds.application" target="undeployMDSApplication" inheritall="true" inheritrefs="false"/>
   </target>

   <target name="deployMDS">
       <echo>undeploy and deploy MDS</echo>
       <if>
         <equals arg1="${mds.undeploy}" arg2="true"/>
         <then>
           <foreach list="${mds.applications}" param="mds.application" target="undeployMDSApplication" inheritall="true" inheritrefs="false"/>
         </then>
       </if>
       <foreach list="${mds.applications}" param="mds.application" target="deployMDSApplication" inheritall="true" inheritrefs="false"/>
   </target>

   <target name="deployMDSApplication">
       <echo>deploy MDS application ${mds.application}</echo>

       <echo>remove and create local MDS temp</echo>
       <property name="mds.deploy.dir" value="${tmp.output.dir}/${mds.application}"/>
    
       <delete dir="${mds.deploy.dir}"/>
       <mkdir dir="${mds.deploy.dir}"/>

       <echo>create zip from file MDS store</echo>
      <zip destfile="${mds.deploy.dir}/${mds.application}_mds.jar" compress="false">
       <fileset dir="${mds.reposistory}" includes="${mds.application}/**"/>
     </zip>

       <echo>create zip with MDS jar</echo>
      <zip destfile="${mds.deploy.dir}/${mds.application}_mds.zip" compress="false">
       <fileset dir="${mds.deploy.dir}" includes="*.jar"/>
     </zip>

       <propertycopy name="deploy.serverURL"    from="${deployment.plan.environment}.serverURL"/>
       <propertycopy name="deploy.overwrite"    from="${deployment.plan.environment}.overwrite"/>
       <propertycopy name="deploy.user"         from="${deployment.plan.environment}.user"/>
       <propertycopy name="deploy.password"     from="${deployment.plan.environment}.password"/>
       <propertycopy name="deploy.forceDefault" from="${deployment.plan.environment}.forceDefault"/>

       <echo>deploy MDS app</echo>

       <echo>deploy on ${deploy.serverURL} with user ${deploy.user}</echo>
       <echo>deploy sarFile ${mds.deploy.dir}/${mds.application}_mds.zip</echo>

       <antcall target="deploy" inheritall="false">
            <param name="wl_home" value="${wl_home}"/>
            <param name="oracle.home" value="${oracle.home}"/>
            <param name="serverURL" value="${deploy.serverURL}"/>
            <param name="user" value="${deploy.user}"/>
            <param name="password" value="${deploy.password}"/>
            <param name="overwrite" value="${deploy.overwrite}"/>
            <param name="forceDefault" value="${deploy.forceDefault}"/>
            <param name="sarLocation" value="${mds.deploy.dir}/${mds.application}_mds.zip"/>
       </antcall> 
   </target>

   <target name="undeployMDSApplication">
       <echo>undeploy MDS application ${mds.application}</echo>

       <propertycopy name="deploy.serverURL"    from="${deployment.plan.environment}.serverURL"/>
       <propertycopy name="deploy.overwrite"    from="${deployment.plan.environment}.overwrite"/>
       <propertycopy name="deploy.user"         from="${deployment.plan.environment}.user"/>
       <propertycopy name="deploy.password"     from="${deployment.plan.environment}.password"/>
       <propertycopy name="deploy.forceDefault" from="${deployment.plan.environment}.forceDefault"/>

        <echo>undeploy MDS app folder apps/${mds.application} </echo>
        <antcall target="removeSharedData" inheritall="false">
             <param name="wl_home" value="${wl_home}"/>
             <param name="oracle.home" value="${oracle.home}"/>
             <param name="serverURL" value="${deploy.serverURL}"/>
             <param name="user" value="${deploy.user}"/>
             <param name="password" value="${deploy.password}"/>
             <param name="folderName" value="${mds.application}"/>
        </antcall>
   </target>


   <target name="deployApplication">
       <echo>deploy application ${application}</echo>
       <property file="${env.CURRENT_FOLDER}/${applications.home}/${application}/build.properties"/>  
       <foreach list="${projects}" param="project" target="deployProject" inheritall="true" inheritrefs="false"/>
   </target>

   <target name="deployProject">
       <echo>deploy project ${project} for  environment ${deployment.plan.environment}</echo>

       <property name="proj.compositeName" value="${project}"/>
       <property name="proj.compositeDir" value="${env.CURRENT_FOLDER}/${applications.home}/${application}"/>
       <propertycopy name="proj.revision" from="${project}.revision"/>
       <propertycopy name="proj.enabled" from="${project}.enabled"/>

       <echo>deploy compositeName ${proj.compositeName}</echo>
       <echo>deploy compositeDir ${proj.compositeDir}</echo>

       <antcall target="package" inheritall="false">
            <param name="compositeDir" value="${proj.compositeDir}/${project}"/>
            <param name="compositeName" value="${proj.compositeName}"/>
            <param name="revision" value="${proj.revision}"/>
            <param name="oracle.home" value="${oracle.home}"/>
            <param name="java.passed.home" value="${java.passed.home}"/>
            <param name="wl_home" value="${wl_home}"/>
            <param name="sca.application.home" value="${proj.compositeDir}"/>
            <param name="scac.application.home" value="${proj.compositeDir}"/>
            <param name="scac.input" value="${proj.compositeDir}/${proj.compositeName}/composite.xml"/>
            <param name="scac.output" value="${tmp.output.dir}/${proj.compositeName}.xml"/>
            <param name="scac.error" value="${tmp.output.dir}/${proj.compositeName}.err"/>
            <param name="scac.displayLevel" value="3"/>
       </antcall> 

       <property name="deploy.sarLocation" value="${proj.compositeDir}/${proj.compositeName}/deploy/sca_${proj.compositeName}_rev${proj.revision}.jar"/>
       <property name="deploy.configplan"  value="${proj.compositeDir}/${proj.compositeName}/${proj.compositeName}_cfgplan_${deployment.plan.environment}.xml"/>

       <propertycopy name="deploy.serverURL"    from="${deployment.plan.environment}.serverURL"/>
       <propertycopy name="deploy.overwrite"    from="${deployment.plan.environment}.overwrite"/>
       <propertycopy name="deploy.user"         from="${deployment.plan.environment}.user"/>
       <propertycopy name="deploy.password"     from="${deployment.plan.environment}.password"/>
       <propertycopy name="deploy.forceDefault" from="${deployment.plan.environment}.forceDefault"/>
       <propertycopy name="deploy.server"       from="${deployment.plan.environment}.server"/>
       <propertycopy name="deploy.port"         from="${deployment.plan.environment}.port"/>

       <echo>deploy on ${deploy.serverURL} with user ${deploy.user}</echo>
       <echo>deploy sarFile ${deploy.sarLocation}</echo>

       <antcall target="deploy" inheritall="false">
            <param name="wl_home" value="${wl_home}"/>
            <param name="oracle.home" value="${oracle.home}"/>
            <param name="serverURL" value="${deploy.serverURL}"/>
            <param name="user" value="${deploy.user}"/>
            <param name="password" value="${deploy.password}"/>
            <param name="overwrite" value="${deploy.overwrite}"/>
            <param name="forceDefault" value="${deploy.forceDefault}"/>
            <param name="sarLocation" value="${deploy.sarLocation}"/>
            <param name="configplan" value="${deploy.configplan}"/>
       </antcall> 

       <echo>unit test sarFile ${proj.compositeName} </echo>


       <antcall target="test" inheritall="false">
            <param name="scatest.input" value="${project}"/>
            <param name="scatest.format" value="junit"/>
            <param name="scatest.result" value="${env.CURRENT_FOLDER}/${junit.output.dir}"/>
            <param name="jndi.properties.input" value="${deployment.plan.environment}.jndi.properties"/>
       </antcall>

       <echo>disable composite ${proj.compositeName} </echo>
          
       <if>
         <equals arg1="${proj.enabled}" arg2="false"/>
         <then>
           <antcall target="stopComposite" inheritall="false">
                 <param name="host" value="${deploy.server}"/>
                 <param name="port" value="${deploy.port}"/>
                 <param name="user" value="${deploy.user}"/>
                 <param name="password" value="${deploy.password}"/>
                 <param name="compositeName" value="${proj.compositeName}"/>
                 <param name="revision" value="${proj.revision}"/>
            </antcall> 

         </then>
       </if>
      
      
       
   </target>
</project>

For development testing environment I need to have dev.jndi.properties


java.naming.factory.initial=weblogic.jndi.WLInitialContextFactory
java.naming.provider.url=t3://localhost:8001/soa-infra
java.naming.security.principal=weblogic
java.naming.security.credentials=weblogic1
dedicated.connection=true
dedicated.rmicontext=true

And finally the cmd script to run this ant script. To make this work we need the ant-contrib libray and put this in the classpath.


set ORACLE_HOME=C:\oracle\MiddlewareJdev11gR1PS1
set ANT_HOME=%ORACLE_HOME%\jdeveloper\ant
set PATH=%ANT_HOME%\bin;%PATH%
set JAVA_HOME=%ORACLE_HOME%\jdk160_14_R27.6.5-32

set CURRENT_FOLDER=%CD%

ant -f build.xml deployAll -Dbasedir=%ORACLE_HOME%\jdeveloper\bin

Here is the zip with all the files and extract this and put this all in the jdeveloper/bin folder.

Job scheduling in Weblogic

2009-09-22T21:30:00.007+02:00

This blog is about how you can run a batchjob on a specific time in the Weblogic application server and as extra, I made an ADF page in which you can stop or start the jobs. This job schedular can start for example some Soa processes at a specific time.
The scheduling is done with the help of the CommonJ API which is standard in Weblogic. This example works perfectly in a managed node but if you want to do the same in a Weblogic Cluster then you should not read this blog and go the James Bayer's blog . And for more information about Timer API see the official Weblogic documentation.

Very important, this job scheduling only works within in a web application.
First we start by adding the TimerManager to the web.xml


 <resource-ref>
   <res-ref-name>tm/TimerManager</res-ref-name>
   <res-type>commonj.timers.TimerManager</res-type>
   <res-auth>Container</res-auth>
   <res-sharing-scope>Unshareable</res-sharing-scope>
 </resource-ref>
</web-app>

Now we done this we can add a servlet which start this TimerManager and its jobs. Important that the servlet is automatically started when the webapp is started.


 <servlet>
   <display-name>timer</display-name>
   <servlet-name>timer</servlet-name>
   <servlet-class>nl.whitehorses.wls.schedular.TimerServlet</servlet-class>
   <load-on-startup>100</load-on-startup>
 </servlet>
 <servlet-mapping>
   <servlet-name>timer</servlet-name>
   <url-pattern>/timer</url-pattern>
 </servlet-mapping>

Then the servlet code which start the TimeManager and the two example batches. In this example the job is started again when it is finished after 30 seconds. If you want to do this at a specific time then use scheduleAtFixedRate


package nl.whitehorses.wls.schedular;

import java.io.IOException;
import java.io.PrintWriter;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import commonj.timers.*;

/**
* TimerServlet demonstrates a simple use of commonj timers
*/
public class TimerServlet extends HttpServlet {

  
   public void init(ServletConfig config) throws ServletException {

       super.init(config);
       System.out.println("timer servlet is initialized  ");
       try {
           InitialContext ic = new InitialContext();
           TimerManager tm = (TimerManager)ic.lookup("java:comp/env/tm/TimerManager");

           Timer batchRun1Timer = null;
           Boolean batchRun1TimerIsRunning = false;
           Timer batchRun2Timer = null;
           Boolean batchRun2TimerIsRunning = false;

           // Execute timer every 30 seconds starting immediately
           batchRun1Timer = tm.schedule(new Batch1(), 0, 30 * 1000);
           batchRun1TimerIsRunning = true;

           batchRun2Timer = tm.schedule(new Batch2(), 0, 30 * 1000);
           batchRun2TimerIsRunning = true;

           config.getServletContext().setAttribute("batch1",batchRun1Timer);
           config.getServletContext().setAttribute("batch2",batchRun2Timer);
           config.getServletContext().setAttribute("batch1Running",batchRun1TimerIsRunning);
           config.getServletContext().setAttribute("batch2Running",batchRun2TimerIsRunning);

       } catch (NamingException ne) {
           ne.printStackTrace();
       }
   }

   public void service(HttpServletRequest req,  HttpServletResponse res) throws IOException {
      res.setContentType("text/html");
       PrintWriter out = res.getWriter();
       out.println("Timer servlet is working!");
   }
}

Here is an example of a batch job. The timerExpired method is fired every time when the job time has passed. Here you can put in your own code and when the job is canceled then the TimerCancel method is fired.


package nl.whitehorses.wls.schedular;

import commonj.timers.*;
import java.io.Serializable;

public class Batch1 implements Serializable, TimerListener, CancelTimerListener {

   public void timerExpired(Timer timer) {
       System.out.println("Batch1 timer expired called on " + timer);
   }
   public  void timerCancel(Timer timer) {
       System.out.println("Batch1 timer cancelled called on " + timer);

   }
}

And finally the JSF page with its backing bean to control the jobs.


<?xml version='1.0' encoding='windows-1252'?>
<jsp:root xmlns:jsp="http://java.sun.com/JSP/Page" version="2.1"
         xmlns:f="http://java.sun.com/jsf/core"
         xmlns:af="http://xmlns.oracle.com/adf/faces/rich">
 <jsp:directive.page contentType="text/html;charset=windows-1252"/>
 <f:view>
   <af:document id="d1">
     <af:form id="f1">
       <af:panelHeader text="Timers" id="ph1">
         <af:panelFormLayout id="pfl1">
           <af:panelGroupLayout id="pgl6" layout="horizontal">
             <af:panelGroupLayout id="pgl8" layout="vertical">
               <af:poll id="poll1">
                 <af:panelGroupLayout id="pgl5" layout="vertical">
                   <af:outputLabel value="#{TimerBean.tmStatus}" id="ol4"
                                   partialTriggers="poll1"/>
                   <af:outputLabel value="#{TimerBean.batch1Status}" id="o22"
                                   partialTriggers="poll1"/>
                   <af:outputLabel value="#{TimerBean.batch2Status}" id="o23"
                                   partialTriggers="poll1"/>
                 </af:panelGroupLayout>
               </af:poll>
             </af:panelGroupLayout>
             <af:panelGroupLayout id="pgl7" layout="vertical">
               <af:commandButton text="Time Manager On / Off" id="cb1"
                                 actionListener="#{TimerBean.timerManager}"/>
               <af:commandButton text="Batch 1 On / Off" id="cb2"
                                 actionListener="#{TimerBean.Batch1}"/>
               <af:commandButton text="Batch 2 On / Off" id="cb3"
                                 actionListener="#{TimerBean.Batch2}"/>
             </af:panelGroupLayout>
           </af:panelGroupLayout>
         </af:panelFormLayout>
       </af:panelHeader>
     </af:form>
   </af:document>
 </f:view>
</jsp:root>


package nl.whitehorses.wls.backing;

import commonj.timers.Timer;
import commonj.timers.TimerManager;

import javax.faces.event.ActionEvent;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import nl.whitehorses.wls.schedular.Batch1;
import nl.whitehorses.wls.schedular.Batch2;

import javax.faces.context.FacesContext; 
import javax.servlet.ServletContext;

public class TimerBean {


   private InitialContext ic = null;
   private TimerManager tm = null;

   private Timer batchRun1Timer = null;
   public Boolean batchRun1TimerIsRunning = false;
   private Timer batchRun2Timer = null;
   public Boolean batchRun2TimerIsRunning = false;


   public TimerBean() {
       try {
           ic = new InitialContext();
           tm = (TimerManager)ic.lookup("java:comp/env/tm/TimerManager");

          FacesContext ctx = FacesContext.getCurrentInstance();
          ServletContext servletContext = (ServletContext) ctx.getExternalContext().getContext();
        
          batchRun1Timer = (Timer)servletContext.getAttribute("batch1");
          batchRun2Timer = (Timer)servletContext.getAttribute("batch2");
          batchRun1TimerIsRunning = (Boolean)servletContext.getAttribute("batch1Running");
          batchRun2TimerIsRunning = (Boolean)servletContext.getAttribute("batch2Running");
          System.out.println("init end");

      } catch (NamingException e) {
           e.printStackTrace();
       }
   }

   public void timerManager(ActionEvent actionEvent) {
       // Add event code here...
       if ( tm.isSuspended() ) {
           tm.resume();       
       } else {
           tm.suspend();
       }
   }

   public void Batch1(ActionEvent actionEvent) {
       // Add event code here...
       if (  batchRun1TimerIsRunning ) {
             batchRun1Timer.cancel();
             batchRun1TimerIsRunning = false;
       } else {
              batchRun1Timer = tm.schedule(new Batch1(), 0, 10 * 1000);
              batchRun1TimerIsRunning = true;
       }
      
   }

   public void Batch2(ActionEvent actionEvent) {
       // Add event code here...
       if (  batchRun2TimerIsRunning ) {
             batchRun2Timer.cancel();
             batchRun2TimerIsRunning = false;
       } else {
              batchRun2Timer = tm.schedule(new Batch2(), 0, 10 * 1000);
              batchRun2TimerIsRunning = true;
       }
   }
  
   public String getTmStatus () {
       if ( tm.isSuspended() ) {
          return "TimerManager is stopped";       
       } else {
          return "TimerManager is running";       
       }
   }

   public String getBatch1Status () {
      Long time = batchRun1Timer.getScheduledExecutionTime();
      java.util.Date date = new  java.util.Date(time);
      if ( batchRun1TimerIsRunning ) {
        return "Batch1 scheduled time "+date.toString();
      } {
        return "Batch1 stopped";
      }
   }
  
   public String getBatch2Status () {
      Long time = batchRun2Timer.getScheduledExecutionTime();
      java.util.Date date = new  java.util.Date(time);
       if ( batchRun2TimerIsRunning ) {
         return "Batch2 scheduled time "+date.toString();
       } {
         return "Batch2 stopped";
       }   
   }


   public Timer getBatchRun1Timer(){
     return batchRun1Timer;
   }

   public void setBatchRun1Timer(Timer batchRun1Timer ){
     this.batchRun1Timer = batchRun1Timer;
   }

   public Timer getBatchRun2Timer(){
     return batchRun2Timer;
   }

   public void setBatchRun2timer(Timer batchRun2Timer ){
     this.batchRun2Timer = batchRun2Timer;
   }
}

Here is the example workspace.

WSM in Fusion Middleware 11G

2009-09-16T23:12:00.011+02:00

Probably you already knew the Web Service Manager of Soa Suite 10.1.3, The 10.1.3 version was mainly used in combination with Soa Suite because this was the only way to secure the BPEL and ESB Services. In FMW 11g Oracle changed WSM so it is fully integrated in all the Fusion Middleware components. Now you can use WSM in ADF, in the Services and References of Soa Suite and in the jax-ws services or proxy clients.
In FMW 11G you can also define your own ws-security policies ( just use a wizard in the EM website) or use the standard policies, So it can always comply to your security requirements.

In this blog entry I will show you how to setup FMW on Weblogic and define security on a BPEL service, call this service with an ADF Web Service Datacontol and a java web service proxy client.

Special thanks to Vishal Jain of Oracle who helped to solve the issues and explained how WSM works with keystores.

First we need to generate a keystore with a self signed certificate. Somehow certificates with generated with OpenSSL fails in FMW.
keytool -genkey -keyalg RSA -keystore C:\test_keystore.jks -storepass password -alias client_key -keypass password -dname "CN=Client, OU=WEB AGE, C=US" -keysize 1024 -validity 1460

Now here comes the trick , copy this keystore to fmwconfig folder ( domain_name/config ) of the soa suite domain

Go the Enterprise Manager Website where we can configure the just created keystore. We have to select the weblogic domain and go to the security menu / credentials.

Here we can change maps or passwords which will be stored in the cwallet.sso file. If you see the oracle.wsm.security map then you can delete this map. This map contains the keystore password.

Go the Security Provider Configuration menu item in the security menu where we will add the keystore to FMW
Press the Configure button in the keystore part of the screen.

Here we can add the keystore details. Use ./ as keystore path. This will fill the oracle.wsm.security map in the credentials menu.

Go back to the Credentials where we will add an extra entry in the wsm map. Create a new key basic.credentials with as username weblogic and with password weblogic1

Restart the Weblogic server.

Next part is to add a wsm policy to a BPEL Service.

Select the server policy you like to use and deploy this to the soa suite server.

Now we can make a jax-ws proxy client so we can test the policy. In this client we will use the matching client policy. If this fails check your libraries.


package nl.whitehorses.wsclient;

import java.util.Map;

import javax.xml.ws.BindingProvider;
import javax.xml.ws.WebServiceRef;

import oracle.webservices.ClientConstants;

import weblogic.wsee.jws.jaxws.owsm.SecurityPolicyFeature;

public class BPELProcess1_ptClient
{
 @WebServiceRef
 private static Bpelprocess1_client_ep bpelprocess1_client_ep;

 public static void main(String [] args)
 {
   bpelprocess1_client_ep = new Bpelprocess1_client_ep();
  
     SecurityPolicyFeature[] securityFeature = new SecurityPolicyFeature[] {
                      new SecurityPolicyFeature("oracle/wss10_message_protection_client_policy") };

     BPELProcess1 port = bpelprocess1_client_ep.getBPELProcess1_pt(securityFeature);
    
    
     Map reqContext = ((BindingProvider) port).getRequestContext();
     reqContext.put(ClientConstants.WSSEC_KEYSTORE_TYPE, "JKS");
     reqContext.put(ClientConstants.WSSEC_KEYSTORE_LOCATION, "C:\\test_keystore.jks");
     reqContext.put(ClientConstants.WSSEC_KEYSTORE_PASSWORD, "password");
     reqContext.put(ClientConstants.WSSEC_SIG_KEY_ALIAS, "client_key");
     reqContext.put(ClientConstants.WSSEC_SIG_KEY_PASSWORD, "password");
     reqContext.put(ClientConstants.WSSEC_ENC_KEY_ALIAS, "client_key");
     reqContext.put(ClientConstants.WSSEC_ENC_KEY_PASSWORD, "password");
     reqContext.put(ClientConstants.WSSEC_RECIPIENT_KEY_ALIAS, "client_key");
     System.out.println("output = " + port.process("aaaa"));
 
 }
}

If all went well then we can do same with a ADF Web Service Datacontrol.

To add the client policy select the DataControls.dcx and go to the structure window.

Here we can define web service security

Select the right client policy and in this case we need to override properties, press the button and fill in the recipient with your key alias. Else you will get a orakey error.

And at last deploy this webapplication with a ear profile to the Soa Suite server and test your webapp.

SSO with WebLogic 10.3.1 and SAML2

2009-09-14T00:42:00.008+02:00

In a previous blog entry I already explained how to setup Single Sign On (SSO) with SAML1.1. In this blogpost I do the same but then with SAML version 2 or SAML2 in Weblogic 10.3.1 server.
First we start with the SAML2 Identity Provider, in SAML1.1 this is called the source site. Because we can't do anything in the federation tab of the serve, we need to create a Credential Mapping Provider ( go to myrealm security, Providers , Credential Mappings. )
and choose the SAML2 credential mapping.

Fill the provider specific details and use the demoidentity keystore ( this is default)

Now we can go the Federation Services tab of the server configuration and create a SAML2 profile for this server, We need to save this to a file and import this later in the other SAML2 Service Providers.
The published site url is very important , choose url of this server , use http or https and add saml2 to this url. SAML needs this url to communicate with the other SAML services.

Second part of the SAML2 profile

Save this profile to a xml

Go the Identity provider tab and fill in these fields
Go to the second Weblogic server, this is called the Service provider or in SAML1.1 the destination. Here we need to create a new SAML2 Authentication provider ( Go to the myrealm Security realm , Providers and then Authentication )

Now we done this we can go the Federation Services Tab of this weblogic server and fill in this SAML2 profile. The published url is very important and it must match with the server url and have to end with saml2

Second part of this SAML profile

Save this metadata to a xml. This needs to be imported in the Credential Mapping Provider of the Identity Provider ( the first weblogic server).

Next step is to go the SAML2 Service Provider tab.
Go back to the SAML2 authentication provider where we will import the identity provider metadata xml.

Select the identity metadata xml.

You have to enable this and most important, fill in all the url's of your applications who needs SAML authentication.

Now we do the same for metadata xml of the service provider, We need to import this in the Credential Mapper provider of the Identity Provider
Select the Service Provider metadata xml

enable this Service Provider.

That's all

In this example I use http but it shoud also work with https and when it fails, please check your url's , don't mix localhost or pc name. Same for the domain name.

For more debug information in your server.log and set these java parameters in your setDomainEnv
set EXTRA_JAVA_PROPERTIES=-Dweblogic.debug.DebugSecuritySAMLAtn=true -Dweblogic.debug.DebugSecuritySAMLLib=true -Dweblogic.debug.DebugSecuritySAML2Service=true -Dweblogic.debug.DebugSecuritySAML2CredMap=true -Dweblogic.debug.DebugSecuritySAML2Atn=true %EXTRA_JAVA_PROPERTIES%

Starting SOA Suite Testcases from java

2009-08-25T21:51:00.005+02:00

In a previous blog I already explained how to unit test a Soa Suite 11g composite application. In that blog entry I create a Test Suite with a testcase but I had to start this testcase and watch the results of the test in the Enterprise Manager Website. In this blog I will start the TestSuite with the Testcases from the Soa Suite java API. This can be handy when you have a continious build system like Hudson or Apache Continuum. Now you can build your test in JDeveloper and run the test in the Continious Build System.
In this test I made a simple Test Suite with two testcases and deployed this to the Soa Suite Server.
Create a test project with the following libraries
And create a java class like this example class.


package nl.whitehorses.bpel.unit;

import java.util.Hashtable;
import java.util.List;

import javax.naming.Context;

import oracle.soa.management.facade.Locator;
import oracle.soa.management.facade.LocatorFactory;

import oracle.soa.management.util.TestSuiteFilter;
import oracle.soa.management.util.TestRunOptions;

import oracle.soa.management.facade.tst.TestSuite;
import oracle.soa.management.facade.tst.TestCase;
import oracle.soa.management.facade.tst.TestRunResults;
import oracle.soa.management.facade.tst.TestSuiteResult;
import oracle.soa.management.facade.tst.TestCaseResult;


public class StartUnitProcess {
 public StartUnitProcess() {
     super();

     Hashtable jndiProps = new Hashtable();
     jndiProps.put(Context.PROVIDER_URL, "t3://localhost:8001/soa-infra");
     jndiProps.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
     jndiProps.put(Context.SECURITY_PRINCIPAL, "weblogic");
     jndiProps.put(Context.SECURITY_CREDENTIALS, "weblogic1");
     jndiProps.put("dedicated.connection", "true");

     Locator locator = null;
     try {
         // connect to the soa server
         locator = LocatorFactory.createLocator(jndiProps);

         TestSuiteFilter testFilter = new TestSuiteFilter();
         testFilter.addSuiteName("HelloTest");
         String compositeDN = "default/Helloworld!1.0";
         List testSuites = locator.getTestSuites(compositeDN,testFilter);
      
         for (TestSuite testSuite : testSuites) {
             System.out.println("Found TestSuite name: "+testSuite.getName()+" description: "+testSuite.getDescription());
          
             List testcases = testSuite.getTestCases();
             System.out.println("Total TestCases: " +testcases.size());
         
             for (TestCase testCase : testcases) {
                 System.out.println("Contains TestCase: " +testCase.getName());
             }
          
             TestRunOptions testRunOptions = new TestRunOptions();
             testRunOptions.setTestRunId("123");
             testRunOptions.setTestRunName("name123");
          
             TestRunResults result =  locator.executeTestCases(compositeDN,testRunOptions,testcases);
             System.out.println("total errors: "+ result.getNumErrors() +
                                " status: "+ result.getStatus());

             List testSuiteResults = result.getTestSuiteResults() ;
             for (TestSuiteResult testSuiteResult : testSuiteResults) {
                 System.out.println("TestSuite name: "+testSuiteResult.getSuiteName()+
                                    " success: "+testSuiteResult.getNumSuccesses()  +
                                    " errors: "+ testSuiteResult.getNumErrors() );
                 List testCaseResults = testSuiteResult.getTestResults() ;
                 for (TestCaseResult testCaseResult : testCaseResults) {
                     System.out.println("TestCase name: "+testCaseResult.getTestName()+
                                        " status: "+testCaseResult.getStatus()   );
                 }                 
             }             
         }
     } catch (Exception e) {
         e.printStackTrace();
     }
 }

 public static void main(String[] args) {
     StartUnitProcess startUnitProcess = new StartUnitProcess();
 }
}

Here is an example of the result of invoking the TestSuite in java

HTC Hero ( Android ) Thetering

2009-08-17T23:08:00.023+02:00

This blog is about how to setup your PC and HTC Hero android phone, so you can use your phone as a proxy server. This is called Thetering.

First we need to download the latest HTC Sync Software. Use this url.
Now we can open the HTC Sync on your PC. You will see that the buttons are not enabled even when you connect your phone with an USB cable.

Connect your the USB cable so the HTC Hero and your PC are connected.

Open the status bar of your phone and press HTC Sync and watch how the buttons are accessible in your HTC Sync PC application.

When you take a look at your hardware then you will see an Android USB Device.

Download Proxoid for free from the Market ( on your HTC Hero ) and install this app on your phone.

Download the android utilities for your PC :
for 32 bits : http://www.baroukh.com/proxoid/proxoid-adb.zip
for 64 bits : http://www.baroukh.com/proxoid/proxoid-adb64.zip
and save it on your disk and unpack this in a folder.

Go to this folder

open check.bat or adb.exe devices to see the connected devices

open start-tunnel.bat or adb.exe forward tcp:8080 tcp:8080
open Proxoid on your phone and start Proxoid.

and set the proxy server in your favorite browser
that's all, happy browsing

CRUD operations with a Bind Entity variable in BPEL

2009-08-13T17:56:00.009+02:00

With Soa Suite 11G ( FMW 11G R1) you can now use the Bind Entity activity in a BPEL process, which can do your CRUD operations for you. This Bind Entity is connected to a web service reference, this WS has to have SDO types just like an ADF BC SDO service interface. Now you can use an normal Assign activity to retrieve or update data from the Entity variable instead of an invoking a lot of Partner Links.

First we need to make a SDO web service. For more details then this short description, see my previous blog or this blog of Andrejus .

I made an simple ADF BC Model project with an Employee viewobject based on the employees table in the HR sample schema.

Create a Service Interface on this Employees Viewobject and select all the basic operations.

JDeveloper 11G generates SDO types on this employees viewobject and generates a Web Service on this Application Module. We will use this WS in the BPEL process.

Create a new Service Interface deployment profile

Deploy this to a Weblogic Server

The Web Service is ready and we can create a new SOA Project. I use a XSD with a simple request and response. The input will be the EmployeeId and the BPEL process returns the lastname

We don't need use the ADF-BC service adapter, just add the Web Service Adapter to the Composite. Use the WSDL of the Employee WS in the WS Reference adapter

Wire the WS adapter reference to the BPEL process
Open the BPEL process and add a new variable

Select the partnerlink in the entity variable.

Select the Employee WS
Now we need to define the element in this variable. Select the Employees SDO element

Add the Bind Entity activity to the BPEL process, This will map the Primary Key on the just created variable.

Select the just created employee variable
Select the Primary Key Element of the Employee XSD. In my case is this EmployeeId

And use the BPEL request (input) variable as value to this PK column. This will lookup the right employee

We are ready with the configuration of the Bind Entity. We can now use Assign Activities to retrieve or update the Employee record. In my case I will get the lastname of the employee and return this as response

that's all , just deploy this to the Soa Server and test this in the EM website. Use for example 199

This returns Grant as lastname

Here you can download the test workspace

JDeveloper 11G improvements for the Mediator component

2009-08-02T14:10:00.007+02:00

With JDeveloper 11G FMW R1 Oracle made life a little bit easier when you are working with the Mediator component. In 10.1.3 the ESB Router can do a lot but you didn't have IDE support to configure this.
The first big change is the Assign option in the routing rules. In 10.1.3 you can change the header properties of a adapter by setting these values in the XSLT transformation of a routing.

In 11G you can't set a adapter property in a routing rule transformation. You need to do this in the assign option. This is a great feature, the transformation doesn't contain any hidden logica.

This assign wizard summarize all the possible header properties you can set. In 10.1.3 you have to search the internet what properties you can use.

The ESB XSLT header functions are now being replaced by the Mediator Get Functions. The Set functions are replaced by the Assign option.

In 11G you can create a Domain Value Map in JDeveloper. In 10.1.3 we had to do this in the ESB console, this is great for the DVM lookup XSLT function. You can use the looking glass button to select the right values.

The XSLT GetProperty function also summaries all the adapter properties.

In 10.1.3 we have a ESB request parameter to see the original request in the reply transformation. In 10.1.3 we have to do this all manually with JDeveloper 11G you have now an Include Request option in the reply Transformation.

In the XSLT editor you can use the request values in your reply transformation.