Examples of connect()

Examples of org.apache.helix.manager.zk.ZKHelixManager.connect()

60
61
62
63
64
65
66
67
68
69
70
    ZKHelixManager controller = new ZKHelixManager(clusterName, null,
                                                   InstanceType.CONTROLLER,
                                                   ZK_ADDR);
    try
    {
      controller.connect();
      Assert.fail("Should throw HelixException if initial cluster structure is not setup");
    } catch (HelixException e)
    {
      // OK
    }
View Full Code Here

Examples of org.apache.helix.manager.zk.ZkHelixConnection.connect()

55
56
57
58
59
60
61
62
63
64
65
    opts.addOption("participantClass", true, "Participant service class");
    try {
      CommandLine cliParser = new GnuParser().parse(opts, args);
      String zkAddress = cliParser.getOptionValue("zkAddress");
      final HelixConnection connection = new ZkHelixConnection(zkAddress);
      connection.connect();
      ClusterId clusterId = ClusterId.from(cliParser.getOptionValue("cluster"));
      ParticipantId participantId = ParticipantId.from(cliParser.getOptionValue("participantId"));
      String participantClass = cliParser.getOptionValue("participantClass");
      @SuppressWarnings("unchecked")
      Class<? extends AbstractParticipantService> clazz =
View Full Code Here

Examples of org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect()

110
111
112
113
114
115
116
117
118
119
120
        final HttpRequest request = new BasicHttpRequest("GET", uri, HttpVersion.HTTP_1_1);
        final HttpContext context = new BasicHttpContext();

        HttpClientConnection conn = getConnection(mgr, route);
        mgr.connect(conn, route.getTargetHost(), route.getLocalAddress(), 0, context);

        context.setAttribute(ExecutionContext.HTTP_CONNECTION, conn);
        context.setAttribute(ExecutionContext.HTTP_TARGET_HOST, target);

        final HttpProcessor httpProcessor = new ImmutableHttpProcessor(
View Full Code Here

Examples of org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.connect()

110
111
112
113
114
115
116
117
118
119
120
           
        });
        t.start();

        SessionRequest[] reqs = new SessionRequest[3];
        reqs[0] = ioReactor.connect(
                new InetSocketAddress("www.yahoo.com", 80),
                null,
                new HttpHost("www.yahoo.com"),
                null);
        reqs[1] = ioReactor.connect(
View Full Code Here

Examples of org.apache.http.nio.impl.reactor.DefaultConnectingIOReactor.connect()

56
57
58
59
60
61
62
63
64
65
66
            .setParameter(HttpProtocolParams.USER_AGENT, "Jakarta-HttpComponents-NIO/1.1");

        ConnectingIOReactor ioReactor = new DefaultConnectingIOReactor(2, params);

        SessionRequest[] reqs = new SessionRequest[3];
        reqs[0] = ioReactor.connect(
                new InetSocketAddress("www.yahoo.com", 80),
                null,
                new HttpHost("www.yahoo.com"));
        reqs[1] = ioReactor.connect(
                new InetSocketAddress("www.google.com", 80),
View Full Code Here

Examples of org.apache.http.nio.reactor.ConnectingIOReactor.connect()

110
111
112
113
114
115
116
117
118
119
120
           
        });
        t.start();

        SessionRequest[] reqs = new SessionRequest[3];
        reqs[0] = ioReactor.connect(
                new InetSocketAddress("www.yahoo.com", 80),
                null,
                new HttpHost("www.yahoo.com"),
                null);
        reqs[1] = ioReactor.connect(
View Full Code Here

Examples of org.apache.isis.runtimes.dflt.remoting.marshalling.encode.EncodingMarshaller.connect()

39
40
41
42
43
44
45
46
47
48
49
    @Override
    protected ServerConnectionDefault createServerConnection(final InputStream input, final OutputStream output, final ServerFacade serverFacade) {
        final SimpleTransport transport = new SimpleTransport(getConfiguration(), input, output);
        final EncodingMarshaller marshaller = new EncodingMarshaller(getConfiguration(), transport);
        try {
            marshaller.connect();
        } catch (final IOException e) {
            throw new ConnectionException(e);
        }
        return new ServerConnectionDefault(serverFacade, marshaller);
    }
View Full Code Here

Examples of org.apache.isis.runtimes.dflt.remoting.marshalling.serialize.SerializingMarshaller.connect()

40
41
42
43
44
45
46
47
48
49
50
    @Override
    protected ServerConnection createServerConnection(final InputStream input, final OutputStream output, final ServerFacade serverFacade) {
        final SimpleTransport transport = new SimpleTransport(getConfiguration(), input, output);
        final SerializingMarshaller serverMarshaller = new SerializingMarshaller(getConfiguration(), transport);
        try {
            serverMarshaller.connect();
        } catch (final IOException e) {
            throw new ConnectionException(e);
        }
        return new ServerConnectionDefault(serverFacade, serverMarshaller);
    }
View Full Code Here

Examples of org.apache.isis.runtimes.dflt.remoting.marshalling.xstream.shared.XStreamMarshaller.connect()

41
42
43
44
45
46
47
48
49
50
51
    @Override
    protected ServerConnection createServerConnection(final InputStream input, final OutputStream output, final ServerFacade distribution) {
        final SimpleTransport transport = new SimpleTransport(getConfiguration(), input, output);
        final XStreamMarshaller serverMarshaller = new XStreamMarshaller(getConfiguration(), transport);
        try {
            serverMarshaller.connect();
        } catch (final IOException e) {
            throw new ConnectionException(e);
        }
        return new ServerConnectionDefault(distribution, serverMarshaller);
    }
View Full Code Here

Examples of org.apache.jmeter.protocol.ldap.sampler.LdapExtClient.connect()

666
667
668
669
670
671
672
673
674
675
676
   **************************************************************************/
  private void singleBindOp(SampleResult res) throws NamingException {
    LdapExtClient ldap_temp;
    ldap_temp = new LdapExtClient();
    res.sampleStart();
    DirContext ctx = ldap_temp.connect(getServername(), getPort(), getRootdn(), getSuserDN(), getSuserPw());
    ldap_temp.disconnect(ctx);
    res.sampleEnd();
  }

  /***************************************************************************
 
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.