Java 类org.apache.thrift7.transport.TSaslClientTransport 实例源码

项目:jstorm-0.9.6.3-    文件:DigestSaslTransportPlugin.java   
@Override
public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException, IOException {
    ClientCallbackHandler client_callback_handler = new ClientCallbackHandler(
            login_conf);
    TSaslClientTransport wrapper_transport = new TSaslClientTransport(
            DIGEST, null, AuthUtils.SERVICE, serverHost, null,
            client_callback_handler, transport);

    wrapper_transport.open();
    LOG.debug("SASL DIGEST-MD5 client transport has been established");

    return wrapper_transport;
}
项目:learn_jstorm    文件:DigestSaslTransportPlugin.java   
public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException, IOException {
    ClientCallbackHandler client_callback_handler = new ClientCallbackHandler(
            login_conf);
    TSaslClientTransport wrapper_transport = new TSaslClientTransport(
            DIGEST, null, AuthUtils.SERVICE, serverHost, null,
            client_callback_handler, transport);

    wrapper_transport.open();
    LOG.debug("SASL DIGEST-MD5 client transport has been established");

    return wrapper_transport;
}
项目:Tstream    文件:DigestSaslTransportPlugin.java   
public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException, IOException {
    ClientCallbackHandler client_callback_handler = new ClientCallbackHandler(
            login_conf);
    TSaslClientTransport wrapper_transport = new TSaslClientTransport(
            DIGEST, null, AuthUtils.SERVICE, serverHost, null,
            client_callback_handler, transport);

    wrapper_transport.open();
    LOG.debug("SASL DIGEST-MD5 client transport has been established");

    return wrapper_transport;
}