Removed some unused imports and two statements from one line
Issue-ID: DMAAP-1415
Change-Id: I2802078fc8063a65de748d2399710f97c9adee8e
Signed-off-by: Rupinder <rupinsi1@in.ibm.com>
try
{
final String line = fReader.readLine ();
try
{
final String line = fReader.readLine ();
- if ( line == null ) return null;
-
+ if ( line == null ) {
+ return null;
+ }
+
return new message ()
{
private LogDetails logDetails;
return new message ()
{
private LogDetails logDetails;
String contactEmail = nsaApiKey.getEmail();
final boolean emailProvided = contactEmail != null && contactEmail.length() > 0 && contactEmail.indexOf("@") > 1 ;
String kSetting_AllowAnonymousKeys= com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,"apiKeys.allowAnonymous");
String contactEmail = nsaApiKey.getEmail();
final boolean emailProvided = contactEmail != null && contactEmail.length() > 0 && contactEmail.indexOf("@") > 1 ;
String kSetting_AllowAnonymousKeys= com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,"apiKeys.allowAnonymous");
- if(null==kSetting_AllowAnonymousKeys) kSetting_AllowAnonymousKeys ="false";
-
+ if(null==kSetting_AllowAnonymousKeys) {
+ kSetting_AllowAnonymousKeys ="false";
+ }
if ( kSetting_AllowAnonymousKeys.equalsIgnoreCase("true") && !emailProvided )
{
if ( kSetting_AllowAnonymousKeys.equalsIgnoreCase("true") && !emailProvided )
{
import com.google.common.base.Preconditions;
import java.util.Date;
import org.apache.http.HttpStatus;
import com.google.common.base.Preconditions;
import java.util.Date;
import org.apache.http.HttpStatus;
-import org.onap.dmaap.dmf.mr.beans.DMaaPContext;
import org.onap.dmaap.dmf.mr.exception.DMaaPErrorMessages;
import org.onap.dmaap.dmf.mr.exception.DMaaPResponseCode;
import org.onap.dmaap.dmf.mr.exception.ErrorResponse;
import org.onap.dmaap.dmf.mr.exception.DMaaPErrorMessages;
import org.onap.dmaap.dmf.mr.exception.DMaaPResponseCode;
import org.onap.dmaap.dmf.mr.exception.ErrorResponse;
import org.onap.dmaap.dmf.mr.backends.memory.MemoryQueue;
import org.onap.dmaap.dmf.mr.backends.memory.MemoryQueuePublisher;
import org.onap.dmaap.dmf.mr.beans.DMaaPCambriaLimiter;
import org.onap.dmaap.dmf.mr.backends.memory.MemoryQueue;
import org.onap.dmaap.dmf.mr.backends.memory.MemoryQueuePublisher;
import org.onap.dmaap.dmf.mr.beans.DMaaPCambriaLimiter;
-import org.onap.dmaap.dmf.mr.beans.DMaaPKafkaMetaBroker;
import org.onap.dmaap.dmf.mr.beans.DMaaPZkConfigDb;
import org.onap.dmaap.dmf.mr.constants.CambriaConstants;
import org.onap.dmaap.dmf.mr.metabroker.Broker;
import org.onap.dmaap.dmf.mr.beans.DMaaPZkConfigDb;
import org.onap.dmaap.dmf.mr.constants.CambriaConstants;
import org.onap.dmaap.dmf.mr.metabroker.Broker;
long allowedtimeSkewMs=600000L;
String strallowedTimeSkewM= com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,"authentication.allowedTimeSkewMs");
long allowedtimeSkewMs=600000L;
String strallowedTimeSkewM= com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,"authentication.allowedTimeSkewMs");
- if(null!=strallowedTimeSkewM)allowedtimeSkewMs= Long.parseLong(strallowedTimeSkewM);
-
+ if(null!=strallowedTimeSkewM)
+ {
+ allowedtimeSkewMs= Long.parseLong(strallowedTimeSkewM);
+ }
//String strrequireSecureChannel= com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,"aauthentication.requireSecureChannel");
//if(strrequireSecureChannel!=null)requireSecureChannel=Boolean.parseBoolean(strrequireSecureChannel);
//String strrequireSecureChannel= com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,"aauthentication.requireSecureChannel");
//if(strrequireSecureChannel!=null)requireSecureChannel=Boolean.parseBoolean(strrequireSecureChannel);
// setup a backend
String type = com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,CambriaConstants.kBrokerType);
// setup a backend
String type = com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,CambriaConstants.kBrokerType);
- if (type==null) type = CambriaConstants.kBrokerType_Kafka;
+ if (type==null){
+ type = CambriaConstants.kBrokerType_Kafka;
+ }
if (CambriaConstants.kBrokerType_Kafka.equalsIgnoreCase(type)) {
log.info("Broker Type is:" + CambriaConstants.kBrokerType_Kafka);
} else if (CambriaConstants.kBrokerType_Memory.equalsIgnoreCase(type)) {
if (CambriaConstants.kBrokerType_Kafka.equalsIgnoreCase(type)) {
log.info("Broker Type is:" + CambriaConstants.kBrokerType_Kafka);
} else if (CambriaConstants.kBrokerType_Memory.equalsIgnoreCase(type)) {
String zkServername = com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,CambriaConstants.kSetting_ZkConfigDbServers);
String zkServername = com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,CambriaConstants.kSetting_ZkConfigDbServers);
- if (zkServername==null) zkServername=CambriaConstants.kDefault_ZkConfigDbServers;
+ if (zkServername==null){
+ zkServername=CambriaConstants.kDefault_ZkConfigDbServers;
+ }
import java.util.Properties;
import javax.servlet.http.HttpServletRequest;
import java.util.Properties;
import javax.servlet.http.HttpServletRequest;
-
-import org.onap.dmaap.dmf.mr.backends.kafka.KafkaPublisher;
import org.onap.dmaap.dmf.mr.beans.DMaaPContext;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import org.onap.dmaap.dmf.mr.beans.DMaaPContext;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
*/
public static long getSleepMsForRate ( double ratePerMinute )
{
*/
public static long getSleepMsForRate ( double ratePerMinute )
{
- if ( ratePerMinute <= 0.0 ) return 0;
+ if ( ratePerMinute <= 0.0 )
+ {
+ return 0;
+ }
return Math.max ( 1000, Math.round ( 60 * 1000 / ratePerMinute ) );
}
return Math.max ( 1000, Math.round ( 60 * 1000 / ratePerMinute ) );
}