Uses of Class
com.swiftmq.impl.streams.comp.message.Message

Packages that use Message

Package	Description
com.swiftmq.impl.streams
com.swiftmq.impl.streams.comp.io
com.swiftmq.impl.streams.comp.memory
com.swiftmq.impl.streams.comp.message
com.swiftmq.impl.streams.processor.po

Uses of Message in com.swiftmq.impl.streams

Methods in com.swiftmq.impl.streams that return Message

Modifier and Type	Method	Description
Message	Stream.current()	Returns the currently processed Message.

Methods in com.swiftmq.impl.streams with parameters of type Message

Modifier and Type	Method	Description
Stream	Stream.current(Message current)	Sets/overwrites the currently processed Message.

Uses of Message in com.swiftmq.impl.streams.comp.io

Methods in com.swiftmq.impl.streams.comp.io that return Message

Modifier and Type	Method	Description
Message	Input.current()	Returns the current Message of this Input.
Message	ManagementInput.current()
Message	QueueInput.current()
Message	QueueWireTapInput.current()
Message	TopicInput.current()
Message	QueueWireTapInput.next()	Internal use.

Methods in com.swiftmq.impl.streams.comp.io with parameters of type Message

Modifier and Type	Method	Description
Input	Input.current(Message current)	Sets the current Message on this Input.
Input	ManagementInput.current(Message current)
Input	QueueInput.current(Message current)
Input	QueueWireTapInput.current(Message current)
Input	TopicInput.current(Message current)
Output	Output.send(Message message)	Sends a Message.

Uses of Message in com.swiftmq.impl.streams.comp.memory

Methods in com.swiftmq.impl.streams.comp.memory that return Message

Modifier and Type	Method	Description
Message	HeapMemory.at(int index)
abstract Message	Memory.at(int index)	Returns the Message at the index.
Message	QueueMemory.at(int index)
Message	Memory.first()	Returns the first Message of this Memory.
Message	Memory.last()	Returns the last Message of this Memory.
Message	Memory.max(String propName)	Returns the Message with the maximum value of a Property.
Message	Memory.min(String propName)	Returns the Message with the minimum value of a Property.

Methods in com.swiftmq.impl.streams.comp.memory with parameters of type Message

Modifier and Type	Method	Description
Memory	HeapMemory.add(Message message)
abstract Memory	Memory.add(Message message)	Add a Message to the Memory.
MemoryGroup	MemoryGroup.add(Message message)	Adds a Message to this MemoryGroup.
Memory	QueueMemory.add(Message message)
protected void	Memory.addToIndexes(String key, Message message)
void	ForEachMessageCallback.execute(Message message)	Single method to be executed for each Message of a Memory
protected long	Memory.getStoreTime(Message message)
protected boolean	Memory.isLate(Message message)
protected void	Memory.removeFromIndexes(String key, Message message)

Constructors in com.swiftmq.impl.streams.comp.memory with parameters of type Message

Modifier	Constructor	Description
	Entry(String key, long storeTime, Message message)

Uses of Message in com.swiftmq.impl.streams.comp.message

Subclasses of Message in com.swiftmq.impl.streams.comp.message

Modifier and Type	Class	Description
class	BytesMessage	Facade to wrap a javax.jms.BytesMessage.
class	MapMessage	Facade to wrap a javax.jms.MapMessage
class	ObjectMessage	Facade to wrap a javax.jms.ObjectMessage.
class	StreamMessage	Facade to wrap a javax.jms.StreamMessage.
class	TextMessage	Facade to wrap a javax.jms.TextMessage.

Methods in com.swiftmq.impl.streams.comp.message that return Message

Modifier and Type	Method	Description
Message	Property.clear()	Clears the property value.
Message	Message.clearBody()	Clears the message body.
Message	MessageBuilder.copyMessage(Message msg)	Internal use only.
Message	Message.copyProperties(Message source)	Internal use only.
Message	Message.correlationId(String s)	Sets the JMS correlation ID.
Message	Message.expiration(long exp)	Sets the JMS expiration
Message	MessageBuilder.message()	Returns a new Message facade.
Message	Message.messageId(String s)	Sets the JMS message ID.
Message	Message.nonpersistent()	Marks this Message as non-persistent.
Message	Message.onMessageEnabled(boolean onMessageEnabled)	Can be set to false in an Input callback to disable calling the onMessage Callback with this Message.
Message	Message.persistent()	Marks this Message as persistent.
Message	Message.priority(int prio)	Sets the JMS priority.
Message	Message.replyTo(Destination destination)	Sets the replyTo address
Message	Property.set(Object value)	Sets the value.
Message	Message.timestamp(long timestamp)	Sets the JMS timestamp
Message	MessageBuilder.wrap(MessageImpl impl)	Internal use only.

Methods in com.swiftmq.impl.streams.comp.message with parameters of type Message

Modifier and Type	Method	Description
Message	MessageBuilder.copyMessage(Message msg)	Internal use only.
Message	Message.copyProperties(Message source)	Internal use only.

Constructors in com.swiftmq.impl.streams.comp.message with parameters of type Message

Modifier	Constructor	Description
	Property(Message message, String name, Object value)	Internal use.

Uses of Message in com.swiftmq.impl.streams.processor.po

Methods in com.swiftmq.impl.streams.processor.po that return Message

Modifier and Type	Method	Description
Message	POMgmtMessage.getMessage()
Message	POWireTapMessage.getMessage()

Constructors in com.swiftmq.impl.streams.processor.po with parameters of type Message

Modifier	Constructor	Description
	POMgmtMessage(Semaphore semaphore, ManagementProcessor managementProcessor, Message message)