Added Message interface, header, and simple document message implementation (EAI-1)

spring-eai-core/src/main/java/org/springframework/eai/message/DocumentMessage.java

@@ -0,0 +1,43 @@
+/*
+ * Copyright 2002-2007 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.eai.message;
+
+/**
+ * @author Mark Fisher
+ */
+public class DocumentMessage implements Message {
+
+	private MessageHeader header;
+
+	private Object payload;
+
+
+	public DocumentMessage(Object id, Object payload) {
+		this.header = new MessageHeader(id);
+		this.payload = payload;
+	}
+
+
+	public MessageHeader getHeader() {
+		return this.header;
+	}
+
+	public Object getPayload() {
+		return this.payload;
+	}
+
+}

spring-eai-core/src/main/java/org/springframework/eai/message/Message.java

@@ -0,0 +1,28 @@
+/*
+ * Copyright 2002-2007 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.eai.message;
+
+/**
+ * @author Mark Fisher
+ */
+public interface Message {
+
+	MessageHeader getHeader();
+
+	Object getPayload();
+
+}

spring-eai-core/src/main/java/org/springframework/eai/message/MessageHeader.java

@@ -0,0 +1,100 @@
+/*
+ * Copyright 2002-2007 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.eai.message;
+
+import java.util.Map;
+import java.util.Properties;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * @author Mark Fisher
+ */
+public class MessageHeader {
+
+	private Object id;
+
+	private Object correlationId;
+
+	private String replyChannelName;
+
+	private int sequenceNumber = 1;
+
+	private int sequenceSize = 1;
+
+	private Properties properties = new Properties();
+
+	private Map<String, Object> attributes = new ConcurrentHashMap<String, Object>();
+
+
+	public MessageHeader(Object id) {
+		this.id = id;
+	}
+
+
+	public Object getId() {
+		return this.id;
+	}
+
+	public Object getCorrelationId() {
+		return this.correlationId;
+	}
+
+	public void setCorrelationId(Object correlationId) {
+		this.correlationId = correlationId;
+	}
+
+	public String getReplyChannelName() {
+		return this.replyChannelName;
+	}
+
+	public void setReplyChannelName(String replyChannelName) {
+		this.replyChannelName = replyChannelName;
+	}
+
+	public int getSequenceNumber() {
+		return this.sequenceNumber;
+	}
+
+	public void setSequenceNumber(int sequenceNumber) {
+		this.sequenceNumber = sequenceNumber;
+	}
+
+	public int getSequenceSize() {
+		return this.sequenceSize;
+	}
+
+	public void setSequenceSize(int sequenceSize) {
+		this.sequenceSize = sequenceSize;
+	}
+
+	public String getProperty(String key) {
+		return this.properties.getProperty(key);
+	}
+
+	public void setProperty(String key, String value) {
+		this.properties.setProperty(key, value);
+	}
+
+	public Object getAttribute(String key) {
+		return this.attributes.get(key);
+	}
+
+	public void setAttribute(String key, Object value) {
+		this.attributes.put(key, value);
+	}
+
+}