Review Board 1.7.22


flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/LoadBalancingLog4jAppender.java
Revision 713234f New Change
[20] 120 lines
[+20] [+] public synchronized void append(LoggingEvent event) {
121
  @Override
121
  @Override
122
  public void activateOptions() throws FlumeException {
122
  public void activateOptions() throws FlumeException {
123
    try {
123
    try {
124
      final Properties properties = getProperties(hosts, selector,
124
      final Properties properties = getProperties(hosts, selector,
125
        maxBackoff, getTimeout());
125
        maxBackoff, getTimeout());

    
   
126
      parseAdditionalHeaders();
126
      rpcClient = RpcClientFactory.getInstance(properties);
127
      rpcClient = RpcClientFactory.getInstance(properties);
127
      if(layout != null) {
128
      if(layout != null) {
128
        layout.activateOptions();
129
        layout.activateOptions();
129
      }
130
      }
130
      configured = true;
131
      configured = true;
[+20] [20] 52 lines
flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAppender.java
Revision b07b189 New Change
 
flume-ng-clients/flume-ng-log4jappender/src/test/java/org/apache/flume/clients/log4jappender/TestLoadBalancingLog4jAppender.java
Revision 267ac1d New Change
 
flume-ng-clients/flume-ng-log4jappender/src/test/java/org/apache/flume/clients/log4jappender/TestLog4jAppender.java
Revision 1b840f3 New Change
 
flume-ng-clients/flume-ng-log4jappender/src/test/resources/flume-loadbalancinglog4jtest.additionalheaders.properties
New File
 
flume-ng-doc/sphinx/FlumeUserGuide.rst
Revision c614991 New Change
 
  1. flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/LoadBalancingLog4jAppender.java: Loading...
  2. flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAppender.java: Loading...
  3. flume-ng-clients/flume-ng-log4jappender/src/test/java/org/apache/flume/clients/log4jappender/TestLoadBalancingLog4jAppender.java: Loading...
  4. flume-ng-clients/flume-ng-log4jappender/src/test/java/org/apache/flume/clients/log4jappender/TestLog4jAppender.java: Loading...
  5. flume-ng-clients/flume-ng-log4jappender/src/test/resources/flume-loadbalancinglog4jtest.additionalheaders.properties: Loading...
  6. flume-ng-doc/sphinx/FlumeUserGuide.rst: Loading...