Package com.swiftmq.jms.smqp.v400
Class ProduceMessageRequest
- java.lang.Object
-
- com.swiftmq.tools.requestreply.Request
-
- com.swiftmq.jms.smqp.v400.ProduceMessageRequest
-
- All Implemented Interfaces:
Dumpable
,java.io.Serializable
public class ProduceMessageRequest extends Request
- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from class com.swiftmq.tools.requestreply.Request
_sem, NO_TIMEOUT
-
-
Constructor Summary
Constructors Constructor Description ProduceMessageRequest(int dispatchId, int queueProducerId, MessageImpl message, boolean replyRequired)
ProduceMessageRequest(int dispatchId, int queueProducerId, MessageImpl message, boolean replyRequired, boolean copyRequired)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
accept(RequestVisitor visitor)
protected Reply
createReplyInstance()
int
getDumpId()
Returns a unique dump id for this object.MessageImpl
getMessage()
int
getQueueProducerId()
void
readContent(java.io.DataInput in)
Read the content of this object from the stream.void
setQueueProducerId(int queueProducerId)
java.lang.String
toString()
void
writeContent(java.io.DataOutput out)
Write the content of this object to the stream.-
Methods inherited from class com.swiftmq.tools.requestreply.Request
createReply, getConnectionId, getCorrelationId, getDispatchId, getValidator, isCancelledByValidator, isDoRetry, isReplyRequired, isWasRetry, setCancelledByValidator, setConnectionId, setCorrelationId, setDispatchId, setDoRetry, setReplyRequired, setValidator
-
-
-
-
Constructor Detail
-
ProduceMessageRequest
public ProduceMessageRequest(int dispatchId, int queueProducerId, MessageImpl message, boolean replyRequired)
-
ProduceMessageRequest
public ProduceMessageRequest(int dispatchId, int queueProducerId, MessageImpl message, boolean replyRequired, boolean copyRequired)
-
-
Method Detail
-
getDumpId
public int getDumpId()
Description copied from interface:Dumpable
Returns a unique dump id for this object.
-
writeContent
public void writeContent(java.io.DataOutput out) throws java.io.IOException
Description copied from interface:Dumpable
Write the content of this object to the stream.- Specified by:
writeContent
in interfaceDumpable
- Overrides:
writeContent
in classRequest
- Parameters:
out
- output stream- Throws:
java.io.IOException
- if an error occurs
-
readContent
public void readContent(java.io.DataInput in) throws java.io.IOException
Description copied from interface:Dumpable
Read the content of this object from the stream.- Specified by:
readContent
in interfaceDumpable
- Overrides:
readContent
in classRequest
- Parameters:
in
- input stream- Throws:
java.io.IOException
- if an error occurs
-
createReplyInstance
protected Reply createReplyInstance()
- Specified by:
createReplyInstance
in classRequest
-
getQueueProducerId
public int getQueueProducerId()
-
setQueueProducerId
public void setQueueProducerId(int queueProducerId)
-
getMessage
public MessageImpl getMessage()
-
accept
public void accept(RequestVisitor visitor)
-
-