flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From terrey shih <terreys...@gmail.com>
Subject does flume send event in a multi threaded manner ?
Date Thu, 09 Oct 2014 17:38:14 GMT

Can sending an event gets blocked because something happened down at the
source of the other agent?

For example, consider the following taken from the developer guide.

public void myMethod(){

SomeDataObject data = getData()
Event event = EventBuilder.withBody(data);

    // Send the event
    try {
    } catch (EventDeliveryException e) {
      // clean up and recreate the client
      client = null;
      client = RpcClientFactory.getDefaultInstance(hostname, port);


if for some reason, the event has problem sending downstream, would it
block myMethod from returning ?

I know the catch block might catch the exception, but is it possible that
something else happens and the method just hangs and myMethod never returns
?  Or is it multithreaded and does not block ?


View raw message