sdks/java/src/main/java/org/apache/usergrid/java/client/entities/Message.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You 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.apache.usergrid.java.client.entities;

import static com.fasterxml.jackson.databind.annotation.JsonSerialize.Inclusion.NON_NULL;
import static org.apache.usergrid.java.client.utils.JsonUtils.getBooleanProperty;
import static org.apache.usergrid.java.client.utils.JsonUtils.getLongProperty;
import static org.apache.usergrid.java.client.utils.JsonUtils.getStringProperty;
import static org.apache.usergrid.java.client.utils.JsonUtils.getUUIDProperty;
import static org.apache.usergrid.java.client.utils.JsonUtils.setBooleanProperty;
import static org.apache.usergrid.java.client.utils.JsonUtils.setLongProperty;
import static org.apache.usergrid.java.client.utils.JsonUtils.setStringProperty;
import static org.apache.usergrid.java.client.utils.JsonUtils.setUUIDProperty;

import java.util.List;
import java.util.UUID;

import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.databind.annotation.JsonSerialize.Inclusion;

public class Message extends Entity {

	public static final String ENTITY_TYPE = "message";

	public static final String PROPERTY_CORRELATION_ID = "correlation_id";
	public static final String PROPERTY_DESTINATION = "destination";
	public static final String PROPERTY_REPLY_TO = "reply_to";
	public static final String PROPERTY_TIMESTAMP = "timestamp";
	public static final String PROPERTY_TYPE = "type";
	public static final String PROPERTY_CATEGORY = "category";
	public static final String PROPERTY_INDEXED = "indexed";
	public static final String PROPERTY_PERSISTENT = "persistent";

	public Message() {
		super();
		setType(ENTITY_TYPE);
	}

	public Message(Entity entity) {
		super();
		properties = entity.properties;
		setType(ENTITY_TYPE);
	}

	@Override
	@JsonIgnore
	public String getNativeType() {
		return ENTITY_TYPE;
	}

	@Override
	@JsonIgnore
	public List<String> getPropertyNames() {
		List<String> properties = super.getPropertyNames();
		properties.add(PROPERTY_CORRELATION_ID);
		properties.add(PROPERTY_DESTINATION);
		properties.add(PROPERTY_REPLY_TO);
		properties.add(PROPERTY_TIMESTAMP);
		properties.add(PROPERTY_CATEGORY);
		properties.add(PROPERTY_INDEXED);
		properties.add(PROPERTY_PERSISTENT);
		return properties;
	}

	@JsonSerialize(include = NON_NULL)
	@JsonProperty(PROPERTY_CORRELATION_ID)
	public UUID getCorrelationId() {
		return getUUIDProperty(properties, PROPERTY_CORRELATION_ID);
	}

	@JsonProperty(PROPERTY_CORRELATION_ID)
	public void setCorrelationId(UUID uuid) {
		setUUIDProperty(properties, PROPERTY_CORRELATION_ID, uuid);
	}

	@JsonSerialize(include = NON_NULL)
	public String getDestination() {
		return getStringProperty(properties, PROPERTY_DESTINATION);
	}

	public void setDestination(String destination) {
		setStringProperty(properties, PROPERTY_DESTINATION, destination);
	}

	@JsonSerialize(include = NON_NULL)
	@JsonProperty(PROPERTY_REPLY_TO)
	public String getReplyTo() {
		return getStringProperty(properties, PROPERTY_DESTINATION);
	}

	@JsonProperty(PROPERTY_REPLY_TO)
	public void setReplyTo(String replyTo) {
		setStringProperty(properties, PROPERTY_DESTINATION, replyTo);
	}

	@JsonSerialize(include = Inclusion.NON_NULL)
	public Long getTimestamp() {
		return getLongProperty(properties, PROPERTY_TIMESTAMP);
	}

	public void setTimestamp(Long timestamp) {
		setLongProperty(properties, PROPERTY_TIMESTAMP, timestamp);
	}

	@JsonSerialize(include = NON_NULL)
	public String getCategory() {
		return getStringProperty(properties, PROPERTY_CATEGORY);
	}

	public void setCategory(String category) {
		setStringProperty(properties, PROPERTY_CATEGORY, category);
	}

	@JsonSerialize(include = NON_NULL)
	public Boolean isIndexed() {
		return getBooleanProperty(properties, PROPERTY_INDEXED);
	}

	public void setIndexed(Boolean indexed) {
		setBooleanProperty(properties, PROPERTY_INDEXED, indexed);
	}

	@JsonSerialize(include = NON_NULL)
	public Boolean isPersistent() {
		return getBooleanProperty(properties, PROPERTY_INDEXED);
	}

	public void setPersistent(Boolean persistent) {
		setBooleanProperty(properties, PROPERTY_INDEXED, persistent);
	}

}