Class DeliveryRequest
java.lang.Object
com.swiftmq.tools.requestreply.Request
com.swiftmq.impl.routing.single.smqpr.DeliveryRequest
- All Implemented Interfaces:
com.swiftmq.tools.dump.Dumpable, Serializable
public class DeliveryRequest
extends com.swiftmq.tools.requestreply.Request
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptioncom.swiftmq.swiftlet.queue.MessageEntry[]intcom.swiftmq.swiftlet.queue.QueuePullTransactioncom.swiftmq.swiftlet.queue.QueueReceiverFields inherited from class com.swiftmq.tools.requestreply.Request
_sem, NO_TIMEOUT -
Constructor Summary
ConstructorsConstructorDescriptionDeliveryRequest(String destinationRouter, com.swiftmq.swiftlet.queue.QueueReceiver receiver, com.swiftmq.swiftlet.queue.QueuePullTransaction readTransaction, com.swiftmq.swiftlet.queue.MessageEntry[] entries, int len, DeliveryCallback callback) -
Method Summary
Methods inherited from class com.swiftmq.tools.requestreply.Request
createReply, getConnectionId, getCorrelationId, getDispatchId, getValidator, isCancelledByValidator, isDoRetry, isReplyRequired, isWasRetry, readContent, setCancelledByValidator, setConnectionId, setCorrelationId, setDispatchId, setDoRetry, setReplyRequired, setValidator, writeContent
-
Field Details
-
destinationRouter
-
receiver
public com.swiftmq.swiftlet.queue.QueueReceiver receiver -
readTransaction
public com.swiftmq.swiftlet.queue.QueuePullTransaction readTransaction -
entries
public com.swiftmq.swiftlet.queue.MessageEntry[] entries -
len
public int len -
callback
-
-
Constructor Details
-
DeliveryRequest
public DeliveryRequest(String destinationRouter, com.swiftmq.swiftlet.queue.QueueReceiver receiver, com.swiftmq.swiftlet.queue.QueuePullTransaction readTransaction, com.swiftmq.swiftlet.queue.MessageEntry[] entries, int len, DeliveryCallback callback) -
DeliveryRequest
public DeliveryRequest()
-
-
Method Details
-
getDumpId
public int getDumpId()- Specified by:
getDumpIdin interfacecom.swiftmq.tools.dump.Dumpable- Overrides:
getDumpIdin classcom.swiftmq.tools.requestreply.Request
-
createReplyInstance
protected com.swiftmq.tools.requestreply.Reply createReplyInstance()- Specified by:
createReplyInstancein classcom.swiftmq.tools.requestreply.Request
-
accept
public void accept(com.swiftmq.tools.requestreply.RequestVisitor visitor) - Specified by:
acceptin classcom.swiftmq.tools.requestreply.Request
-
toString
- Overrides:
toStringin classcom.swiftmq.tools.requestreply.Request
-