Package org.apache.etch.util

Examples of org.apache.etch.util.URL

55
56
57
58
59
60
61
    Log.addSink( null );
  }
 
  private PwAuth newPwAuth( String uri ) throws Exception
  {
    return new PwAuth( transport, new URL( uri ), resources );
  }
View Full Code Here
47
48
49
50
51
52
53
54
55
56
    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() );
    localUri = u.toString();
  }
View Full Code Here
749
750
751
752
753
754
755
756
757
758
759
760
761
762
 
  private byte[] msg2bytes( Message msg, Boolean stringTypeAndField ) throws IOException
  {
    FlexBuffer buf = new FlexBuffer();
   
    URL u = new URL( "none:" );
    if (stringTypeAndField != null)
      u.addTerm( BinaryTaggedDataOutput.STRING_TYPE_AND_FIELD, stringTypeAndField );
   
    BinaryTaggedDataOutput btdo = new BinaryTaggedDataOutput( vf, u.toString() );
    btdo.writeMessage( msg, buf );
    buf.setIndex( 0 );
    return buf.getAvailBytes();
  }
View Full Code Here
49
50
51
52
53
54
55
56
57
58
      new MainInheritanceListener() );

    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() );
    localUri = u.toString();
  }
View Full Code Here
50
51
52
53
54
55
56
   * @param uri
   * @param resources
   */
  public Tcp2Listener( String uri, Resources resources )
  {
    this( new URL( uri ), resources );
  }
View Full Code Here
37
38
39
40
41
42
43
44
{
  /** @throws Exception */
  @Test
  public void testImport() throws Exception
  {
    URL url = new URL( "scheme://user:pw@host:23/resource;s=1;t=2?p=3&q=4#frag" );
    test( url );
  }
View Full Code Here
57
58
59
60
61
62
63
64
65
66
    StructValue sv = helper.exportValue( vf, url );
//    System.out.println( "sv = "+sv );
   
    assertEquals( sv.type(), type );
   
    URL url2 = (URL) helper.importValue( sv );
//    System.out.println( "url2 = "+url2 );
   
    assertEquals( url, url2 );
  }
View Full Code Here
54
55
56
57
58
59
60
  }

 
  private Logger newLogger(String uri) throws Exception
  {
    return new Logger(transport,new URL(uri),null);
  }
View Full Code Here
54
55
56
57
58
59
60
    Log.addSink( null );
  }
 
  private KeepAlive newKeepAlive(String uri) throws Exception
  {
    return new KeepAlive(transport,new URL(uri),resources);
  }
View Full Code Here
46
47
48
49
50
51
52
    { CommandParser.class, Parameter.class, URL.class };

  @Override
  public Object convertValue( String value )
  {
    return new URL( value );
  }
View Full Code Here
TOP

Related Classes of org.apache.etch.util.URL

  • org.apache.etch.bindings.java.support.DefaultValueFactory
  • org.apache.etch.bindings.java.support.TransportFactory
  • org.apache.etch.bindings.java.transport.DefaultDeliveryService
  • org.apache.etch.bindings.java.transport.filters.TestKeepAlive
  • org.apache.etch.bindings.java.transport.filters.TestLogger
  • org.apache.etch.bindings.java.transport.filters.TestPwAuth
  • org.apache.etch.bindings.java.transport.fmt.binary.BinaryTaggedDataOutput
  • org.apache.etch.bindings.java.transport.fmt.binary.TestBinaryTaggedDataInOut
  • org.apache.etch.bindings.java.transport.Messagizer
  • org.apache.etch.bindings.java.transport.PlainMailboxManager
    • 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.