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<Message> |
messages
Vector of messages.
|
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
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<Message> messages)
Constructs a
TopicMsgsReply . |
Modifier and Type | Method and Description |
---|---|
List<Message> |
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
public void setDMQId(AgentId dmqId)
Notification.setDeadNotificationAgentId(AgentId)
Copyright © 2023 ScalAgent D.T.. All rights reserved.