Recovering the BPEL instances from Java For Fault Recovery For Invoke

Written By Archit Bhardwaj There are three types of Recoverable messages in BPEL Recovery console 1.       Invoke 2.       Callback 3.       Activity There are five message states for each type 1.       Undelivered 2.       Resolved 3.       Delivered 4.       Cancelled 5.       Exhausted The Classes mentioned below are used only to recover messages in Undelivered Message state. ·         FaultRecoveryForInvoke.java- It recovers undelivered recoverable Invoke instances based on Composite Name. ·         FaultRecoveryForInvokeAll.java- It recovers all the Undelivered recoverable Invoke instances. ·         FaultRecoveryForCallback.java- It recovers undelivered recoverable Callback instances based on Composite Name. ·         FaultRecoveryForCallbackAll.java- It recovers all the Undelivered recoverable Callback instances. The state set for undelivered instances is 0 in the code.     For recovering messages from other states ,the filter.setState(x) can be changed to :- 0 for Undelivered 1 for Resolved 2 for delivered 3 for Cancelled 4 for exhausted The jar files used for the code are :-   Code For Fault Recovery For Invoke for single service *************************************************************************** package Recovery.client; import java.util.Hashtable; import java.util.List; import java.util.ListIterator; import java.util.Scanner; import javax.naming.Context; import oracle.soa.management.facade.Locator; import oracle.soa.management.facade.LocatorFactory; import oracle.soa.management.facade.bpel.BPELServiceEngine; import oracle.soa.management.facade.bpm.BPMInvokeMessage; import oracle.soa.management.util.MessageFilter; public class FaultRecoveryForInvoke{     private Locator locator = null;     private BPELServiceEngine mBPELServiceEngine;               public FaultRecoveryForInvoke(){         System.out.println("Inside Constructor");         locator = this.getLocator();                 try{                 System.out.println("Try Block of Constructor");                 mBPELServiceEngine=(BPELServiceEngine)locator.getServiceEngine(Locator.SE_BPEL);             }             catch (Exception e){                 e.printStackTrace();             }     }               // Setting up connection properties           public Hashtable getJndiProps(){       System.out.println("Inside getJndiProps");         Hashtable jndiProps = new Hashtable();         jndiProps.put(Context.PROVIDER_URL,"t3://manish:7501/soa-infra");         jndiProps.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");         jndiProps.put(Context.SECURITY_PRINCIPAL, "manish");         jndiProps.put(Context.SECURITY_CREDENTIALS, "*********");         jndiProps.put("dedicated.connection", "true");       System.out.println("Connection Successfull");         return jndiProps;     }             //Creating the locator to set up the connection to the server           public Locator getLocator(){       System.out.println("Inside  getLocator");        try{             System.out.println("Try Block of getLocator");             return LocatorFactory.createLocator(getJndiProps());         }       catch(Exception e){             e.printStackTrace();       }         return null;     }             // Reovering all recoverable faults listed under invoke and having the state Undelivered as on BPEL Recovery Console           public void recoverFaults(){       System.out.println("Inside  recoverFaults");       try{             int i=1;             System.out.println("Try Block of recoverFaults");             MessageFilter filter=new MessageFilter();                               //Input Composite Name             Scanner sc=new Scanner(System.in);             System.out.println("Enter The Composite Name");             String CompositeName=sc.next();                                           //filters can be set according to desired criteria             filter.setCompositeName(CompositeName);             filter.setState(0);                                            //Getting all recoverable messages             System.out.println("Getting Recoverable messages");             List<BPMInvokeMessage> recoverable=mBPELServiceEngine.getInvokeMessages(filter);             ListIterator it=recoverable.listIterator();             while(it.hasNext()){                   System.out.println("Record number----->>>"+i+"\t"+it.next());                   i++;             }             System.out.println("total number of records-------->>>>>"+recoverable.size());                         //Recovering all recoverable messages             mBPELServiceEngine.recoverInvokeMessages(recoverable);             System.out.println("Messages Retried in one chance");         }                catch (Exception e){             e.printStackTrace();       }     }     public static void main(String[] args){       // calling the method recoverFaults        FaultRecoveryForInvoke faultRecovery = new FaultRecoveryForInvoke();        faultRecovery.recoverFaults();     } } ************************************************************************