org.objectweb.joram.shared.client

Class ConsumerMessages

Implemented Interfaces:
java.io.Serializable

public class ConsumerMessages
extends AbstractJmsReply

A ConsumerMessages is used by a JMS proxy for sending messages to a consumer.

See Also:
Serialized Form

Field Summary

Fields inherited from class org.objectweb.joram.shared.client.AbstractJmsReply

correlationId

Constructor Summary

ConsumerMessages()
Constructs an empty ConsumerMessages instance.
ConsumerMessages(int correlationId, String comingFrom, boolean queueMode)
Constructs an empty ConsumerMessages instance.
ConsumerMessages(int correlationId, Vector messages, String comingFrom, boolean queueMode)
Constructs a ConsumerMessages instance.
ConsumerMessages(int correlationId, Message message, String comingFrom, boolean queueMode)
Constructs a ConsumerMessages instance.

Method Summary

void
addMessage(Message msg)
String
comesFrom()
Returns the name of the queue or the subscription the messages come from.
Message
getMessage()
Returns the first sent message.
Vector
getMessages()
Returns the messages to deliver.
boolean
getQueueMode()
Returns true if the messages come from a queue.
void
setComesFrom(String comingFrom)
void
setMessage(Message msg)
void
setQueueMode(boolean queueMode)
Hashtable
soapCode()
Transforms this reply into a hashtable of primitive values that can be vehiculated through the SOAP protocol.
static Object
soapDecode(Hashtable h)
Transforms a hashtable of primitive values into a ConsumerMessages reply.
String
toString()

Methods inherited from class org.objectweb.joram.shared.client.AbstractJmsReply

getCorrelationId, getKey, setCorrelationId, soapCode, soapDecode, toString

Constructor Details

ConsumerMessages

public ConsumerMessages()
Constructs an empty ConsumerMessages instance.


ConsumerMessages

public ConsumerMessages(int correlationId,
                        String comingFrom,
                        boolean queueMode)
Constructs an empty ConsumerMessages instance.

Parameters:
correlationId - Reply identifier.
comingFrom - Name of the queue or the subscription the reply comes from.
queueMode - true if it replies to a queue consumer.


ConsumerMessages

public ConsumerMessages(int correlationId,
                        Vector messages,
                        String comingFrom,
                        boolean queueMode)
Constructs a ConsumerMessages instance.

Parameters:
correlationId - Reply identifier.
messages - Messages to wrap.
comingFrom - Name of the queue or the subscription the messages comes from.
queueMode - true if the messages come from a queue.


ConsumerMessages

public ConsumerMessages(int correlationId,
                        Message message,
                        String comingFrom,
                        boolean queueMode)
Constructs a ConsumerMessages instance.

Parameters:
correlationId - Reply identifier.
message - Message to wrap.
comingFrom - Name of the queue or the subscription the message come from.
queueMode - true if the message come from a queue.

Method Details

addMessage

public void addMessage(Message msg)


comesFrom

public String comesFrom()
Returns the name of the queue or the subscription the messages come from.


getMessage

public Message getMessage()
Returns the first sent message.


getMessages

public Vector getMessages()
Returns the messages to deliver.


getQueueMode

public boolean getQueueMode()
Returns true if the messages come from a queue.


setComesFrom

public void setComesFrom(String comingFrom)


setMessage

public void setMessage(Message msg)


setQueueMode

public void setQueueMode(boolean queueMode)


soapCode

public Hashtable soapCode()
Transforms this reply into a hashtable of primitive values that can be vehiculated through the SOAP protocol.
Overrides:
soapCode in interface AbstractJmsReply


soapDecode

public static Object soapDecode(Hashtable h)
Transforms a hashtable of primitive values into a ConsumerMessages reply.
Overrides:
soapDecode in interface AbstractJmsReply


toString

public String toString()
Overrides:
toString in interface AbstractJmsReply


Copyright B) 2004 Scalagent - All rights reserved