public final class ConsumerMessages extends AbstractJmsReply
ConsumerMessages
is used by a JMS proxy for sending messages
to a consumer.Modifier and Type | Field and Description |
---|---|
private String |
comingFrom
Name of the subscription or the queue the messages come from.
|
private boolean |
isActive |
private Vector |
messages
Wrapped messages.
|
private boolean |
queueMode
true if the messages come from a queue. |
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
correlationId
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 |
---|
ConsumerMessages()
Constructs an empty
ConsumerMessages instance. |
ConsumerMessages(int correlationId,
Message message,
String comingFrom,
boolean queueMode)
Constructs a
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. |
Modifier and Type | Method and Description |
---|---|
void |
addMessage(Message msg) |
String |
comesFrom()
Returns the name of the queue or the subscription the messages come from.
|
protected int |
getClassId() |
int |
getMessageCount() |
Vector |
getMessages()
Returns the messages to deliver.
|
boolean |
getQueueMode()
Returns
true if the messages come from a queue. |
boolean |
isActive() |
void |
readFrom(InputStream is)
The object implements the readFrom method to restore its contents from
the input stream.
|
void |
setActive(boolean isActive) |
void |
setComesFrom(String comingFrom) |
void |
setMessages(Vector newMsgs)
Replace old messages vector by new newMsgs vector
|
void |
setQueueMode(boolean queueMode) |
void |
toString(StringBuffer strbuf) |
void |
writeTo(OutputStream os)
The object implements the writeTo method to write its contents to
the output stream.
|
decode, encode, getCorrelationId, getEncodableClassId, getEncodedSize, setCorrelationId, toString
read, readExternal, write, writeExternal
private static final long serialVersionUID
private Vector messages
private String comingFrom
private boolean queueMode
true
if the messages come from a queue.private boolean isActive
public ConsumerMessages(int correlationId, Message message, String comingFrom, boolean queueMode)
ConsumerMessages
instance.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.public ConsumerMessages(int correlationId, Vector messages, String comingFrom, boolean queueMode)
ConsumerMessages
instance.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.public ConsumerMessages(int correlationId, String comingFrom, boolean queueMode)
ConsumerMessages
instance.correlationId
- Reply identifier.comingFrom
- Name of the queue or the subscription the reply
comes from.queueMode
- true
if it replies to a queue consumer.public ConsumerMessages()
ConsumerMessages
instance.public Vector getMessages()
public void addMessage(Message msg)
public int getMessageCount()
public void setMessages(Vector newMsgs)
newMsgs
- new messages vector.public String comesFrom()
public void setComesFrom(String comingFrom)
public boolean getQueueMode()
true
if the messages come from a queue.public void setQueueMode(boolean queueMode)
public boolean isActive()
public void setActive(boolean isActive)
isActive
- the isActive to setprotected int getClassId()
getClassId
in class AbstractJmsMessage
public void toString(StringBuffer strbuf)
toString
in class AbstractJmsReply
public void writeTo(OutputStream os) throws IOException
writeTo
in interface Streamable
writeTo
in class AbstractJmsReply
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 AbstractJmsReply
is
- the stream to read data from in order to restore the objectIOException
- an error occurs during IO operation.Copyright © 2021 ScalAgent D.T.. All rights reserved.