* ============LICENSE_START==========================================
* org.onap.aai
* ===================================================================
- * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
- * Copyright © 2017 Amdocs
+ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright © 2017-2018 Amdocs
* ===================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END============================================
- * ECOMP is a trademark and service mark of AT&T Intellectual Property.
*/
package org.onap.aai.champ.event;
/** Configuration property for setting the maximum amount of time to wait for a batch of
* outgoing messages to fill up before sending the batch. */
public static final String PARAM_EVENT_STREAM_BATCH_TIMEOUT = "champ.event.stream.batch-timeout";
- public final static Integer DEFAULT_EVENT_STREAM_BATCH_TIMEOUT_MS = 500;
+ public static final Integer DEFAULT_EVENT_STREAM_BATCH_TIMEOUT_MS = 500;
- public final static String PARAM_EVENT_STREAM_PUBLISHER_POOL_SIZE = "champ.event.stream.publisher-pool-size";
+ public static final String PARAM_EVENT_STREAM_PUBLISHER_POOL_SIZE = "champ.event.stream.publisher-pool-size";
public static final Integer DEFAULT_EVENT_STREAM_PUBLISHER_POOL_SIZE = 100;
/** The event stream topic that we will publish Champ events to. */
objectToDelete = retrieveObject(key);
} catch (ChampUnmarshallingException e) {
- logger.error("Unable to generate delete object log: " + e.getMessage());
+ logger.error("Unable to generate delete object log: " + e.getMessage(),e);
}
executeDeleteObject(key);
publisherPool.execute(new EventPublisher(anEvent));
} catch (RejectedExecutionException re) {
- logger.error("Event could not be published to the event bus due to: " + re.getMessage());
+ logger.error("Event could not be published to the event bus due to: " + re.getMessage(),re);
} catch (NullPointerException npe) {
- logger.error("Can not publish null event to event bus.");
+ logger.error("Can not publish null event to event bus." + npe.getMessage(),npe);
}
}