Also deleted the checkstyle suppression file.
Change-Id: I51c69bce644204435fa8131c14132e0384b4e886
Issue-ID: POLICY-1909
Signed-off-by: Jim Hahn <jrh3@att.com>
import org.onap.policy.drools.properties.DroolsProperties;
import org.onap.policy.drools.utils.PropertyUtil;
import org.onap.policy.drools.utils.logging.LoggerUtil;
-import org.onap.policy.drools.utils.logging.MDCTransaction;
+import org.onap.policy.drools.utils.logging.MdcTransaction;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/* 3. Start the Engine with the basic services only (no Policy Controllers) */
- MDCTransaction trans =
- MDCTransaction.newTransaction(null, null)
+ MdcTransaction trans =
+ MdcTransaction.newTransaction(null, null)
.setServiceName(Main.class.getSimpleName())
.setTargetEntity("engine")
.setTargetServiceName("start");
controllerProperties.getProperty(DroolsProperties.PROPERTY_CONTROLLER_NAME);
try {
trans =
- MDCTransaction.newTransaction(null, null)
+ MdcTransaction.newTransaction(null, null)
.setServiceName(Main.class.getSimpleName())
.setTargetEntity("controller:" + controllerName)
.setTargetServiceName("start");
import org.onap.policy.drools.server.restful.aaf.AafTelemetryAuthFilter;
import org.onap.policy.drools.utils.PropertyUtil;
import org.onap.policy.drools.utils.logging.LoggerUtil;
-import org.onap.policy.drools.utils.logging.MDCTransaction;
+import org.onap.policy.drools.utils.logging.MdcTransaction;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
final String entity = config.getEntity();
- MDCTransaction mdcTrans = MDCTransaction.newTransaction(config.getRequestId(), "brmsgw");
+ MdcTransaction mdcTrans = MdcTransaction.newTransaction(config.getRequestId(), "brmsgw");
if (this.getSources().size() == 1) {
Topic topic = this.getSources().get(0);
mdcTrans.setServiceName(topic.getTopic()).setRemoteHost(topic.getServers().toString())
}
for (final ControllerConfiguration configController : configControllers) {
- MDCTransaction mdcTrans = MDCTransaction.newSubTransaction(null).setTargetEntity(configController.getName())
+ MdcTransaction mdcTrans = MdcTransaction.newSubTransaction(null).setTargetEntity(configController.getName())
.setTargetServiceName(configController.getOperation())
.setTargetVirtualEntity("" + configController.getDrools());
try {
+++ /dev/null
-<?xml version="1.0"?>
-<!--
- ============LICENSE_START=======================================================
- Copyright (C) 2018 AT&T Technologies. All rights reserved.
- ================================================================================
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
- SPDX-License-Identifier: Apache-2.0
- ============LICENSE_END=========================================================
--->
-
-<!DOCTYPE suppressions PUBLIC
- "-//Puppy Crawl//DTD Suppressions 1.0//EN"
- "http://www.puppycrawl.com/dtds/suppressions_1_0.dtd">
-
-<suppressions>
- <suppress checks="AbbreviationAsWordInName"
- files="MDCTransaction.java"
- lines="1-9999"/>
- <suppress checks="OneTopLevelClass"
- files="MDCTransaction.java"
- lines="1-9999"/>
-</suppressions>
<includeTestResources>true</includeTestResources>
<excludes>
</excludes>
- <suppressionsLocation>${project.baseUri}checkstyle-suppressions.xml</suppressionsLocation>
<consoleOutput>true</consoleOutput>
<failsOnViolation>true</failsOnViolation>
<violationSeverity>warning</violationSeverity>
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * policy-utils
+ * ================================================================================
+ * Copyright (C) 2018-2019 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.policy.drools.utils.logging;
+
+import java.time.Instant;
+import org.onap.policy.common.utils.network.NetworkUtil;
+
+/**
+ * MDC Transaction Utility Class.
+ *
+ * <p>There is an implicit 2-level tree of Transactions in ONAP: transactions and subtransactions.
+ *
+ * <p>1. The top level transaction relates to the overarching transaction id (ie. RequestId) and should
+ * be made available to subtransactions for reuse in the ThreadLocal MDC structure.
+ *
+ * <p>This is the data to be inherited and common to all subtransactions (not a common case but could
+ * be modified by subtransactions):
+ *
+ * <p>Request ID Virtual Server Name Partner Name Server Server IP Address Server FQDN
+ *
+ * <p>2. The second level at the leaves is formed by subtransactions and the key identifier is the
+ * invocation id.
+ *
+ * <p>Begin Timestamp End Timestamp Elapsed Time Service Instance ID Service Name Status Code Response
+ * Code Response Description Instance UUID Severity Target Entity Target Service Name Server Server
+ * IP Address Server FQDN Client IP Address Process Key Remote Host Alert Severity Target Virtual
+ * Entity
+ *
+ *
+ * <p>The naming convention for the fields must match the naming given at
+ *
+ * <p>https://wiki.onap.org/pages/viewpage.action?pageId=20087036
+ */
+public interface MdcTransaction {
+ /*
+ * The fields must match the naming given at
+ * https://wiki.onap.org/pages/viewpage.action?pageId=20087036
+ */
+
+ /**
+ * End to end transaction ID. Subtransactions will inherit this value from the transaction.
+ */
+ String REQUEST_ID = "RequestID";
+
+ /**
+ * Invocation ID, ie. SubTransaction ID.
+ */
+ String INVOCATION_ID = "InvocationID";
+
+ /**
+ * Service Name. Both transactions and subtransactions will have its own copy.
+ */
+ String SERVICE_NAME = "ServiceName";
+
+ /**
+ * Partner Name Subtransactions will inherit this value from the transaction.
+ */
+ String PARTNER_NAME = "PartnerName";
+
+ /**
+ * Start Timestamp. Both transactions and subtransactions will have its own copy.
+ */
+ String BEGIN_TIMESTAMP = "BeginTimestamp";
+
+ /**
+ * End Timestamp. Both transactions and subtransactions will have its own copy.
+ */
+ String END_TIMESTAMP = "EndTimestamp";
+
+ /**
+ * Elapsed Time. Both transactions and subtransactions will have its own copy.
+ */
+ String ELAPSED_TIME = "ElapsedTime";
+
+ /**
+ * Elapsed Time. Both transactions and subtransactions will have its own copy.
+ */
+ String SERVICE_INSTANCE_ID = "ServiceInstanceID";
+
+ /**
+ * Virtual Server Name. Subtransactions will inherit this value from the transaction.
+ */
+ String VIRTUAL_SERVER_NAME = "VirtualServerName";
+
+ /**
+ * Status Code Both transactions and subtransactions will have its own copy.
+ */
+ String STATUS_CODE = "StatusCode";
+
+ /**
+ * Response Code Both transactions and subtransactions will have its own copy.
+ */
+ String RESPONSE_CODE = "ResponseCode";
+
+ /**
+ * Response Description Both transactions and subtransactions will have its own copy.
+ */
+ String RESPONSE_DESCRIPTION = "ResponseDescription";
+
+ /**
+ * Instance UUID Both transactions and subtransactions will have its own copy.
+ */
+ String INSTANCE_UUID = "InstanceUUID";
+
+ /**
+ * Severity Both transactions and subtransactions will have its own copy.
+ */
+ String SEVERITY = "Severity";
+
+ /**
+ * Target Entity Both transactions and subtransactions will have its own copy.
+ */
+ String TARGET_ENTITY = "TargetEntity";
+
+ /**
+ * Target Service Name Both transactions and subtransactions will have its own copy.
+ */
+ String TARGET_SERVICE_NAME = "TargetServiceName";
+
+ /**
+ * Server Subtransactions inherit this value. if (this.getSources().size() == 1)
+ * this.getSources().get(0).getTopic();
+ */
+ String SERVER = "Server";
+
+ /**
+ * Server IP Address Subtransactions inherit this value.
+ */
+ String SERVER_IP_ADDRESS = "ServerIpAddress";
+
+ /**
+ * Server FQDN Subtransactions inherit this value.
+ */
+ String SERVER_FQDN = "ServerFQDN";
+
+ /**
+ * Client IP Address Both transactions and subtransactions will have its own copy.
+ */
+ String CLIENT_IP_ADDRESS = "ClientIPAddress";
+
+ /**
+ * Process Key Both transactions and subtransactions will have its own copy.
+ */
+ String PROCESS_KEY = "ProcessKey";
+
+ /**
+ * Remote Host Both transactions and subtransactions will have its own copy.
+ */
+ String REMOTE_HOST = "RemoteHost";
+
+ /**
+ * Alert Severity Both transactions and subtransactions will have its own copy.
+ */
+ String ALERT_SEVERITY = "AlertSeverity";
+
+ /**
+ * Target Virtual Entity Both transactions and subtransactions will have its own copy.
+ */
+ String TARGET_VIRTUAL_ENTITY = "TargetVirtualEntity";
+
+ /**
+ * Default Service Name.
+ */
+ String DEFAULT_SERVICE_NAME = "PDP-D";
+
+ /**
+ * Default Host Name.
+ */
+ String DEFAULT_HOSTNAME = NetworkUtil.getHostname();
+
+ /**
+ * Default Host IP.
+ */
+ String DEFAULT_HOSTIP = NetworkUtil.getHostIp();
+
+ /**
+ * Status Code Complete.
+ */
+ String STATUS_CODE_COMPLETE = "COMPLETE";
+
+ /**
+ * Status Code Error.
+ */
+ String STATUS_CODE_FAILURE = "ERROR";
+
+ /**
+ * reset subtransaction data.
+ */
+ MdcTransaction resetSubTransaction();
+
+ /**
+ * resets transaction data.
+ */
+ MdcTransaction resetTransaction();
+
+ /**
+ * flush to MDC structure.
+ */
+ MdcTransaction flush();
+
+ /**
+ * convenience method to log a metric. Alternatively caller could call flush() and the logging
+ * statement directly for further granularity.
+ */
+ MdcTransaction metric();
+
+ /**
+ * convenience method to log a transaction record. Alternatively caller could call flush() and
+ * the logging statement directly for further granularity.
+ */
+ MdcTransaction transaction();
+
+ /**
+ * get invocation id.
+ */
+ MdcTransaction setInvocationId(String invocationId);
+
+ /**
+ * set start time.
+ */
+ MdcTransaction setStartTime(Instant startTime);
+
+ /**
+ * set service name.
+ */
+ MdcTransaction setServiceName(String serviceName);
+
+ /**
+ * set status code.
+ */
+ MdcTransaction setStatusCode(String statusCode);
+
+ /**
+ * set status code.
+ */
+ MdcTransaction setStatusCode(boolean success);
+
+ /**
+ * sets response code.
+ */
+ MdcTransaction setResponseCode(String responseCode);
+
+ /**
+ * sets response description.
+ */
+ MdcTransaction setResponseDescription(String responseDescription);
+
+ /**
+ * sets instance uuid.
+ */
+ MdcTransaction setInstanceUuid(String instanceUuid);
+
+ /**
+ * set severity.
+ */
+ MdcTransaction setSeverity(String severity);
+
+ /**
+ * set target entity.
+ */
+ MdcTransaction setTargetEntity(String targetEntity);
+
+ /**
+ * set target service name.
+ */
+ MdcTransaction setTargetServiceName(String targetServiceName);
+
+ /**
+ * set target virtual entity.
+ */
+ MdcTransaction setTargetVirtualEntity(String targetVirtualEntity);
+
+ /**
+ * set request id.
+ */
+ MdcTransaction setRequestId(String requestId);
+
+ /**
+ * set partner.
+ */
+ MdcTransaction setPartner(String partner);
+
+ /**
+ * set server.
+ */
+ MdcTransaction setServer(String server);
+
+ /**
+ * set server ip address.
+ */
+ MdcTransaction setServerIpAddress(String serverIpAddress);
+
+ /**
+ * set server fqdn.
+ */
+ MdcTransaction setServerFqdn(String serverFqdn);
+
+ /**
+ * set virtual server.
+ */
+ MdcTransaction setVirtualServerName(String virtualServerName);
+
+ /**
+ * sets end time.
+ */
+ MdcTransaction setEndTime(Instant endTime);
+
+ /**
+ * sets elapsed time.
+ */
+ MdcTransaction setElapsedTime(Long elapsedTime);
+
+ /**
+ * sets service instance id.
+ */
+ MdcTransaction setServiceInstanceId(String serviceInstanceId);
+
+ /**
+ * sets process key.
+ */
+ MdcTransaction setProcessKey(String processKey);
+
+ /**
+ * sets alert severity.
+ */
+ MdcTransaction setAlertSeverity(String alertSeverity);
+
+ /**
+ * sets client ip address.
+ */
+ MdcTransaction setClientIpAddress(String clientIpAddress);
+
+ /**
+ * sets remote host.
+ */
+ MdcTransaction setRemoteHost(String remoteHost);
+
+ /**
+ * get start time.
+ */
+ Instant getStartTime();
+
+ /**
+ * get server.
+ */
+ String getServer();
+
+ /**
+ * get end time.
+ */
+ Instant getEndTime();
+
+ /**
+ * get elapsed time.
+ */
+ Long getElapsedTime();
+
+ /**
+ * get remote host.
+ */
+ String getRemoteHost();
+
+ /**
+ * get client ip address.
+ */
+ String getClientIpAddress();
+
+ /**
+ * get alert severity.
+ */
+ String getAlertSeverity();
+
+ /**
+ * get process key.
+ */
+ String getProcessKey();
+
+ /**
+ * get service instance id.
+ */
+ String getServiceInstanceId();
+
+ /**
+ * get invocation id.
+ */
+ String getInvocationId();
+
+ /**
+ * get service name.
+ */
+ String getServiceName();
+
+ /**
+ * get status code.
+ */
+ String getStatusCode();
+
+ /**
+ * get response description.
+ */
+ String getResponseDescription();
+
+ /**
+ * get instance uuid.
+ */
+ String getInstanceUuid();
+
+ /**
+ * get severity.
+ */
+ String getSeverity();
+
+ /**
+ * get target entity.
+ */
+ String getTargetEntity();
+
+ /**
+ * get service name.
+ */
+ String getTargetServiceName();
+
+ /**
+ * get target virtual entity.
+ */
+ String getTargetVirtualEntity();
+
+ /**
+ * get response code.
+ */
+ String getResponseCode();
+
+ /**
+ * get request id.
+ */
+ String getRequestId();
+
+ /**
+ * get partner.
+ */
+ String getPartner();
+
+ /**
+ * get server fqdn.
+ */
+ String getServerFqdn();
+
+ /**
+ * get virtual server name.
+ */
+ String getVirtualServerName();
+
+ /**
+ * get server ip.
+ */
+ String getServerIpAddress();
+
+ /**
+ * generate timestamp used for logging.
+ */
+ String timestamp(Instant time);
+
+ /**
+ * create new MDC Transaction.
+ *
+ * @param requestId transaction Id
+ * @param partner requesting partner
+ *
+ * @return MDC Transaction
+ */
+ static MdcTransaction newTransaction(String requestId, String partner) {
+ return new MdcTransactionImpl(requestId, partner);
+ }
+
+ /**
+ * create new MDC Transaction.
+ */
+ static MdcTransaction newTransaction() {
+ return new MdcTransactionImpl();
+ }
+
+ /**
+ * create new subtransaction.
+ *
+ * @param invocationId sub-transaction od
+ * @return MDC Transaction
+ */
+ static MdcTransaction newSubTransaction(String invocationId) {
+ return new MdcTransactionImpl(invocationId);
+ }
+
+ /**
+ * create transaction from an existing one.
+ *
+ * @param transaction transaction
+ * @return MDC Transaction
+ */
+ static MdcTransaction fromTransaction(MdcTransaction transaction) {
+ return new MdcTransactionImpl(transaction);
+ }
+
+}
-/*-
+/*
* ============LICENSE_START=======================================================
- * policy-utils
+ * ONAP
* ================================================================================
- * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
+ * ============LICENSE_END=========================================================
*/
package org.onap.policy.drools.utils.logging;
import java.time.Instant;
import java.util.Date;
import java.util.UUID;
-
-import org.onap.policy.common.utils.network.NetworkUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.slf4j.MDC;
-/**
- * MDC Transaction Utility Class.
- *
- * <p>There is an implicit 2-level tree of Transactions in ONAP: transactions and subtransactions.
- *
- * <p>1. The top level transaction relates to the overarching transaction id (ie. RequestId) and should
- * be made available to subtransactions for reuse in the ThreadLocal MDC structure.
- *
- * <p>This is the data to be inherited and common to all subtransactions (not a common case but could
- * be modified by subtransactions):
- *
- * <p>Request ID Virtual Server Name Partner Name Server Server IP Address Server FQDN
- *
- * <p>2. The second level at the leaves is formed by subtransactions and the key identifier is the
- * invocation id.
- *
- * <p>Begin Timestamp End Timestamp Elapsed Time Service Instance ID Service Name Status Code Response
- * Code Response Description Instance UUID Severity Target Entity Target Service Name Server Server
- * IP Address Server FQDN Client IP Address Process Key Remote Host Alert Severity Target Virtual
- * Entity
- *
- *
- * <p>The naming convention for the fields must match the naming given at
- *
- * <p>https://wiki.onap.org/pages/viewpage.action?pageId=20087036
- */
-public interface MDCTransaction {
- /*
- * The fields must match the naming given at
- * https://wiki.onap.org/pages/viewpage.action?pageId=20087036
- */
-
- /**
- * End to end transaction ID. Subtransactions will inherit this value from the transaction.
- */
- String REQUEST_ID = "RequestID";
-
- /**
- * Invocation ID, ie. SubTransaction ID.
- */
- String INVOCATION_ID = "InvocationID";
-
- /**
- * Service Name. Both transactions and subtransactions will have its own copy.
- */
- String SERVICE_NAME = "ServiceName";
-
- /**
- * Partner Name Subtransactions will inherit this value from the transaction.
- */
- String PARTNER_NAME = "PartnerName";
-
- /**
- * Start Timestamp. Both transactions and subtransactions will have its own copy.
- */
- String BEGIN_TIMESTAMP = "BeginTimestamp";
-
- /**
- * End Timestamp. Both transactions and subtransactions will have its own copy.
- */
- String END_TIMESTAMP = "EndTimestamp";
-
- /**
- * Elapsed Time. Both transactions and subtransactions will have its own copy.
- */
- String ELAPSED_TIME = "ElapsedTime";
-
- /**
- * Elapsed Time. Both transactions and subtransactions will have its own copy.
- */
- String SERVICE_INSTANCE_ID = "ServiceInstanceID";
-
- /**
- * Virtual Server Name. Subtransactions will inherit this value from the transaction.
- */
- String VIRTUAL_SERVER_NAME = "VirtualServerName";
-
- /**
- * Status Code Both transactions and subtransactions will have its own copy.
- */
- String STATUS_CODE = "StatusCode";
-
- /**
- * Response Code Both transactions and subtransactions will have its own copy.
- */
- String RESPONSE_CODE = "ResponseCode";
-
- /**
- * Response Description Both transactions and subtransactions will have its own copy.
- */
- String RESPONSE_DESCRIPTION = "ResponseDescription";
-
- /**
- * Instance UUID Both transactions and subtransactions will have its own copy.
- */
- String INSTANCE_UUID = "InstanceUUID";
-
- /**
- * Severity Both transactions and subtransactions will have its own copy.
- */
- String SEVERITY = "Severity";
-
- /**
- * Target Entity Both transactions and subtransactions will have its own copy.
- */
- String TARGET_ENTITY = "TargetEntity";
-
- /**
- * Target Service Name Both transactions and subtransactions will have its own copy.
- */
- String TARGET_SERVICE_NAME = "TargetServiceName";
-
- /**
- * Server Subtransactions inherit this value. if (this.getSources().size() == 1)
- * this.getSources().get(0).getTopic();
- */
- String SERVER = "Server";
-
- /**
- * Server IP Address Subtransactions inherit this value.
- */
- String SERVER_IP_ADDRESS = "ServerIpAddress";
-
- /**
- * Server FQDN Subtransactions inherit this value.
- */
- String SERVER_FQDN = "ServerFQDN";
-
- /**
- * Client IP Address Both transactions and subtransactions will have its own copy.
- */
- String CLIENT_IP_ADDRESS = "ClientIPAddress";
-
- /**
- * Process Key Both transactions and subtransactions will have its own copy.
- */
- String PROCESS_KEY = "ProcessKey";
-
- /**
- * Remote Host Both transactions and subtransactions will have its own copy.
- */
- String REMOTE_HOST = "RemoteHost";
-
- /**
- * Alert Severity Both transactions and subtransactions will have its own copy.
- */
- String ALERT_SEVERITY = "AlertSeverity";
-
- /**
- * Target Virtual Entity Both transactions and subtransactions will have its own copy.
- */
- String TARGET_VIRTUAL_ENTITY = "TargetVirtualEntity";
-
- /**
- * Default Service Name.
- */
- String DEFAULT_SERVICE_NAME = "PDP-D";
-
- /**
- * Default Host Name.
- */
- String DEFAULT_HOSTNAME = NetworkUtil.getHostname();
-
- /**
- * Default Host IP.
- */
- String DEFAULT_HOSTIP = NetworkUtil.getHostIp();
-
- /**
- * Status Code Complete.
- */
- String STATUS_CODE_COMPLETE = "COMPLETE";
-
- /**
- * Status Code Error.
- */
- String STATUS_CODE_FAILURE = "ERROR";
-
- /**
- * reset subtransaction data.
- */
- MDCTransaction resetSubTransaction();
-
- /**
- * resets transaction data.
- */
- MDCTransaction resetTransaction();
-
- /**
- * flush to MDC structure.
- */
- MDCTransaction flush();
-
- /**
- * convenience method to log a metric. Alternatively caller could call flush() and the logging
- * statement directly for further granularity.
- */
- MDCTransaction metric();
-
- /**
- * convenience method to log a transaction record. Alternatively caller could call flush() and
- * the logging statement directly for further granularity.
- */
- MDCTransaction transaction();
-
- /**
- * get invocation id.
- */
- MDCTransaction setInvocationId(String invocationId);
-
- /**
- * set start time.
- */
- MDCTransaction setStartTime(Instant startTime);
-
- /**
- * set service name.
- */
- MDCTransaction setServiceName(String serviceName);
-
- /**
- * set status code.
- */
- MDCTransaction setStatusCode(String statusCode);
-
- /**
- * set status code.
- */
- MDCTransaction setStatusCode(boolean success);
-
- /**
- * sets response code.
- */
- MDCTransaction setResponseCode(String responseCode);
-
- /**
- * sets response description.
- */
- MDCTransaction setResponseDescription(String responseDescription);
-
- /**
- * sets instance uuid.
- */
- MDCTransaction setInstanceUUID(String instanceUUID);
-
- /**
- * set severity.
- */
- MDCTransaction setSeverity(String severity);
-
- /**
- * set target entity.
- */
- MDCTransaction setTargetEntity(String targetEntity);
-
- /**
- * set target service name.
- */
- MDCTransaction setTargetServiceName(String targetServiceName);
-
- /**
- * set target virtual entity.
- */
- MDCTransaction setTargetVirtualEntity(String targetVirtualEntity);
-
- /**
- * set request id.
- */
- MDCTransaction setRequestId(String requestId);
-
- /**
- * set partner.
- */
- MDCTransaction setPartner(String partner);
-
- /**
- * set server.
- */
- MDCTransaction setServer(String server);
-
- /**
- * set server ip address.
- */
- MDCTransaction setServerIpAddress(String serverIpAddress);
-
- /**
- * set server fqdn.
- */
- MDCTransaction setServerFqdn(String serverFqdn);
-
- /**
- * set virtual server.
- */
- MDCTransaction setVirtualServerName(String virtualServerName);
-
- /**
- * sets end time.
- */
- MDCTransaction setEndTime(Instant endTime);
-
- /**
- * sets elapsed time.
- */
- MDCTransaction setElapsedTime(Long elapsedTime);
-
- /**
- * sets service instance id.
- */
- MDCTransaction setServiceInstanceId(String serviceInstanceId);
-
- /**
- * sets process key.
- */
- MDCTransaction setProcessKey(String processKey);
-
- /**
- * sets alert severity.
- */
- MDCTransaction setAlertSeverity(String alertSeverity);
-
- /**
- * sets client ip address.
- */
- MDCTransaction setClientIpAddress(String clientIpAddress);
-
- /**
- * sets remote host.
- */
- MDCTransaction setRemoteHost(String remoteHost);
-
- /**
- * get start time.
- */
- Instant getStartTime();
-
- /**
- * get server.
- */
- String getServer();
-
- /**
- * get end time.
- */
- Instant getEndTime();
-
- /**
- * get elapsed time.
- */
- Long getElapsedTime();
-
- /**
- * get remote host.
- */
- String getRemoteHost();
-
- /**
- * get client ip address.
- */
- String getClientIpAddress();
-
- /**
- * get alert severity.
- */
- String getAlertSeverity();
-
- /**
- * get process key.
- */
- String getProcessKey();
-
- /**
- * get service instance id.
- */
- String getServiceInstanceId();
-
- /**
- * get invocation id.
- */
- String getInvocationId();
-
- /**
- * get service name.
- */
- String getServiceName();
-
- /**
- * get status code.
- */
- String getStatusCode();
-
- /**
- * get response description.
- */
- String getResponseDescription();
-
- /**
- * get instance uuid.
- */
- String getInstanceUUID();
-
- /**
- * get severity.
- */
- String getSeverity();
-
- /**
- * get target entity.
- */
- String getTargetEntity();
-
- /**
- * get service name.
- */
- String getTargetServiceName();
-
- /**
- * get target virtual entity.
- */
- String getTargetVirtualEntity();
-
- /**
- * get response code.
- */
- String getResponseCode();
-
- /**
- * get request id.
- */
- String getRequestId();
-
- /**
- * get partner.
- */
- String getPartner();
-
- /**
- * get server fqdn.
- */
- String getServerFqdn();
-
- /**
- * get virtual server name.
- */
- String getVirtualServerName();
-
- /**
- * get server ip.
- */
- String getServerIpAddress();
-
- /**
- * generate timestamp used for logging.
- */
- String timestamp(Instant time);
-
- /**
- * create new MDC Transaction.
- *
- * @param requestId transaction Id
- * @param partner requesting partner
- *
- * @return MDC Transaction
- */
- static MDCTransaction newTransaction(String requestId, String partner) {
- return new MDCTransactionImpl(requestId, partner);
- }
-
- /**
- * create new MDC Transaction.
- */
- static MDCTransaction newTransaction() {
- return new MDCTransactionImpl();
- }
-
- /**
- * create new subtransaction.
- *
- * @param invocationId sub-transaction od
- * @return MDC Transaction
- */
- static MDCTransaction newSubTransaction(String invocationId) {
- return new MDCTransactionImpl(invocationId);
- }
-
- /**
- * create transaction from an existing one.
- *
- * @param transaction transaction
- * @return MDC Transaction
- */
- static MDCTransaction fromTransaction(MDCTransaction transaction) {
- return new MDCTransactionImpl(transaction);
- }
-
-}
-
-
-class MDCTransactionImpl implements MDCTransaction {
+class MdcTransactionImpl implements MdcTransaction {
- private static final Logger logger = LoggerFactory.getLogger(MDCTransactionImpl.class.getName());
+ private static final Logger logger = LoggerFactory.getLogger(MdcTransactionImpl.class.getName());
/**
* Logging Format for Timestamps.
private Long elapsedTime;
private String serviceInstanceId;
- private String instanceUUID;
+ private String instanceUuid;
private String processKey;
private String statusCode;
/**
* Transaction with no information set.
*/
- public MDCTransactionImpl() {
+ public MdcTransactionImpl() {
MDC.clear();
}
* @param requestId transaction id
* @param partner transaction origin
*/
- public MDCTransactionImpl(String requestId, String partner) {
+ public MdcTransactionImpl(String requestId, String partner) {
MDC.clear();
this.setRequestId(requestId);
*
* @param invocationId subtransaction id
*/
- public MDCTransactionImpl(String invocationId) {
+ public MdcTransactionImpl(String invocationId) {
this.resetSubTransaction();
this.setRequestId(MDC.get(REQUEST_ID));
*
* @param transaction transaction
*/
- public MDCTransactionImpl(MDCTransaction transaction) {
+ public MdcTransactionImpl(MdcTransaction transaction) {
MDC.clear();
this.setAlertSeverity(transaction.getAlertSeverity());
this.setClientIpAddress(transaction.getClientIpAddress());
this.setElapsedTime(transaction.getElapsedTime());
this.setEndTime(transaction.getEndTime());
- this.setInstanceUUID(transaction.getInstanceUUID());
+ this.setInstanceUuid(transaction.getInstanceUuid());
this.setInvocationId(transaction.getInvocationId());
this.setPartner(transaction.getPartner());
this.setProcessKey(transaction.getProcessKey());
* @return MDCTransaction
*/
@Override
- public MDCTransaction resetSubTransaction() {
+ public MdcTransaction resetSubTransaction() {
MDC.remove(INVOCATION_ID);
MDC.remove(BEGIN_TIMESTAMP);
MDC.remove(END_TIMESTAMP);
}
@Override
- public MDCTransaction resetTransaction() {
+ public MdcTransaction resetTransaction() {
MDC.clear();
return this;
}
* flush transaction to MDC.
*/
@Override
- public MDCTransaction flush() {
+ public MdcTransaction flush() {
if (this.requestId != null && !this.requestId.isEmpty()) {
MDC.put(REQUEST_ID, this.requestId);
}
MDC.put(SERVICE_INSTANCE_ID, this.serviceInstanceId);
}
- if (this.instanceUUID != null) {
- MDC.put(INSTANCE_UUID, this.instanceUUID);
+ if (this.instanceUuid != null) {
+ MDC.put(INSTANCE_UUID, this.instanceUuid);
}
if (this.processKey != null) {
}
@Override
- public MDCTransaction metric() {
+ public MdcTransaction metric() {
this.flush();
logger.info(LoggerUtil.METRIC_LOG_MARKER, "");
return this;
}
@Override
- public MDCTransaction transaction() {
+ public MdcTransaction transaction() {
this.flush();
logger.info(LoggerUtil.TRANSACTION_LOG_MARKER, "");
return this;
}
@Override
- public MDCTransaction setEndTime(Instant endTime) {
+ public MdcTransaction setEndTime(Instant endTime) {
if (endTime == null) {
this.endTime = Instant.now();
} else {
}
@Override
- public MDCTransaction setElapsedTime(Long elapsedTime) {
+ public MdcTransaction setElapsedTime(Long elapsedTime) {
this.elapsedTime = elapsedTime;
return this;
}
@Override
- public MDCTransaction setServiceInstanceId(String serviceInstanceId) {
+ public MdcTransaction setServiceInstanceId(String serviceInstanceId) {
this.serviceInstanceId = serviceInstanceId;
return this;
}
@Override
- public MDCTransaction setProcessKey(String processKey) {
+ public MdcTransaction setProcessKey(String processKey) {
this.processKey = processKey;
return this;
}
@Override
- public MDCTransaction setAlertSeverity(String alertSeverity) {
+ public MdcTransaction setAlertSeverity(String alertSeverity) {
this.alertSeverity = alertSeverity;
return this;
}
@Override
- public MDCTransaction setClientIpAddress(String clientIpAddress) {
+ public MdcTransaction setClientIpAddress(String clientIpAddress) {
this.clientIpAddress = clientIpAddress;
return this;
}
@Override
- public MDCTransaction setRemoteHost(String remoteHost) {
+ public MdcTransaction setRemoteHost(String remoteHost) {
this.remoteHost = remoteHost;
return this;
}
/* transaction and subtransaction fields */
@Override
- public MDCTransaction setInvocationId(String invocationId) {
+ public MdcTransaction setInvocationId(String invocationId) {
if (invocationId == null) {
this.invocationId = UUID.randomUUID().toString();
} else {
}
@Override
- public MDCTransaction setStartTime(Instant startTime) {
+ public MdcTransaction setStartTime(Instant startTime) {
if (startTime == null) {
this.startTime = Instant.now();
} else {
}
@Override
- public MDCTransaction setServiceName(String serviceName) {
+ public MdcTransaction setServiceName(String serviceName) {
if (serviceName == null || serviceName.isEmpty()) {
this.serviceName = DEFAULT_SERVICE_NAME;
} else {
}
@Override
- public MDCTransaction setStatusCode(String statusCode) {
+ public MdcTransaction setStatusCode(String statusCode) {
this.statusCode = statusCode;
return this;
}
@Override
- public MDCTransaction setStatusCode(boolean success) {
+ public MdcTransaction setStatusCode(boolean success) {
if (success) {
this.statusCode = STATUS_CODE_COMPLETE;
} else {
}
@Override
- public MDCTransaction setResponseCode(String responseCode) {
+ public MdcTransaction setResponseCode(String responseCode) {
this.responseCode = responseCode;
return this;
}
@Override
- public MDCTransaction setResponseDescription(String responseDescription) {
+ public MdcTransaction setResponseDescription(String responseDescription) {
this.responseDescription = responseDescription;
return this;
}
@Override
- public MDCTransaction setInstanceUUID(String instanceUuid) {
+ public MdcTransaction setInstanceUuid(String instanceUuid) {
if (instanceUuid == null) {
- this.instanceUUID = UUID.randomUUID().toString();
+ this.instanceUuid = UUID.randomUUID().toString();
} else {
- this.instanceUUID = instanceUuid;
+ this.instanceUuid = instanceUuid;
}
- MDC.put(INSTANCE_UUID, this.instanceUUID);
+ MDC.put(INSTANCE_UUID, this.instanceUuid);
return this;
}
@Override
- public MDCTransaction setSeverity(String severity) {
+ public MdcTransaction setSeverity(String severity) {
this.severity = severity;
return this;
}
@Override
- public MDCTransaction setTargetEntity(String targetEntity) {
+ public MdcTransaction setTargetEntity(String targetEntity) {
this.targetEntity = targetEntity;
return this;
}
@Override
- public MDCTransaction setTargetServiceName(String targetServiceName) {
+ public MdcTransaction setTargetServiceName(String targetServiceName) {
this.targetServiceName = targetServiceName;
return this;
}
@Override
- public MDCTransaction setTargetVirtualEntity(String targetVirtualEntity) {
+ public MdcTransaction setTargetVirtualEntity(String targetVirtualEntity) {
this.targetVirtualEntity = targetVirtualEntity;
return this;
}
}
@Override
- public String getInstanceUUID() {
- return instanceUUID;
+ public String getInstanceUuid() {
+ return instanceUuid;
}
@Override
/* inheritable fields by subtransactions via MDC */
@Override
- public MDCTransaction setRequestId(String requestId) {
+ public MdcTransaction setRequestId(String requestId) {
if (requestId == null || requestId.isEmpty()) {
this.requestId = UUID.randomUUID().toString();
} else {
}
@Override
- public MDCTransaction setPartner(String partner) {
+ public MdcTransaction setPartner(String partner) {
if (partner == null || partner.isEmpty()) {
this.partner = DEFAULT_SERVICE_NAME;
} else {
}
@Override
- public MDCTransaction setServer(String server) {
+ public MdcTransaction setServer(String server) {
if (server == null || server.isEmpty()) {
this.server = DEFAULT_HOSTNAME;
} else {
}
@Override
- public MDCTransaction setServerIpAddress(String serverIpAddress) {
+ public MdcTransaction setServerIpAddress(String serverIpAddress) {
if (serverIpAddress == null || serverIpAddress.isEmpty()) {
this.serverIpAddress = DEFAULT_HOSTIP;
} else {
}
@Override
- public MDCTransaction setServerFqdn(String serverFqdn) {
+ public MdcTransaction setServerFqdn(String serverFqdn) {
if (serverFqdn == null || serverFqdn.isEmpty()) {
this.serverFqdn = DEFAULT_HOSTNAME;
} else {
}
@Override
- public MDCTransaction setVirtualServerName(String virtualServerName) {
+ public MdcTransaction setVirtualServerName(String virtualServerName) {
if (virtualServerName == null || virtualServerName.isEmpty()) {
this.virtualServerName = DEFAULT_HOSTNAME;
} else {
sb.append(", endTime=").append(endTime);
sb.append(", elapsedTime=").append(elapsedTime);
sb.append(", serviceInstanceId='").append(serviceInstanceId).append('\'');
- sb.append(", instanceUUID='").append(instanceUUID).append('\'');
+ sb.append(", instanceUUID='").append(instanceUuid).append('\'');
sb.append(", processKey='").append(processKey).append('\'');
sb.append(", statusCode='").append(statusCode).append('\'');
sb.append(", responseCode='").append(responseCode).append('\'');
* ============LICENSE_START=======================================================
* policy-utils
* ================================================================================
- * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2018-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@Test
public void resetSubTransaction() {
- MDCTransaction trans =
- MDCTransaction.newTransaction(null, null).resetSubTransaction();
+ MdcTransaction trans =
+ MdcTransaction.newTransaction(null, null).resetSubTransaction();
assertNotNull(trans.getRequestId());
assertNotNull(trans.getPartner());
assertNullSubTransactionFields(trans);
- assertNotNull(MDC.get(MDCTransaction.REQUEST_ID));
- assertNotNull(MDC.get(MDCTransaction.PARTNER_NAME));
- assertNotNull(MDC.get(MDCTransaction.VIRTUAL_SERVER_NAME));
- assertNotNull(MDC.get(MDCTransaction.SERVER));
- assertNotNull(MDC.get(MDCTransaction.SERVER_IP_ADDRESS));
- assertNotNull(MDC.get(MDCTransaction.SERVER_FQDN));
- assertNotNull(MDC.get(MDCTransaction.SERVICE_NAME));
-
- assertNull(MDC.get(MDCTransaction.INVOCATION_ID));
- assertNull(MDC.get(MDCTransaction.BEGIN_TIMESTAMP));
- assertNull(MDC.get(MDCTransaction.END_TIMESTAMP));
- assertNull(MDC.get(MDCTransaction.ELAPSED_TIME));
- assertNull(MDC.get(MDCTransaction.SERVICE_INSTANCE_ID));
- assertNull(MDC.get(MDCTransaction.INSTANCE_UUID));
- assertNull(MDC.get(MDCTransaction.PROCESS_KEY));
- assertNull(MDC.get(MDCTransaction.STATUS_CODE));
- assertNull(MDC.get(MDCTransaction.RESPONSE_CODE));
- assertNull(MDC.get(MDCTransaction.RESPONSE_DESCRIPTION));
- assertNull(MDC.get(MDCTransaction.SEVERITY));
- assertNull(MDC.get(MDCTransaction.ALERT_SEVERITY));
- assertNull(MDC.get(MDCTransaction.TARGET_ENTITY));
- assertNull(MDC.get(MDCTransaction.TARGET_SERVICE_NAME));
- assertNull(MDC.get(MDCTransaction.TARGET_VIRTUAL_ENTITY));
- assertNull(MDC.get(MDCTransaction.CLIENT_IP_ADDRESS));
- assertNull(MDC.get(MDCTransaction.REMOTE_HOST));
-
- assertEquals(trans.getRequestId(), MDC.get(MDCTransaction.REQUEST_ID));
- assertEquals(trans.getPartner(), MDC.get(MDCTransaction.PARTNER_NAME));
- assertEquals(trans.getVirtualServerName(), MDC.get(MDCTransaction.VIRTUAL_SERVER_NAME));
- assertEquals(trans.getServer(), MDC.get(MDCTransaction.SERVER));
- assertEquals(trans.getServerIpAddress(), MDC.get(MDCTransaction.SERVER_IP_ADDRESS));
- assertEquals(trans.getServerFqdn(), MDC.get(MDCTransaction.SERVER_FQDN));
- assertEquals(trans.getServiceName(), MDC.get(MDCTransaction.SERVICE_NAME));
+ assertNotNull(MDC.get(MdcTransaction.REQUEST_ID));
+ assertNotNull(MDC.get(MdcTransaction.PARTNER_NAME));
+ assertNotNull(MDC.get(MdcTransaction.VIRTUAL_SERVER_NAME));
+ assertNotNull(MDC.get(MdcTransaction.SERVER));
+ assertNotNull(MDC.get(MdcTransaction.SERVER_IP_ADDRESS));
+ assertNotNull(MDC.get(MdcTransaction.SERVER_FQDN));
+ assertNotNull(MDC.get(MdcTransaction.SERVICE_NAME));
+
+ assertNull(MDC.get(MdcTransaction.INVOCATION_ID));
+ assertNull(MDC.get(MdcTransaction.BEGIN_TIMESTAMP));
+ assertNull(MDC.get(MdcTransaction.END_TIMESTAMP));
+ assertNull(MDC.get(MdcTransaction.ELAPSED_TIME));
+ assertNull(MDC.get(MdcTransaction.SERVICE_INSTANCE_ID));
+ assertNull(MDC.get(MdcTransaction.INSTANCE_UUID));
+ assertNull(MDC.get(MdcTransaction.PROCESS_KEY));
+ assertNull(MDC.get(MdcTransaction.STATUS_CODE));
+ assertNull(MDC.get(MdcTransaction.RESPONSE_CODE));
+ assertNull(MDC.get(MdcTransaction.RESPONSE_DESCRIPTION));
+ assertNull(MDC.get(MdcTransaction.SEVERITY));
+ assertNull(MDC.get(MdcTransaction.ALERT_SEVERITY));
+ assertNull(MDC.get(MdcTransaction.TARGET_ENTITY));
+ assertNull(MDC.get(MdcTransaction.TARGET_SERVICE_NAME));
+ assertNull(MDC.get(MdcTransaction.TARGET_VIRTUAL_ENTITY));
+ assertNull(MDC.get(MdcTransaction.CLIENT_IP_ADDRESS));
+ assertNull(MDC.get(MdcTransaction.REMOTE_HOST));
+
+ assertEquals(trans.getRequestId(), MDC.get(MdcTransaction.REQUEST_ID));
+ assertEquals(trans.getPartner(), MDC.get(MdcTransaction.PARTNER_NAME));
+ assertEquals(trans.getVirtualServerName(), MDC.get(MdcTransaction.VIRTUAL_SERVER_NAME));
+ assertEquals(trans.getServer(), MDC.get(MdcTransaction.SERVER));
+ assertEquals(trans.getServerIpAddress(), MDC.get(MdcTransaction.SERVER_IP_ADDRESS));
+ assertEquals(trans.getServerFqdn(), MDC.get(MdcTransaction.SERVER_FQDN));
+ assertEquals(trans.getServiceName(), MDC.get(MdcTransaction.SERVICE_NAME));
}
- private void assertNullSubTransactionFields(MDCTransaction trans) {
+ private void assertNullSubTransactionFields(MdcTransaction trans) {
assertNull(trans.getInvocationId());
assertNullSubTransactionFieldsButInvocationId(trans);
}
- private void assertNullSubTransactionFieldsButInvocationId(MDCTransaction trans) {
+ private void assertNullSubTransactionFieldsButInvocationId(MdcTransaction trans) {
assertNull(trans.getEndTime());
assertNull(trans.getElapsedTime());
assertNull(trans.getServiceInstanceId());
assertNull(trans.getStatusCode());
assertNull(trans.getResponseCode());
assertNull(trans.getResponseDescription());
- assertNull(trans.getInstanceUUID());
+ assertNull(trans.getInstanceUuid());
assertNull(trans.getTargetEntity());
assertNull(trans.getTargetServiceName());
assertNull(trans.getProcessKey());
assertNull(trans.getTargetVirtualEntity());
}
- protected void assertTransactionFields(MDCTransaction trans) {
- assertEquals(trans.getRequestId(), MDC.get(MDCTransaction.REQUEST_ID));
- assertEquals(trans.getPartner(), MDC.get(MDCTransaction.PARTNER_NAME));
- assertEquals(trans.getVirtualServerName(), MDC.get(MDCTransaction.VIRTUAL_SERVER_NAME));
- assertEquals(trans.getServer(), MDC.get(MDCTransaction.SERVER));
- assertEquals(trans.getServerIpAddress(), MDC.get(MDCTransaction.SERVER_IP_ADDRESS));
- assertEquals(trans.getServerFqdn(), MDC.get(MDCTransaction.SERVER_FQDN));
- assertEquals(trans.getServiceName(), MDC.get(MDCTransaction.SERVICE_NAME));
+ protected void assertTransactionFields(MdcTransaction trans) {
+ assertEquals(trans.getRequestId(), MDC.get(MdcTransaction.REQUEST_ID));
+ assertEquals(trans.getPartner(), MDC.get(MdcTransaction.PARTNER_NAME));
+ assertEquals(trans.getVirtualServerName(), MDC.get(MdcTransaction.VIRTUAL_SERVER_NAME));
+ assertEquals(trans.getServer(), MDC.get(MdcTransaction.SERVER));
+ assertEquals(trans.getServerIpAddress(), MDC.get(MdcTransaction.SERVER_IP_ADDRESS));
+ assertEquals(trans.getServerFqdn(), MDC.get(MdcTransaction.SERVER_FQDN));
+ assertEquals(trans.getServiceName(), MDC.get(MdcTransaction.SERVICE_NAME));
}
@Test
public void flush() {
- MDCTransaction trans =
- MDCTransaction.newTransaction()
+ MdcTransaction trans =
+ MdcTransaction.newTransaction()
.setRequestId(null)
.setInvocationId(null)
.setPartner(null)
.setStartTime(null)
.setEndTime(null)
.setServiceInstanceId("service-instance-id")
- .setInstanceUUID(null)
+ .setInstanceUuid(null)
.setProcessKey("process-key")
.setStatusCode("status-code")
.setResponseCode("response-code")
assertTransactionFields(trans);
- assertNotNull(MDC.get(MDCTransaction.INVOCATION_ID));
- assertNotNull(MDC.get(MDCTransaction.BEGIN_TIMESTAMP));
- assertNotNull(MDC.get(MDCTransaction.END_TIMESTAMP));
- assertNotNull(MDC.get(MDCTransaction.ELAPSED_TIME));
- assertNotNull(MDC.get(MDCTransaction.SERVICE_INSTANCE_ID));
- assertNotNull(MDC.get(MDCTransaction.INSTANCE_UUID));
- assertNotNull(MDC.get(MDCTransaction.PROCESS_KEY));
- assertNotNull(MDC.get(MDCTransaction.STATUS_CODE));
- assertNotNull(MDC.get(MDCTransaction.RESPONSE_CODE));
- assertNotNull(MDC.get(MDCTransaction.RESPONSE_DESCRIPTION));
- assertNotNull(MDC.get(MDCTransaction.SEVERITY));
- assertNotNull(MDC.get(MDCTransaction.ALERT_SEVERITY));
- assertNotNull(MDC.get(MDCTransaction.TARGET_ENTITY));
- assertNotNull(MDC.get(MDCTransaction.TARGET_SERVICE_NAME));
- assertNotNull(MDC.get(MDCTransaction.TARGET_VIRTUAL_ENTITY));
- assertNotNull(MDC.get(MDCTransaction.CLIENT_IP_ADDRESS));
- assertNotNull(MDC.get(MDCTransaction.REMOTE_HOST));
-
- assertEquals(trans.getInvocationId(), MDC.get(MDCTransaction.INVOCATION_ID));
- assertEquals(trans.timestamp(trans.getStartTime()), MDC.get(MDCTransaction.BEGIN_TIMESTAMP));
- assertEquals(trans.timestamp(trans.getEndTime()), MDC.get(MDCTransaction.END_TIMESTAMP));
- assertNotEquals(trans.getElapsedTime(), MDC.get(MDCTransaction.ELAPSED_TIME));
+ assertNotNull(MDC.get(MdcTransaction.INVOCATION_ID));
+ assertNotNull(MDC.get(MdcTransaction.BEGIN_TIMESTAMP));
+ assertNotNull(MDC.get(MdcTransaction.END_TIMESTAMP));
+ assertNotNull(MDC.get(MdcTransaction.ELAPSED_TIME));
+ assertNotNull(MDC.get(MdcTransaction.SERVICE_INSTANCE_ID));
+ assertNotNull(MDC.get(MdcTransaction.INSTANCE_UUID));
+ assertNotNull(MDC.get(MdcTransaction.PROCESS_KEY));
+ assertNotNull(MDC.get(MdcTransaction.STATUS_CODE));
+ assertNotNull(MDC.get(MdcTransaction.RESPONSE_CODE));
+ assertNotNull(MDC.get(MdcTransaction.RESPONSE_DESCRIPTION));
+ assertNotNull(MDC.get(MdcTransaction.SEVERITY));
+ assertNotNull(MDC.get(MdcTransaction.ALERT_SEVERITY));
+ assertNotNull(MDC.get(MdcTransaction.TARGET_ENTITY));
+ assertNotNull(MDC.get(MdcTransaction.TARGET_SERVICE_NAME));
+ assertNotNull(MDC.get(MdcTransaction.TARGET_VIRTUAL_ENTITY));
+ assertNotNull(MDC.get(MdcTransaction.CLIENT_IP_ADDRESS));
+ assertNotNull(MDC.get(MdcTransaction.REMOTE_HOST));
+
+ assertEquals(trans.getInvocationId(), MDC.get(MdcTransaction.INVOCATION_ID));
+ assertEquals(trans.timestamp(trans.getStartTime()), MDC.get(MdcTransaction.BEGIN_TIMESTAMP));
+ assertEquals(trans.timestamp(trans.getEndTime()), MDC.get(MdcTransaction.END_TIMESTAMP));
+ assertNotEquals(trans.getElapsedTime(), MDC.get(MdcTransaction.ELAPSED_TIME));
assertEquals(String.valueOf(Duration.between(trans.getStartTime(), trans.getEndTime()).toMillis()),
- MDC.get(MDCTransaction.ELAPSED_TIME));
- assertEquals(trans.getServiceInstanceId(), MDC.get(MDCTransaction.SERVICE_INSTANCE_ID));
- assertEquals(trans.getInstanceUUID(), MDC.get(MDCTransaction.INSTANCE_UUID));
- assertEquals(trans.getProcessKey(),MDC.get(MDCTransaction.PROCESS_KEY));
- assertEquals(trans.getStatusCode(), MDC.get(MDCTransaction.STATUS_CODE));
- assertEquals(trans.getResponseCode(), MDC.get(MDCTransaction.RESPONSE_CODE));
- assertEquals(trans.getResponseDescription(), MDC.get(MDCTransaction.RESPONSE_DESCRIPTION));
- assertEquals(trans.getSeverity(), MDC.get(MDCTransaction.SEVERITY));
- assertEquals(trans.getAlertSeverity(), MDC.get(MDCTransaction.ALERT_SEVERITY));
- assertEquals(trans.getTargetEntity(), MDC.get(MDCTransaction.TARGET_ENTITY));
- assertEquals(trans.getTargetServiceName(), MDC.get(MDCTransaction.TARGET_SERVICE_NAME));
- assertEquals(trans.getTargetVirtualEntity(), MDC.get(MDCTransaction.TARGET_VIRTUAL_ENTITY));
- assertEquals(trans.getClientIpAddress(), MDC.get(MDCTransaction.CLIENT_IP_ADDRESS));
- assertEquals(trans.getRemoteHost(), MDC.get(MDCTransaction.REMOTE_HOST));
+ MDC.get(MdcTransaction.ELAPSED_TIME));
+ assertEquals(trans.getServiceInstanceId(), MDC.get(MdcTransaction.SERVICE_INSTANCE_ID));
+ assertEquals(trans.getInstanceUuid(), MDC.get(MdcTransaction.INSTANCE_UUID));
+ assertEquals(trans.getProcessKey(),MDC.get(MdcTransaction.PROCESS_KEY));
+ assertEquals(trans.getStatusCode(), MDC.get(MdcTransaction.STATUS_CODE));
+ assertEquals(trans.getResponseCode(), MDC.get(MdcTransaction.RESPONSE_CODE));
+ assertEquals(trans.getResponseDescription(), MDC.get(MdcTransaction.RESPONSE_DESCRIPTION));
+ assertEquals(trans.getSeverity(), MDC.get(MdcTransaction.SEVERITY));
+ assertEquals(trans.getAlertSeverity(), MDC.get(MdcTransaction.ALERT_SEVERITY));
+ assertEquals(trans.getTargetEntity(), MDC.get(MdcTransaction.TARGET_ENTITY));
+ assertEquals(trans.getTargetServiceName(), MDC.get(MdcTransaction.TARGET_SERVICE_NAME));
+ assertEquals(trans.getTargetVirtualEntity(), MDC.get(MdcTransaction.TARGET_VIRTUAL_ENTITY));
+ assertEquals(trans.getClientIpAddress(), MDC.get(MdcTransaction.CLIENT_IP_ADDRESS));
+ assertEquals(trans.getRemoteHost(), MDC.get(MdcTransaction.REMOTE_HOST));
assertEquals("service-instance-id", trans.getServiceInstanceId());
assertEquals("process-key", trans.getProcessKey());
@Test
public void metric() {
- MDCTransaction trans =
- MDCTransaction.newTransaction(null, null).metric();
+ MdcTransaction trans =
+ MdcTransaction.newTransaction(null, null).metric();
assertTransactionFields(trans);
}
@Test
public void transaction() {
- MDCTransaction trans =
- MDCTransaction.newTransaction(null, null).transaction();
+ MdcTransaction trans =
+ MdcTransaction.newTransaction(null, null).transaction();
assertTransactionFields(trans);
}
@Test
public void subTransaction() {
- MDCTransaction trans =
- MDCTransaction.newTransaction(null, "partner");
+ MdcTransaction trans =
+ MdcTransaction.newTransaction(null, "partner");
- MDCTransaction subTrans = MDCTransaction.newSubTransaction(null);
+ MdcTransaction subTrans = MdcTransaction.newSubTransaction(null);
assertTransactionFields(trans);
assertTransactionFields(subTrans);
assertNullSubTransactionFieldsButInvocationId(trans);
subTrans.setServiceInstanceId("service-instance-id")
- .setInstanceUUID(null)
+ .setInstanceUuid(null)
.setProcessKey("process-key")
.setStatusCode("status-code")
.setResponseCode("response-code")
subTrans.setStatusCode(false).setResponseCode("400");
- MDCTransaction subTrans2 = MDCTransaction.fromTransaction(subTrans);
+ MdcTransaction subTrans2 = MdcTransaction.fromTransaction(subTrans);
assertEquals(subTrans.toString(), subTrans2.toString());
trans.resetSubTransaction().setStatusCode(true).setResponseCode("200").metric();
}
-}
\ No newline at end of file
+}
Code Review / policy / drools-pdp.git / commitdiff