public class InternalMessage extends AbstractServerMessageImpl<InternalMessage,InternalMessageMetaData>
debugIdentity, getConnectionReference, getContent, getContent, getMessageNumber, getStoredMessage, isPersistent, isReferenced, isReferenced, newReference, newReference, toString
public String getInitialRoutingAddress()
public InternalMessageHeader getMessageHeader()
public long getSize()
public long getExpiration()
public long getArrivalTime()
public Object getMessageBody()
public static InternalMessage createStringMessage(MessageStore store, AMQMessageHeader header, String messageBody)
public static InternalMessage createStringMessage(MessageStore store, AMQMessageHeader header, String messageBody, boolean persistent)
public static InternalMessage createMapMessage(MessageStore store, AMQMessageHeader header, Map<? extends Object,? extends Object> messageBody)
public static InternalMessage createListMessage(MessageStore store, AMQMessageHeader header, List<? extends Object> messageBody)
public static InternalMessage createBytesMessage(MessageStore store, AMQMessageHeader header, byte[] messageBody)
public static InternalMessage createBytesMessage(MessageStore store, AMQMessageHeader header, byte[] messageBody, boolean persist)
public static InternalMessage convert(long messageNumber, boolean persistent, AMQMessageHeader header, Object messageBody)
public void setInitialRoutingAddress(String initialRoutingAddress)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.