public final class ProducerMessages extends AbstractJmsRequest
ProducerMessages
instance is sent by a
MessageProducer
when sending messages.Modifier and Type | Field and Description |
---|---|
private boolean |
asyncSend
Indicates whether the produced messages are asynchronously send or not
(without or with an acknowledgement).
|
private Vector |
messages
The wrapped messages.
|
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
requestId, target
ACTIVATE_CONSUMER_REQUEST, ADD_CLIENTID_REPLY, ADD_CLIENTID_REQUEST, classid, classnames, CNX_CLOSE_REPLY, CNX_CLOSE_REQUEST, CNX_CONNECT_REPLY, CNX_CONNECT_REQUEST, CNX_START_REQUEST, CNX_STOP_REQUEST, COMMIT_REQUEST, CONSUMER_ACK_REQUEST, CONSUMER_CLOSE_SUB_REQUEST, CONSUMER_DENY_REQUEST, CONSUMER_MESSAGES, CONSUMER_RECEIVE_REQUEST, CONSUMER_SET_LIST_REQUEST, CONSUMER_SUB_REQUEST, CONSUMER_UNSET_LIST_REQUEST, CONSUMER_UNSUB_REQUEST, GET_ADMIN_TOPIC_REPLY, GET_ADMIN_TOPIC_REQUEST, JMS_REQUEST_GROUP, logger, MOM_EXCEPTION_REPLY, NULL_CLASS_ID, PING_REQUEST, PRODUCER_MESSAGES, QBROWSE_REPLY, QBROWSE_REQUEST, SERVER_REPLY, SESS_ACK_REQUEST, SESS_CREATE_DEST_REPLY, SESS_CREATE_DEST_REQUEST, SESS_DENY_REQUEST, TEMP_DEST_DELETE_REQUEST, XA_CNX_COMMIT, XA_CNX_PREPARE, XA_CNX_RECOVER_REPLY, XA_CNX_RECOVER_REQUEST, XA_CNX_ROLLBACK, XXX_SESS_CREATE_TTREQUEST
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
Constructor and Description |
---|
ProducerMessages()
Constructs a
ProducerMessages instance. |
ProducerMessages(String dest)
Constructs a
ProducerMessages instance. |
ProducerMessages(String dest,
Message msg)
Constructs a
ProducerMessages instance carrying a single
message. |
Modifier and Type | Method and Description |
---|---|
void |
addMessage(Message msg)
Adds a message to deliver.
|
void |
addMessages(Vector msgs)
Adds messages to deliver.
|
void |
decode(Decoder decoder)
Decodes the content of this object
|
void |
encode(Encoder encoder)
Encodes the content of this object
|
boolean |
getAsyncSend() |
protected int |
getClassId() |
int |
getEncodableClassId()
Returns a unique class identifier.
|
int |
getEncodedSize()
Returns the size of the byte array that results
from the encoding of this object.
|
Vector |
getMessages()
Returns the produced messages
|
void |
readFrom(InputStream is)
The object implements the readFrom method to restore its contents from
the input stream.
|
void |
setAsyncSend(boolean b) |
void |
setMessages(Vector newMsgs)
Replace old messages vector by new newMsgs vector
|
void |
toString(StringBuffer strbuf) |
void |
writeTo(OutputStream os)
The object implements the writeTo method to write its contents to
the output stream.
|
getRequestId, getTarget, setRequestId, setTarget, toString
read, readExternal, write, writeExternal
private static final long serialVersionUID
private Vector messages
private boolean asyncSend
public ProducerMessages(String dest)
ProducerMessages
instance.dest
- Name of the destination the messages are sent to.public ProducerMessages(String dest, Message msg)
ProducerMessages
instance carrying a single
message.dest
- Name of the destination the messages are sent to.msg
- Message to carry.public ProducerMessages()
ProducerMessages
instance.public void setAsyncSend(boolean b)
public final boolean getAsyncSend()
public Vector getMessages()
public void addMessage(Message msg)
msg
- The message to add.public void addMessages(Vector msgs)
msgs
- The messages to addpublic void setMessages(Vector newMsgs)
newMsgs
- new messages vector.protected int getClassId()
getClassId
in class AbstractJmsMessage
public void toString(StringBuffer strbuf)
toString
in class AbstractJmsRequest
public void writeTo(OutputStream os) throws IOException
writeTo
in interface Streamable
writeTo
in class AbstractJmsRequest
os
- the stream to write the object toIOException
- an error occurs during IO operation.public void readFrom(InputStream is) throws IOException
readFrom
in interface Streamable
readFrom
in class AbstractJmsRequest
is
- the stream to read data from in order to restore the objectIOException
- an error occurs during IO operation.public int getEncodableClassId()
Encodable
getEncodableClassId
in interface Encodable
getEncodableClassId
in class AbstractJmsRequest
public int getEncodedSize() throws Exception
Encodable
getEncodedSize
in interface Encodable
getEncodedSize
in class AbstractJmsRequest
Exception
- if an error occurspublic void encode(Encoder encoder) throws Exception
Encodable
encode
in interface Encodable
encode
in class AbstractJmsRequest
encoder
- the encoder to be used for the encodingException
- if an error occurspublic void decode(Decoder decoder) throws Exception
Encodable
decode
in interface Encodable
decode
in class AbstractJmsRequest
decoder
- the decoder to be used for the decodingException
- if an error occursCopyright © 2021 ScalAgent D.T.. All rights reserved.