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

项目:jstorm-0.9.6.3-    文件:UIUtils.java   
public static List nimbusClientandConn(String host, Integer port)
        throws TTransportException {
    TSocket ts = new TSocket(host, port);
    TFramedTransport tt = new TFramedTransport(ts);
    TBinaryProtocol prot = new TBinaryProtocol(tt);
    Client nc = new Client(prot);
    ts.open();
    List l = new ArrayList();
    l.add(nc);
    l.add(tt);
    return l;
}
项目:jstorm-0.9.6.3-    文件:SimpleTransportPlugin.java   
/**
 * Connect to the specified server via framed transport
 * 
 * @param transport
 *            The underlying Thrift transport.
 */
@Override
public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException {
    // create a framed transport
    TTransport conn = new TFramedTransport(transport);

    // connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}
项目:jstorm-0.9.6.3-    文件:DRPCClient.java   
private void connect() throws TException {
    TSocket socket = new TSocket(host, port);
    if (timeout != null) {
        socket.setTimeout(timeout);
    }
    conn = new TFramedTransport(socket);
    client = new DistributedRPC.Client(new TBinaryProtocol(conn));
    conn.open();
}
项目:jstorm-0.9.6.3-    文件:SimpleTransportPlugin.java   
/**
 * Connect to the specified server via framed transport 
 * @param transport The underlying Thrift transport.
 */
public TTransport connect(TTransport transport, String serverHost) throws TTransportException {
    //create a framed transport
    TTransport conn = new TFramedTransport(transport);

    //connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}
项目:learn_jstorm    文件:UIUtils.java   
public static List nimbusClientandConn(String host, Integer port)
        throws TTransportException {
    TSocket ts = new TSocket(host, port);
    TFramedTransport tt = new TFramedTransport(ts);
    TBinaryProtocol prot = new TBinaryProtocol(tt);
    Client nc = new Client(prot);
    ts.open();
    List l = new ArrayList();
    l.add(nc);
    l.add(tt);
    return l;
}
项目:learn_jstorm    文件:SimpleTransportPlugin.java   
/**
 * Connect to the specified server via framed transport
 * 
 * @param transport
 *            The underlying Thrift transport.
 */
public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException {
    // create a framed transport
    TTransport conn = new TFramedTransport(transport);

    // connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}
项目:learn_jstorm    文件:DRPCClient.java   
private void connect() throws TException {
    TSocket socket = new TSocket(host, port);
    if (timeout != null) {
        socket.setTimeout(timeout);
    }
    conn = new TFramedTransport(socket);
    client = new DistributedRPC.Client(new TBinaryProtocol(conn));
    conn.open();
}
项目:learn_jstorm    文件:SimpleTransportPlugin.java   
/**
 * Connect to the specified server via framed transport 
 * @param transport The underlying Thrift transport.
 */
public TTransport connect(TTransport transport, String serverHost) throws TTransportException {
    //create a framed transport
    TTransport conn = new TFramedTransport(transport);

    //connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}
项目:jstrom    文件:SimpleTransportPlugin.java   
/**
 * Connect to the specified server via framed transport 
 * @param transport The underlying Thrift transport.
 */
public TTransport connect(TTransport transport, String serverHost) throws TTransportException {
    //create a framed transport
    TTransport conn = new TFramedTransport(transport);

    //connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}
项目:Infrastructure    文件:ThriftConnection.java   
/**
 * Creates a connection with explicit nimbus host. Ignored if a local cluster is set 
 * for testing.
 * 
 * @param nimbusHost the nimbus host name
 * @param port the nimbus port number
 * @see #setLocalCluster(ILocalCluster)
 */
public ThriftConnection(String nimbusHost, int port) {
    if (null == localCluster) {
        socket = new TSocket(nimbusHost, port);
        LOGGER.info("Thrift connection info " + nimbusHost + " " + port);
        transport = new TFramedTransport(socket);
        protocol = new TBinaryProtocol(transport);
        client = new Client(protocol);
    }
}
项目:Tstream    文件:SimpleTransportPlugin.java   
/**
 * Connect to the specified server via framed transport
 * 
 * @param transport
 *            The underlying Thrift transport.
 */
public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException {
    // create a framed transport
    TTransport conn = new TFramedTransport(transport);

    // connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}
项目:Tstream    文件:DRPCClient.java   
private void connect() throws TException {
    TSocket socket = new TSocket(host, port);
    if (timeout != null) {
        socket.setTimeout(timeout);
    }
    conn = new TFramedTransport(socket);
    client = new DistributedRPC.Client(new TBinaryProtocol(conn));
    conn.open();
}
项目:Tstream    文件:UIUtils.java   
public static List nimbusClientandConn(String host, Integer port)
        throws TTransportException {
    TSocket ts = new TSocket(host, port);
    TFramedTransport tt = new TFramedTransport(ts);
    TBinaryProtocol prot = new TBinaryProtocol(tt);
    Client nc = new Client(prot);
    ts.open();
    List l = new ArrayList();
    l.add(nc);
    l.add(tt);
    return l;
}
项目:openimaj    文件:KestrelThriftClient.java   
public KestrelThriftClient(String hostname, int port)
        throws TException
{

    _transport = new TFramedTransport(new TSocket(hostname, port));
    final TProtocol proto = new TBinaryProtocol(_transport);
    _client = new Kestrel.Client(proto);
    _transport.open();
}
项目:jstorm-0.9.6.3-    文件:DRPCInvocationsClient.java   
private void connect() throws TException {
    conn = new TFramedTransport(new TSocket(host, port));
    client = new DistributedRPCInvocations.Client(new TBinaryProtocol(conn));
    conn.open();
}
项目:learn_jstorm    文件:DRPCInvocationsClient.java   
private void connect() throws TException {
    conn = new TFramedTransport(new TSocket(host, port));
    client = new DistributedRPCInvocations.Client(new TBinaryProtocol(conn));
    conn.open();
}
项目:Tstream    文件:DRPCInvocationsClient.java   
private void connect() throws TException {
    conn = new TFramedTransport(new TSocket(host, port));
    client = new DistributedRPCInvocations.Client(new TBinaryProtocol(conn));
    conn.open();
}