You are viewing a plain text version of this content. The canonical link for it is here.
Posted to log4j-dev@logging.apache.org by "Jinder Aujla (JIRA)" <ji...@apache.org> on 2013/06/10 19:40:20 UTC

[jira] [Closed] (LOG4J2-275) The send method in FlumeAvroManager quietly loses messages on a failed rpcClient connection

     [ https://issues.apache.org/jira/browse/LOG4J2-275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jinder Aujla closed LOG4J2-275.
-------------------------------


Looks good thanks!
                
> The send method in FlumeAvroManager quietly loses messages on a failed rpcClient connection
> -------------------------------------------------------------------------------------------
>
>                 Key: LOG4J2-275
>                 URL: https://issues.apache.org/jira/browse/LOG4J2-275
>             Project: Log4j 2
>          Issue Type: Bug
>          Components: Flume Appender
>    Affects Versions: 2.0-beta6
>            Reporter: Jinder Aujla
>            Assignee: Ralph Goers
>             Fix For: 2.0-beta8
>
>
> In the FlumeAvroManager in the send method, the code looks like this:
> @Override
>     public synchronized void send(final Event event)  {
>         if (rpcClient == null) {
>             rpcClient = connect(agents, retries, connectTimeout, requestTimeout);
>         }
>         if (rpcClient != null) {
>             try {
>                 rpcClient.append(event);
>             } catch (final Exception ex) {.........
> if the rpcClient is null and the connect fails the rpcClient is still null and the method returns losing the event. I think this is a bug.
> Thanks

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

---------------------------------------------------------------------
To unsubscribe, e-mail: log4j-dev-unsubscribe@logging.apache.org
For additional commands, e-mail: log4j-dev-help@logging.apache.org