Package org.openspaces.admin.pu

Examples of org.openspaces.admin.pu.ProcessingUnit

87
88
89
90
91
92
93
94
95
96
97
98
99
        return clusterInfo.getName().substring(0, index);
    }

    private static ProcessingUnitInstance[] waitForInstances(final String applicationName, final String serviceName, final int minimumNumberOfInstances, final long timeout, final TimeUnit timeunit) {
        final ProcessingUnit pu = waitForProcessingUnit(applicationName, serviceName, timeout, timeunit);
        pu.waitFor(minimumNumberOfInstances, timeout, timeunit);
        final ProcessingUnitInstance[] instances = pu.getInstances();
        if (instances.length < minimumNumberOfInstances) {
            throw new IllegalStateException("Could not discover " + minimumNumberOfInstances + " "+ serviceName + " instances in application " + applicationName);
        }
        return instances;
    }
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
    }

    private static ProcessingUnit waitForProcessingUnit(final String applicationName, final String serviceName,  final long timeout, final TimeUnit timeunit) {
        final Admin admin = new AdminFactory().createAdmin();
        final String puName = applicationName + "." + serviceName;
        final ProcessingUnit pu = admin.getProcessingUnits().waitFor(puName, timeout, timeunit);
        if (pu == null) {
            throw new IllegalStateException("Could not discover service " + serviceName + " in application " + applicationName);
        }
        return pu;
    }
View Full Code Here
TOP

Related Classes of org.openspaces.admin.pu.ProcessingUnit

  • org.openspaces.bigdata.processor.ServiceDiscoveryPropertyPlaceHolderConfigurer
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.