public class ClientMessages extends AbstractRequestNot
ClientMessages
instance is used by a client agent for
sending one or many messages to a destination.Modifier and Type | Class and Description |
---|---|
static class |
ClientMessages.Factory |
Modifier and Type | Field and Description |
---|---|
private boolean |
asyncSend |
private Message |
message
Message sent by the client.
|
private List<Message> |
messages
Messages sent by the client.
|
private AgentId |
proxyId |
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 |
---|
ClientMessages()
Constructs a
ClientMessages instance. |
ClientMessages(int clientContext,
int requestId)
Constructs a
ClientMessages instance. |
ClientMessages(int clientContext,
int requestId,
List messages)
Constructs a
ClientMessages instance. |
ClientMessages(int clientContext,
int requestId,
Message message)
Constructs a
ClientMessages instance. |
Modifier and Type | Method and Description |
---|---|
void |
addMessage(Message msg)
Adds a message to deliver.
|
void |
decode(Decoder decoder)
Decodes the object.
|
void |
encode(Encoder encoder)
Encodes the object.
|
boolean |
getAsyncSend() |
AgentId |
getDMQId()
Returns the identifier of the producer's dead message queue, if any.
|
int |
getEncodableClassId()
The class id is still not defined.
|
int |
getEncodedSize()
Returns the size of the encoded object.
|
int |
getMessageCount() |
List |
getMessages()
Returns the messages.
|
AgentId |
getProxyId() |
void |
setAsyncSend(boolean b) |
void |
setDMQId(AgentId dmqId)
Sets the identifier of the producer's dead message queue.
|
void |
setProxyId(AgentId proxyId) |
StringBuffer |
toString(StringBuffer output)
Appends a string image for this object to the StringBuffer parameter.
|
getRequestId
getClientContext, setPersistent
done, failed, hasCallback, passCallback, setCountDownCallback
clone, getContext, getDeadNotificationAgentId, getExpiration, getMessageId, getPriority, isPersistent, setContext, setDeadNotificationAgentId, setExpiration, setPriority, toString
private static final long serialVersionUID
private Message message
private boolean asyncSend
private AgentId proxyId
public ClientMessages(int clientContext, int requestId)
ClientMessages
instance.clientContext
- Identifies a client context.requestId
- Request identifier.public ClientMessages(int clientContext, int requestId, Message message)
ClientMessages
instance.clientContext
- Identifies a client context.requestId
- Request identifier.message
- The message.public ClientMessages(int clientContext, int requestId, List messages)
ClientMessages
instance.clientContext
- Identifies a client context.requestId
- Request identifier.messages
- Vector of messages.public ClientMessages()
ClientMessages
instance.public int getEncodableClassId()
Notification
getEncodableClassId
in interface Encodable
getEncodableClassId
in class Notification
public int getEncodedSize() throws Exception
Notification
getEncodedSize
in interface Encodable
getEncodedSize
in class AbstractRequestNot
Exception
- if an error occurspublic void encode(Encoder encoder) throws Exception
Notification
encode
in interface Encodable
encode
in class AbstractRequestNot
encoder
- the encoderException
- if an error occurspublic void decode(Decoder decoder) throws Exception
Notification
decode
in interface Encodable
decode
in class AbstractRequestNot
decoder
- the encoderException
- if an error occurspublic AgentId getProxyId()
public void setProxyId(AgentId proxyId)
public void addMessage(Message msg)
public void setDMQId(AgentId dmqId)
Notification.setDeadNotificationAgentId(AgentId)
public List getMessages()
public void setAsyncSend(boolean b)
public final boolean getAsyncSend()
public int getMessageCount()
public AgentId getDMQId()
Notification.getDeadNotificationAgentId()
public StringBuffer toString(StringBuffer output)
toString
in class AbstractRequestNot
output
- buffer to fill inoutput
buffer is returnedCopyright © 2018 ScalAgent D.T.. All Rights Reserved.