private String mmProvCred;
private String unit_test;
- private boolean useAAF;
+ private String authMethod;
private boolean hostnameVerify;
public MrTopicConnection(String user, String pwd ) {
mmProvCred = new String( user + ":" + pwd );
DmaapConfig p = (DmaapConfig)DmaapConfig.getConfig();
unit_test = p.getProperty( "UnitTest", "No" );
- useAAF= "true".equalsIgnoreCase(p.getProperty("UseAAF", "false"));
+ authMethod = p.getProperty("MR.authentication", "none");
hostnameVerify= "true".equalsIgnoreCase(p.getProperty("MR.hostnameVerify", "true"));
}
try {
byte[] postData = postMessage.getBytes();
logger.info( "post fields=" + postMessage );
- if ( useAAF ) {
+ if ( authMethod.equalsIgnoreCase("basicAuth") ) {
uc.setRequestProperty("Authorization", auth);
logger.info( "Authenticating with " + auth );
+ } else if ( authMethod.equalsIgnoreCase("cert")) {
+ logger.error( "MR.authentication set for client certificate. Not supported yet.");
}
uc.setRequestMethod("POST");
uc.setRequestProperty("Content-Type", "application/json");
} catch (Exception e) {
if ( unit_test.equals( "Yes" ) ) {
- response.setCode(200);
+ response.setCode(201);
response.setMessage( "simulated response");
- logger.info( "artificial 200 response from doPostMessage because unit_test =" + unit_test );
+ logger.info( "artificial 201 response from doPostMessage because unit_test =" + unit_test );
} else {
response.setCode(500);