final ArrayList<HttpHost> convertedHosts = new ArrayList<>();
for ( String host : hosts )
{
- if ( host.length () == 0 ) continue;
+ if ( host.length () == 0 ){
+ continue;
+ }
+
convertedHosts.add ( hostForString ( host ) );
}
return convertedHosts;
*/
public static HttpHost hostForString ( String host )
{
- if ( host.length() < 1 ) throw new IllegalArgumentException ( "An empty host entry is invalid." );
+ if ( host.length() < 1 ){
+ throw new IllegalArgumentException ( "An empty host entry is invalid." );
+ }
String hostPart = host;
int port = kStdCambriaServicePort;
final int colon = host.indexOf ( ':' );
- if ( colon == 0 ) throw new IllegalArgumentException ( "Host entry '" + host + "' is invalid." );
+ if ( colon == 0 ){
+ throw new IllegalArgumentException ( "Host entry '" + host + "' is invalid." );
+ }
+
if ( colon > 0 )
{
hostPart = host.substring ( 0, colon ).trim();
public Set<String> jsonArrayToSet ( JSONArray a ) throws JSONException
{
- if ( a == null ) return null;
-
+ if ( a == null ){
+ return null;
+ }
+
final TreeSet<String> set = new TreeSet<>();
for ( int i=0; i<a.length (); i++ )
{
*/
public message next () throws CambriaApiException
{
- if ( fClosed ) return null;
-
+ if ( fClosed ){
+ return null;
+ }
+
try
{
final byte[] rawBytes = StreamTools.readBytes ( fStream );
try
{
final String line = fReader.readLine ();
- if ( line == null ) return null;
-
+ if ( line == null ) {
+ return null;
+ }
+
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");
- if(null==kSetting_AllowAnonymousKeys) kSetting_AllowAnonymousKeys ="false";
-
+ if(null==kSetting_AllowAnonymousKeys) {
+ kSetting_AllowAnonymousKeys ="false";
+ }
if ( kSetting_AllowAnonymousKeys.equalsIgnoreCase("true") && !emailProvided )
{
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;
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);
// 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)) {
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;
+ }
return zkServername;
}
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;
*/
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 ) );
}