Package org.apache.etch.bindings.java.support

Examples of org.apache.etch.bindings.java.support.ServerFactory.transportControl()

44
45
46
47
48
49
50
51
52
53
54
    final String uri = "tcp://localhost:4004";
   
    ServerFactory listener = PerfHelper.newListener( uri, null,
      new MainPerfListener() );

    listener.transportControl( Transport.START_AND_WAIT_UP, 4000 );
   
    System.out.println( "ready" );
  }

  public PerfServer newPerfServer( RemotePerfClient client )
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
    final ServerFactory listener;

    if (startListener)
    {
      listener = PerfHelper.newListener( uri, null, implFactory );
      listener.transportControl( Transport.START_AND_WAIT_UP, maxWaitTime );
    }
    else
    {
      listener = null;
    }
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
        perfReport2( nThreads );
      }
    }

    if (listener != null)
      listener.transportControl( Transport.STOP_AND_WAIT_DOWN, maxWaitTime );
  }

  private static void perfReport2( int threads ) throws Exception
  {
    new PerfTest( "report2", runtime, trials, threads )
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
   
    ServerFactory listener = ExampleHelper.newListener( uri, null,
      new MainExampleListener() );

    // Start the Listener
    listener.transportControl( Transport.START_AND_WAIT_UP, 4000 );
  }

  public ExampleServer newExampleServer( RemoteExampleClient client )
  {
    return new ImplExampleServer( client );
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
    String uri = "tcp://0.0.0.0:4007";
   
    ServerFactory listener = DistributedHashTableHelper.newListener( uri, null,
      new MainDistributedHashTableListener() );

    listener.transportControl( Transport.START_AND_WAIT_UP, 4000 );
  }
 
  private final Map<String, Object> map =
    Collections.synchronizedMap( new HashMap<String, Object>() );
View Full Code Here
29
30
31
32
33
34
35
36
37
38
39
   
    ServerFactory listener = ExampleHelper.newListener( uri, null,
      new MainExampleListener() );

    // Start the Listener
    listener.transportControl( Transport.START_AND_WAIT_UP, 4000 );
  }

  public ExampleServer newExampleServer( RemoteExampleClient client )
  {
    return new ImplExampleServer( client );
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
    String uri = "tcp://0.0.0.0:4001";
   
    ServerFactory listener = TypesHelper.newListener( uri, null,
      new MainTypesListener() );

    listener.transportControl( Transport.START_AND_WAIT_UP, 4000 );
  }

  public TypesServer newTypesServer( RemoteTypesClient client )
  {
    return new ImplTypesServer( client );
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
  {
    String uri = "tcp://0.0.0.0:4006";
   
    ServerFactory listener = ClosingHelper.newListener( uri, null, new MainClosingListener() );

    listener.transportControl( Transport.START_AND_WAIT_UP, 4000 );
   
    InetSocketAddress localAddr = (InetSocketAddress) listener.transportQuery( TcpListener.LOCAL_ADDRESS );
    URL u = new URL( "tcp:" );
    u.setHost( localAddr.getHostName() );
    u.setPort( localAddr.getPort() );
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
   
    ServerFactory listener = HelloWorldHelper.newListener( uri, null,
      new MainHelloWorldListener() );

    // Start the Listener
    listener.transportControl( Transport.START_AND_WAIT_UP, 4000 );
  }

  public HelloWorldServer newHelloWorldServer( RemoteHelloWorldClient client )
  {
    return new ImplHelloWorldServer( client );
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
  {
    String uri = "tcp://0.0.0.0:4001";

    ServerFactory listener = FooHelper.newListener( uri, null, new MainFooListener() );

    listener.transportControl( Transport.START_AND_WAIT_UP, 4000 );
  }

  /**
   * Constructs the MainFooListener.
   */
 
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.