Package org.talend.esb.servicelocator.client

Examples of org.talend.esb.servicelocator.client.Endpoint$PropertiesTransformer


    public static class simpleEndpointMatcher implements IArgumentMatcher {

        @Override
        public boolean matches(Object argument) {
            if (argument != null && argument instanceof Endpoint) {
                Endpoint result = (Endpoint) argument;
                if (!ENDPOINTURL.equals(result.getAddress()))
                    return false;
                if (!SERVICE_NAME.equals(result.getServiceName()))
                    return false;
            }
            return true;
        }
View Full Code Here


    public static class simpleEndpointMatcher implements IArgumentMatcher {

        @Override
        public boolean matches(Object argument) {
            if (argument != null && argument instanceof Endpoint) {
                Endpoint result = (Endpoint) argument;
                if (!ENDPOINTURL.equals(result.getAddress()))
                    return false;
                if (!SERVICE_NAME.equals(result.getServiceName()))
                    return false;
            }
            return true;
        }
View Full Code Here

                List<EntryType> entries = arg0.getEntryType();
                for (EntryType entry : entries) {
                    slProps.addProperty(entry.getKey(), entry.getValue());
                }
            }
            Endpoint simpleEndpoint =
                new SimpleEndpoint(serviceName, endpointURL, bindingType, transportType, slProps);
            locatorClient.register(simpleEndpoint, true);
        } catch (ServiceLocatorException e) {
            // throw new ServiceLocatorFault(e.getMessage(), e);
            throw new WebApplicationException(Response
View Full Code Here

    }

    @Ignore
    @Test
    public void registerServiceExistsEndpointExistsCheckLastTimes() throws Exception {
        Endpoint endpoint = create(SERVICE_QNAME_1, ENDPOINT_1);
        Capture<Long> lastTimeStartedCapture = new Capture<Long>();

        serviceExists(SERVICE_PATH_1);
        endpointExists(ENDPOINT_PATH_11);
        getData(ENDPOINT_PATH_11, OLD_DATA);
View Full Code Here

    }

    @Ignore
    @Test
    public void registerEndpointStatusExists() throws Exception {
        Endpoint endpoint = create(SERVICE_QNAME_1, ENDPOINT_1);

        serviceExists(SERVICE_PATH_1);
        endpointExists(ENDPOINT_PATH_11);
        getData(ENDPOINT_PATH_11, OLD_DATA);
        data2Ep(SERVICE_QNAME_1, OLD_DATA);
View Full Code Here

    }

    @Ignore
    @Test
    public void registerServiceExistsEndpointExistsNot() throws Exception {
        Endpoint endpoint = create(SERVICE_QNAME_1, ENDPOINT_1);

        serviceExists(SERVICE_PATH_1);
        endpointExistsNot(ENDPOINT_PATH_11);

        ep2Data(endpoint, NEW_DATA);
View Full Code Here

    }

    @Ignore
    @Test
    public void registerEndpointPersistently() throws Exception {
        Endpoint endpoint = create(SERVICE_QNAME_1, ENDPOINT_1);

        serviceExists(SERVICE_PATH_1);

        endpointExistsNot(ENDPOINT_PATH_11);
        ep2Data(endpoint, NEW_DATA);
View Full Code Here

    }

    @Ignore
    @Test
    public void registerServiceExistsNot() throws Exception {
        Endpoint endpoint = create(SERVICE_QNAME_1, ENDPOINT_1);

        serviceExistsNot(SERVICE_PATH_1);
        createService(SERVICE_PATH_1);

        endpointExistsNot(ENDPOINT_PATH_11);
View Full Code Here

    }

    @Ignore
    @Test
    public void registerServiceExistsNotWithAuthentication() throws Exception {
        Endpoint endpoint = create(SERVICE_QNAME_1, ENDPOINT_1);

        setAuthentication(true);
        zkMock.addAuthInfo(eq("sl"), aryEq(USER_NAME_PASSWORD_BYTES));
       
        serviceExistsNot(SERVICE_PATH_1);
View Full Code Here

    }

    @Ignore
    @Test
    public void registerServiceExistsNotButConcurrentlyCreated() throws Exception {
        Endpoint endpoint = create(SERVICE_QNAME_1, ENDPOINT_1);

        serviceExistsNot(SERVICE_PATH_1);
        createServiceFails(SERVICE_PATH_1);

        endpointExistsNot(ENDPOINT_PATH_11);
View Full Code Here

TOP

Related Classes of org.talend.esb.servicelocator.client.Endpoint$PropertiesTransformer

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.