Class CloseStageQueueRequest
java.lang.Object
com.swiftmq.tools.requestreply.Request
com.swiftmq.impl.routing.single.smqpr.CloseStageQueueRequest
- All Implemented Interfaces:
com.swiftmq.tools.dump.Dumpable, Serializable
public class CloseStageQueueRequest
extends com.swiftmq.tools.requestreply.Request
- See Also:
-
Field Summary
Fields inherited from class com.swiftmq.tools.requestreply.Request
_sem, NO_TIMEOUT -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidaccept(com.swiftmq.tools.requestreply.RequestVisitor visitor) protected com.swiftmq.tools.requestreply.Replyintcom.swiftmq.tools.concurrent.SemaphorevoidsetSemaphore(com.swiftmq.tools.concurrent.Semaphore semaphore) toString()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
-
Constructor Details
-
CloseStageQueueRequest
public CloseStageQueueRequest()
-
-
Method Details
-
getDumpId
public int getDumpId()- Specified by:
getDumpIdin interfacecom.swiftmq.tools.dump.Dumpable- Overrides:
getDumpIdin classcom.swiftmq.tools.requestreply.Request
-
getSemaphore
public com.swiftmq.tools.concurrent.Semaphore getSemaphore() -
setSemaphore
public void setSemaphore(com.swiftmq.tools.concurrent.Semaphore semaphore) -
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
-