public class TopicMsgsReply extends AbstractReplyNot
TopicMsgsReply
instance is used by a topic for sending
messages to an agent client which subscribed to it.Modifier and Type | Field and Description |
---|---|
private List |
messages
Vector of messages.
|
private static long |
serialVersionUID |
detachable, detached, persistent
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
Constructor and Description |
---|
TopicMsgsReply(List messages)
Constructs a
TopicMsgsReply . |
Modifier and Type | Method and Description |
---|---|
List |
getMessages()
Returns the messages.
|
void |
setDMQId(AgentId dmqId)
Sets the identifier of the producer's dead message queue.
|
getCorrelationId, toString
decode, encode, getClientContext, getEncodedSize, setPersistent
done, failed, hasCallback, passCallback, setCountDownCallback
clone, getContext, getDeadNotificationAgentId, getEncodableClassId, getExpiration, getMessageId, getPriority, isPersistent, setContext, setDeadNotificationAgentId, setExpiration, setPriority, toString
private static final long serialVersionUID
private List messages
public TopicMsgsReply(List messages)
TopicMsgsReply
.messages
- List of delivered messages.public List getMessages()
public void setDMQId(AgentId dmqId)
Notification.setDeadNotificationAgentId(AgentId)
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.