Java program to abort composites

import java.util.Hashtable;

import java.util.List;

import java.util.Date;

import java.util.Calendar;

import javax.naming.Context;

import oracle.soa.management.facade.Component;

import oracle.soa.management.facade.ComponentInstance;

import oracle.soa.management.facade.Composite;

import oracle.soa.management.facade.Locator;

import oracle.soa.management.facade.LocatorFactory;

import oracle.soa.management.util.ComponentInstanceFilter;

import oracle.soa.management.util.CompositeInstanceFilter;

import oracle.soa.management.facade.CompositeInstance;

import oracle.soa.management.CompositeDN;

 

public class abort_running {

        public abort_running() {

            super();

        }

       

        public void abortRunningComposite(String p_PROVIDER_URL) {

        Locator locator = null;

        Hashtable jndiProps = new Hashtable();

        //Connection Details to Connect to Server

 

        System.out.println("Trying to connect to " + p_PROVIDER_URL);

       

        jndiProps.put(Context.PROVIDER_URL, p_PROVIDER_URL);

        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");

 

        long num_aborted = 0;

        long tot_instances = 0;

        long num_instance = 0;

        long display_interval = 20;

        String prefix = "";

       

        try {

                //Connect to SOA Server

                locator = LocatorFactory.createLocator(jndiProps);

                System.out.println("Connected to SOA Server.");

                java.util.List compositeDN=locator.listComposites();

                CompositeInstanceFilter filter = new CompositeInstanceFilter();

               

                Date start = new java.util.Date("Aug 4 00:00:01 GMT 2015");

               

                Calendar cal = Calendar.getInstance();

                cal.setTime(start);

                cal.add(Calendar.DAY_OF_MONTH, 1); //delete for one full day

                Date end = cal.getTime();

               

                System.out.println("Listing from " + start);

                System.out.println("Listing to " + end);

               

                //Set Minimum Creation Time

                filter.setMinCreationDate(start);

                //Set Maximum Creation Time

                filter.setMaxCreationDate(end);

                //Set for RUNNING State

                filter.setState(0);

                Composite composite=null;

                List obInstances=null;

                //For each of the returned composite

                System.out.println("There were " + compositeDN.size() + " composites returned");

                for (Object RJMOBJ : compositeDN) {

                    oracle.soa.management.CompositeDN compositeDN1 = (oracle.soa.management.CompositeDN) RJMOBJ;

                    composite = locator.lookupComposite(compositeDN1);

                        //System.out.println("Outer Loop");

                        //Get composite instances by filter

                        obInstances = composite.getInstances(filter);

                        //for each of the returned composite instances

                        tot_instances = obInstances.size();

                        display_interval = 20;

                        if (tot_instances<10000) display_interval = 20;

                        if (tot_instances<5000) display_interval = 10;

                        if (tot_instances<1000) display_interval = 5;

                        if (tot_instances<100) display_interval = 1;

                        if (tot_instances>0) {

                            System.out.println("  " + compositeDN1.getCompositeName() + " has " + obInstances.size() + " instances");

                            System.out.println("Displaying every " + display_interval);

                        };

                        num_instance = 0;

                        for (Object RJMOBJ2 : obInstances) {

                                num_instance++;

                                oracle.soa.management.facade.CompositeInstance instance = (oracle.soa.management.facade.CompositeInstance) RJMOBJ2;

                                if ((num_instance % display_interval)==0) {

                                    prefix = compositeDN1.getCompositeName() + "(" + num_instance + "/" + tot_instances + ")";

                                    System.out.println(prefix + " DN: " + instance.getCompositeDN() + " Instance: " + instance.getId() + " creation-date: " + instance.getCreationDate() + " state (" + instance.getState() + "): " + getStateAsString(instance.getState()));

                                }

                                //Set up a component filter

                                ComponentInstanceFilter cInstanceFilter = new ComponentInstanceFilter();

                                //Get child component instances

                                List childComponentInstances = instance.getChildComponentInstances(cInstanceFilter);

                                //For each child component instance

                                    /*for (Object RJMOBJ3 : childComponentInstances) {

                                    instance.abort();

                                    num_aborted++;

                                }

                                obInstances=null;

                               

                } //for

               

        } catch (Exception e) {

            System.out.println("Exception in API " + e);

        }

       

        System.out.println("Number aborder = " + num_aborted);

       

        }

        private String getStateAsString(int state){

                //Note that this is dependent on whether 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) {

            System.out.println("Start abort_running");

            String PROVIDER_URL_ADMIN = "";

            String PROVIDER_URL_SOA1 = "";

            String PROVIDER_URL_SOA2 = "";

            PROVIDER_URL_ADMIN = "t3://devsoavip1.ad.ic.ac.uk:7001/soa-infra";

            PROVIDER_URL_SOA1 = "t3://devsoavip2.ad.ic.ac.uk:8001/soa-infra";

            PROVIDER_URL_SOA2 = "t3://devsoavip3.ad.ic.ac.uk:8001/soa-infra";

           

            abort_running  abortcomposite=new abort_running();

            abortcomposite.abortRunningComposite(PROVIDER_URL_SOA1);

            System.out.println("End abort_running");

        }