/** * 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.camel; import java.util.Map; import java.util.Set; import javax.activation.DataHandler; /** * Implements the Message pattern and * represents an inbound or outbound message as part of an {@link Exchange} *

* See {@link org.apache.camel.impl.DefaultMessage DefaultMessage} for how headers * is represented in Camel using a {@link org.apache.camel.util.CaseInsensitiveMap CaseInsensitiveMap}. * * @version $Revision$ */ public interface Message { /** * Returns the id of the message * * @return the message id */ String getMessageId(); /** * Sets the id of the message * * @param messageId id of the message */ void setMessageId(String messageId); /** * Returns the exchange this message is related to * * @return the exchange */ Exchange getExchange(); /** * Returns true if this message represents a fault * * @return true if this is a fault message, false for regular messages. */ boolean isFault(); /** * Sets the fault flag on this message * * @param fault the fault flag */ void setFault(boolean fault); /** * Accesses a specific header * * @param name name of header * @return the value of the given header or null if there is no * header for the given name */ Object getHeader(String name); /** * Accesses a specific header * * @param name name of header * @param defaultValue the default value to return if header was absent * @return the value of the given header or defaultValue if there is no * header for the given name */ Object getHeader(String name, Object defaultValue); /** * Returns a header associated with this message by name and specifying the * type required * * @param name the name of the header * @param type the type of the header * @return the value of the given header or null if there is no header for * the given name or null if it cannot be converted to the given type */ T getHeader(String name, Class type); /** * Returns a header associated with this message by name and specifying the * type required * * @param name the name of the header * @param defaultValue the default value to return if header was absent * @param type the type of the header * @return the value of the given header or defaultValue if there is no header for * the given name or null if it cannot be converted to the given type */ T getHeader(String name, Object defaultValue, Class type); /** * Sets a header on the message * * @param name of the header * @param value to associate with the name */ void setHeader(String name, Object value); /** * Removes the named header from this message * * @param name name of the header * @return the old value of the header */ Object removeHeader(String name); /** * Returns all of the headers associated with the message * * @return all the headers in a Map */ Map getHeaders(); /** * Set all the headers associated with this message * * @param headers headers to set */ void setHeaders(Map headers); /** * Returns whether has any headers has been set. * * @return true if any headers has been set */ boolean hasHeaders(); /** * Returns the body of the message as a POJO *

* The body can be null if no body is set * * @return the body, can be null */ Object getBody(); /** * Returns the body of the message as a POJO * * @return the body, is never null * @throws InvalidPayloadException Is thrown if the body being null or wrong class type */ Object getMandatoryBody() throws InvalidPayloadException; /** * Returns the body as the specified type * * @param type the type that the body * @return the body of the message as the specified type, or null if not possible to convert */ T getBody(Class type); /** * Returns the mandatory body as the specified type * * @param type the type that the body * @return the body of the message as the specified type, is never null. * @throws InvalidPayloadException Is thrown if the body being null or wrong class type */ T getMandatoryBody(Class type) throws InvalidPayloadException; /** * Sets the body of the message * * @param body the body */ void setBody(Object body); /** * Sets the body of the message as a specific type * * @param body the body * @param type the type of the body */ void setBody(Object body, Class type); /** * Creates a copy of this message so that it can be used and possibly * modified further in another exchange * * @return a new message instance copied from this message */ Message copy(); /** * Copies the contents of the other message into this message * * @param message the other message */ void copyFrom(Message message); /** * Returns the attachment specified by the id * * @param id the id under which the attachment is stored * @return the data handler for this attachment or null */ DataHandler getAttachment(String id); /** * Returns a set of attachment names of the message * * @return a set of attachment names */ Set getAttachmentNames(); /** * Removes the attachment specified by the id * * @param id the id of the attachment to remove */ void removeAttachment(String id); /** * Adds an attachment to the message using the id * * @param id the id to store the attachment under * @param content the data handler for the attachment */ void addAttachment(String id, DataHandler content); /** * Returns all attachments of the message * * @return the attachments in a map or null */ Map getAttachments(); /** * Set all the attachments associated with this message * * @param attachments the attachments */ void setAttachments(Map attachments); /** * Returns whether this message has attachments. * * @return true if this message has any attachments. */ boolean hasAttachments(); /** * Returns the unique ID for a message exchange if this message is capable * of creating one or null if not * * @return the created exchange id, or null if not capable of creating */ String createExchangeId(); }