summaryrefslogtreecommitdiffstats
path: root/src/test/java/com/att/nsa/cambria/backends/memory/MemoryMetaBrokerTest.java
diff options
context:
space:
mode:
authorsunil unnava <sunil.unnava@att.com>2018-10-17 14:14:48 -0400
committersunil unnava <sunil.unnava@att.com>2018-10-17 14:15:19 -0400
commit8a3dfd3fe521f18ce07c2d24202a51b28d424fa2 (patch)
tree22c2875d632594f1ff2e05891ca75330c04eac01 /src/test/java/com/att/nsa/cambria/backends/memory/MemoryMetaBrokerTest.java
parent97bb8fd7e436b07dc0a8e0d56ed9c1952e7ba41e (diff)
bump the version
Issue-ID: DMAAP-849 Change-Id: I378eaf210bde07108182a44a7d52d811fa367779 Signed-off-by: sunil unnava <sunil.unnava@att.com>
Diffstat (limited to 'src/test/java/com/att/nsa/cambria/backends/memory/MemoryMetaBrokerTest.java')
0 files changed, 0 insertions, 0 deletions
id='n165' href='#n165'>165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 
/**
 * 
 */
/*******************************************************************************
 *  ============LICENSE_START=======================================================
 *  org.onap.dmaap
 *  ================================================================================
 *  Copyright © 2017 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.
 *  ============LICENSE_END=========================================================
 *  
 *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
 *  
 *******************************************************************************/
package com.att.dmf.mr.beans;

import java.util.Date;

import com.att.dmf.mr.constants.CambriaConstants;
import com.att.dmf.mr.utils.Utils;

/**
 * @author muzainulhaque.qazi
 *
 */

public class LogDetails {
	
	private String publisherId;
	private String topicId;
	private String subscriberGroupId;
	private String subscriberId;
	private String publisherIp;
	private String messageBatchId;
	private String messageSequence;
	private String messageTimestamp;
	private String consumeTimestamp;
	private String transactionIdTs;	
	private String serverIp;
	
	private long messageLengthInBytes; 
	private long totalMessageCount;
	
	private boolean transactionEnabled;
	/**
	 * This is for transaction enabled logging details
	 *
	 */
	public LogDetails() {
		super();
	}

	public String getTransactionId() {
		StringBuilder transactionId = new StringBuilder();
		transactionId.append(transactionIdTs);
		transactionId.append(CambriaConstants.TRANSACTION_ID_SEPARATOR);
		transactionId.append(publisherIp);
		transactionId.append(CambriaConstants.TRANSACTION_ID_SEPARATOR);
		transactionId.append(messageBatchId);
		transactionId.append(CambriaConstants.TRANSACTION_ID_SEPARATOR);
		transactionId.append(messageSequence);

		return transactionId.toString();
	}

	public String getPublisherId() {
		return publisherId;
	}

	public void setPublisherId(String publisherId) {
		this.publisherId = publisherId;
	}

	public String getTopicId() {
		return topicId;
	}

	public void setTopicId(String topicId) {
		this.topicId = topicId;
	}

	public String getSubscriberGroupId() {
		return subscriberGroupId;
	}

	public void setSubscriberGroupId(String subscriberGroupId) {
		this.subscriberGroupId = subscriberGroupId;
	}

	public String getSubscriberId() {
		return subscriberId;
	}

	public void setSubscriberId(String subscriberId) {
		this.subscriberId = subscriberId;
	}

	public String getPublisherIp() {
		return publisherIp;
	}

	public void setPublisherIp(String publisherIp) {
		this.publisherIp = publisherIp;
	}

	public String getMessageBatchId() {
		return messageBatchId;
	}

	public void setMessageBatchId(Long messageBatchId) {
		this.messageBatchId = Utils.getFromattedBatchSequenceId(messageBatchId);
	}

	public String getMessageSequence() {
		return messageSequence;
	}

	public void setMessageSequence(String messageSequence) {
		this.messageSequence = messageSequence;
	}

	public String getMessageTimestamp() {
		return messageTimestamp;
	}

	public void setMessageTimestamp(String messageTimestamp) {
		this.messageTimestamp = messageTimestamp;
	}

	public String getPublishTimestamp() {
		return Utils.getFormattedDate(new Date());
	}

	public String getConsumeTimestamp() {
		return consumeTimestamp;
	}

	public void setConsumeTimestamp(String consumeTimestamp) {
		this.consumeTimestamp = consumeTimestamp;
	}

	public long getMessageLengthInBytes() {
		return messageLengthInBytes;
	}

	public void setMessageLengthInBytes(long messageLengthInBytes) {
		this.messageLengthInBytes = messageLengthInBytes;
	}

	public long getTotalMessageCount() {
		return totalMessageCount;
	}

	public void setTotalMessageCount(long totalMessageCount) {
		this.totalMessageCount = totalMessageCount;
	}

	public boolean isTransactionEnabled() {
		return transactionEnabled;
	}

	public void setTransactionEnabled(boolean transactionEnabled) {
		this.transactionEnabled = transactionEnabled;
	}

	public String getTransactionIdTs() {
		return transactionIdTs;
	}

	public void setTransactionIdTs(String transactionIdTs) {
		this.transactionIdTs = transactionIdTs;
	}

	public String getPublisherLogDetails() {
		
			StringBuilder buffer = new StringBuilder();
			buffer.append("[publisherId=" + publisherId);
			buffer.append(", topicId=" + topicId);
			buffer.append(", messageTimestamp=" + messageTimestamp);
			buffer.append(", publisherIp=" + publisherIp);
			buffer.append(", messageBatchId=" + messageBatchId);
			buffer.append(", messageSequence=" + messageSequence );
			buffer.append(", messageLengthInBytes=" + messageLengthInBytes);
			buffer.append(", transactionEnabled=" + transactionEnabled);
			buffer.append(", transactionId=" + getTransactionId());
			buffer.append(", publishTimestamp=" + getPublishTimestamp());		
			buffer.append(", serverIp=" + getServerIp()+"]");
		return buffer.toString();
		
	}

	public String getServerIp() {
		return serverIp;
	}

	public void setServerIp(String serverIp) {
		this.serverIp = serverIp;
	}

	public void setMessageBatchId(String messageBatchId) {
		this.messageBatchId = messageBatchId;
	}
	
}