package com.inmobi.messaging.consumer.databus;

import com.inmobi.databus.FSCheckpointProvider;

/**
 * Configuration properties and their default values for {@link DatabusConsumer}
 */
public interface DatabusConsumerConfig {

  public static final String queueSizeConfig = "databus.consumer.buffer.size";
  public static final int DEFAULT_QUEUE_SIZE = 5000;
  
  public static final String waitTimeForFlushConfig = 
  "databus.consumer.waittime.forcollectorflush";
  public static final long DEFAULT_WAIT_TIME_FOR_FLUSH = 1000; // 1 second
  
  public static final String databusConfigFileKey = "databus.conf";
  public static final String DEFAULT_DATABUS_CONFIG_FILE = "databus.xml";

  public static final String databusClustersConfig = "databus.consumer.clusters";
  
  public static final String databusChkProviderConfig = 
      "databus.consumer.chkpoint.provider.classname";
  public static final String DEFAULT_CHK_PROVIDER = FSCheckpointProvider.class
  .getName();

  public static final String checkpointDirConfig = 
  "databus.consumer.checkpoint.dir";
  public static final String DEFAULT_CHECKPOINT_DIR = ".";
  
}

@@ -1122,10 +1122,203 @@
 %22.%22;%0A  %0A
+  public static final String databusConsumerPrincipal = %0A      %22databus.consumer.principal.name%22;%0A  public static final String databusConsumerKeytab = %0A      %22databus.consumer.keytab.path%22;%0A  %0A
 %7D%0A

Fix typo in Config name