package org.onlab.onos.store.cluster.messaging;

import org.onlab.nio.AbstractMessage;

import static com.google.common.base.MoreObjects.toStringHelper;

/**
 * Base message for cluster-wide communications.
 */
public abstract class ClusterMessage extends AbstractMessage {

    private final MessageSubject subject;

    /**
     * Creates a cluster message.
     *
     * @param subject message subject
     */
    protected ClusterMessage(MessageSubject subject) {
        this.subject = subject;
    }

    /**
     * Returns the message subject indicator.
     *
     * @return message subject
     */
    public MessageSubject subject() {
        return subject;
    }

    @Override
    public String toString() {
        return toStringHelper(this).add("subject", subject).add("length", length).toString();
    }

}