Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Plain View
Avro >> mail # user >> Setting a deadline on an RPC?


+
Christophe Taton 2012-07-02, 19:21
+
Philip Zeyliger 2012-07-19, 01:19
+
Christophe Taton 2012-07-19, 18:41
+
Doug Cutting 2012-07-19, 19:23
Copy link to this message
-
Re: Setting a deadline on an RPC?
There are also constructors to NettyTransceiver that take timeout values
for connections (this happens to be from 1.6.3):

  /**
   * Creates a NettyTransceiver, and attempts to connect to the given
address.
   * {@link #DEFAULT_CONNECTION_TIMEOUT_MILLIS} is used for the connection
   * timeout.
   * @param addr the address to connect to.
   * @throws IOException if an error occurs connecting to the given address.
   */
  public NettyTransceiver(InetSocketAddress addr) throws IOException {
    this(addr, DEFAULT_CONNECTION_TIMEOUT_MILLIS);
  }

  /**
   * Creates a NettyTransceiver, and attempts to connect to the given
address.
   * @param addr the address to connect to.
   * @param connectTimeoutMillis maximum amount of time to wait for
connection
   * establishment in milliseconds, or null to use
   * {@link #DEFAULT_CONNECTION_TIMEOUT_MILLIS}.
   * @throws IOException if an error occurs connecting to the given address.
   */
  public NettyTransceiver(InetSocketAddress addr,
      Long connectTimeoutMillis) throws IOException {
    this(addr, new NioClientSocketChannelFactory(
        Executors.newCachedThreadPool(new NettyTransceiverThreadFactory(
            "Avro " + NettyTransceiver.class.getSimpleName() + " Boss")),
        Executors.newCachedThreadPool(new NettyTransceiverThreadFactory(
            "Avro " + NettyTransceiver.class.getSimpleName() + " I/O
Worker"))),
        connectTimeoutMillis);
  }

On Thu, Jul 19, 2012 at 12:23 PM, Doug Cutting <[EMAIL PROTECTED]> wrote:

> On Thu, Jul 19, 2012 at 11:41 AM, Christophe Taton <[EMAIL PROTECTED]>
> wrote:
> > Is there an equivalent with NettyTransceivers?
>
> You might use the Callback API and use a CallFuture#await()?
>
> Doug
>
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB