diff options
Diffstat (limited to 'sca-java-1.x/tags/java-stable-20060304/sca/core/src/main/java/org/apache/tuscany/core/message/impl/MessageImpl.java')
-rw-r--r-- | sca-java-1.x/tags/java-stable-20060304/sca/core/src/main/java/org/apache/tuscany/core/message/impl/MessageImpl.java | 249 |
1 files changed, 249 insertions, 0 deletions
diff --git a/sca-java-1.x/tags/java-stable-20060304/sca/core/src/main/java/org/apache/tuscany/core/message/impl/MessageImpl.java b/sca-java-1.x/tags/java-stable-20060304/sca/core/src/main/java/org/apache/tuscany/core/message/impl/MessageImpl.java new file mode 100644 index 0000000000..b67c7e227e --- /dev/null +++ b/sca-java-1.x/tags/java-stable-20060304/sca/core/src/main/java/org/apache/tuscany/core/message/impl/MessageImpl.java @@ -0,0 +1,249 @@ +/** + * + * Copyright 2005 The Apache Software Foundation or its licensors, as applicable. + * + * 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.apache.tuscany.core.message.impl; + +import java.util.HashMap; +import java.util.Map; + +import org.apache.tuscany.core.addressing.EndpointReference; +import org.apache.tuscany.core.invocation.MessageChannel; +import org.apache.tuscany.core.invocation.TargetInvoker; +import org.apache.tuscany.core.message.Message; + +/** + */ +public class MessageImpl implements Message, MessageChannel { + + private String action; + private Object body; + private EndpointReference endpointReference; + private EndpointReference faultTo; + private EndpointReference from; + private Map<String, Object> headers; + private String messageID; + private String operationName; + private Message relatedCallbackMessage; + private String relatesTo; + private EndpointReference replyTo; + private TargetInvoker invoker; + private EndpointReference to; + + /** + * Constructor + */ + protected MessageImpl() { + super(); + } + + /** + * @see org.apache.tuscany.core.message.Message#getAction() + */ + public String getAction() { + return action; + } + + /** + * @see org.apache.tuscany.core.message.Message#getBody() + */ + public Object getBody() { + return body; + } + + /** + * @see org.apache.tuscany.core.message.Message#getEndpointReference() + */ + public EndpointReference getEndpointReference() { + return endpointReference; + } + + /** + * @see org.apache.tuscany.core.message.Message#getFaultTo() + */ + public EndpointReference getFaultTo() { + return faultTo; + } + + /** + * @see org.apache.tuscany.core.message.Message#getFrom() + */ + public EndpointReference getFrom() { + return from; + } + + /** + * @see org.apache.tuscany.core.message.Message#getHeaders() + */ + public Map<String, Object> getHeaders() { + if (headers==null) + headers=new HashMap<String, Object>(); + return headers; + } + + /** + * @see org.apache.tuscany.core.message.Message#getMessageID() + */ + public String getMessageID() { + return messageID; + } + + /** + * @see org.apache.tuscany.core.message.Message#getOperationName() + */ + public String getOperationName() { + return operationName; + } + + /** + * @see org.apache.tuscany.core.message.Message#getRelatesTo() + */ + public String getRelatesTo() { + return relatesTo; + } + + /** + * @see org.apache.tuscany.core.message.Message#getReplyTo() + */ + public EndpointReference getReplyTo() { + return replyTo; + } + + /** + * @see org.apache.tuscany.core.message.Message#getTo() + */ + public EndpointReference getTo() { + return to; + } + + /** + * @see org.apache.tuscany.core.message.Message#isRequest() + */ + public boolean isRequest() { + return relatesTo==null; + } + + /** + * @see org.apache.tuscany.core.message.Message#isResponse() + */ + public boolean isResponse() { + return relatesTo!=null; + } + + /** + * @see org.apache.tuscany.core.message.Message#setAction(java.lang.String) + */ + public void setAction(String action) { + this.action=action; + } + + /** + * @see org.apache.tuscany.core.message.Message#setBody(java.lang.Object) + */ + public void setBody(Object body) { + this.body=body; + } + + /** + * @see org.apache.tuscany.core.message.Message#setEndpointReference(org.apache.tuscany.core.client.runtime.addressing.sdo.EndpointReference) + */ + public void setEndpointReference(EndpointReference endpointReference) { + this.endpointReference=endpointReference; + } + + /** + * @see org.apache.tuscany.core.message.Message#setFaultTo(org.apache.tuscany.core.client.runtime.addressing.sdo.EndpointReference) + */ + public void setFaultTo(EndpointReference faultTo) { + this.faultTo=faultTo; + } + + /** + * @see org.apache.tuscany.core.message.Message#setFrom(org.apache.tuscany.core.client.runtime.addressing.sdo.EndpointReference) + */ + public void setFrom(EndpointReference from) { + this.from=from; + } + + /** + * @see org.apache.tuscany.core.message.Message#setMessageID(java.lang.String) + */ + public void setMessageID(String messageID) { + this.messageID=messageID; + } + + /** + * @see org.apache.tuscany.core.message.Message#setOperationName(java.lang.String) + */ + public void setOperationName(String operationName) { + this.operationName=operationName; + } + + /** + * @see org.apache.tuscany.core.message.Message#setRelatesTo(java.lang.String) + */ + public void setRelatesTo(String relatesTo) { + this.relatesTo=relatesTo; + } + + /** + * @see org.apache.tuscany.core.message.Message#setReplyTo(org.apache.tuscany.core.client.runtime.addressing.sdo.EndpointReference) + */ + public void setReplyTo(EndpointReference replyTo) { + this.replyTo=replyTo; + } + + /** + * @see org.apache.tuscany.core.message.Message#setTo(org.apache.tuscany.core.client.runtime.addressing.sdo.EndpointReference) + */ + public void setTo(EndpointReference to) { + this.to=to; + } + + /** + * @see org.apache.tuscany.core.message.Message#getCallbackChannel() + */ + public MessageChannel getCallbackChannel() { + return this; + } + + /** + * @see org.apache.tuscany.core.invocation.MessageChannel#send(org.apache.tuscany.core.message.Message) + */ + public void send(Message message) { + relatedCallbackMessage = message; + } + + /** + * @see org.apache.tuscany.core.message.Message#getRelatedCallbackMessage() + */ + public Message getRelatedCallbackMessage() { + return relatedCallbackMessage; + } + + /** + * @see org.apache.tuscany.core.message.Message#setTargetInvoker(org.apache.tuscany.core.invocation.TargetInvoker) + */ + public void setTargetInvoker(TargetInvoker invoker){ + this.invoker = invoker; + } + + /** + * @see org.apache.tuscany.core.message.Message#getTargetInvoker() + */ + public TargetInvoker getTargetInvoker(){ + return invoker; + } +} |