Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2002-2014 the original author or authors.
   *
   * 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.springframework.messaging.support;
 
 import java.util.Map;
 
An implementation of org.springframework.messaging.Message with a generic payload. Once created, a GenericMessage is immutable.

Author(s):
Mark Fisher
Since:
4.0
See also:
MessageBuilder
 
 public class GenericMessage<T> implements Message<T>, Serializable {
 
 	private static final long serialVersionUID = 4268801052358035098L;
 
 
 	private final T payload;
 
 	private final MessageHeaders headers;


Create a new message with the given payload.

Parameters:
payload the message payload, never null
 
 	public GenericMessage(T payload) {
 		this(payloadnull);
 	}

Create a new message with the given payload and headers.

Parameters:
payload the message payload, never null
headers message headers
 
 	public GenericMessage(T payloadMap<StringObjectheaders) {
 		Assert.notNull(payload"payload must not be null");
 		this. = new MessageHeaders(headers);
 		this. = payload;
 	}
 
 
 	public MessageHeaders getHeaders() {
 		return this.;
 	}
 
 	public T getPayload() {
 		return this.;
 	}
 
 	public String toString() {
 		StringBuilder sb = new StringBuilder();
 		if (this. instanceof byte[]) {
 			sb.append("[Payload byte[").append(((byte[]) this.).length).append("]]");
 		}
 		else {
 			sb.append("[Payload ").append(this..getClass().getSimpleName());
 			sb.append(" content=").append(this.).append("]");
 		}
 		sb.append("[Headers=").append(this.).append("]");
 		return sb.toString();
 	}
 
 	public int hashCode() {
 		return this..hashCode() * 23 + ObjectUtils.nullSafeHashCode(this.);
 	}
 
 	public boolean equals(Object obj) {
 		if (this == obj) {
 			return true;
 		}
 		if (obj != null && obj instanceof GenericMessage<?>) {
 			GenericMessage<?> other = (GenericMessage<?>) obj;
 			return (this..getId().equals(other.headers.getId()) &&
					this..equals(other.headers) && this..equals(other.payload));
		}
		return false;
	}
New to GrepCode? Check out our FAQ X