org.apache.qpid.transport
Class MessageSubscribe
java.lang.Object
org.apache.qpid.transport.Struct
org.apache.qpid.transport.Method
org.apache.qpid.transport.MessageSubscribe
- All Implemented Interfaces:
- Encodable, ProtocolEvent
public final class MessageSubscribe
- extends Method
Field Summary |
static int |
TYPE
|
Fields inherited from class org.apache.qpid.transport.Struct |
dirty |
Methods inherited from class org.apache.qpid.transport.Method |
complete, create, delegate, getBody, getBodySize, getChannel, getHeader, getId, hasCompletionListener, idSet, isBatch, isSync, isUnreliable, setBatch, setBody, setChannel, setCompletionListener, setHeader, setId, setSync, setUnreliable, toString |
TYPE
public static final int TYPE
- See Also:
- Constant Field Values
MessageSubscribe
public MessageSubscribe()
MessageSubscribe
public MessageSubscribe(String queue,
String destination,
MessageAcceptMode acceptMode,
MessageAcquireMode acquireMode,
String resumeId,
long resumeTtl,
Map<String,Object> arguments,
Option... _options)
getStructType
public final int getStructType()
- Specified by:
getStructType
in class Struct
getSizeWidth
public final int getSizeWidth()
- Specified by:
getSizeWidth
in class Struct
getPackWidth
public final int getPackWidth()
- Specified by:
getPackWidth
in class Struct
hasPayload
public final boolean hasPayload()
- Specified by:
hasPayload
in class Method
getEncodedTrack
public final byte getEncodedTrack()
- Specified by:
getEncodedTrack
in interface ProtocolEvent
- Specified by:
getEncodedTrack
in class Method
dispatch
public <C> void dispatch(C context,
MethodDelegate<C> delegate)
- Specified by:
dispatch
in class Method
hasQueue
public final boolean hasQueue()
clearQueue
public final MessageSubscribe clearQueue()
getQueue
public final String getQueue()
setQueue
public final MessageSubscribe setQueue(String value)
queue
public final MessageSubscribe queue(String value)
hasDestination
public final boolean hasDestination()
clearDestination
public final MessageSubscribe clearDestination()
getDestination
public final String getDestination()
setDestination
public final MessageSubscribe setDestination(String value)
destination
public final MessageSubscribe destination(String value)
hasAcceptMode
public final boolean hasAcceptMode()
clearAcceptMode
public final MessageSubscribe clearAcceptMode()
getAcceptMode
public final MessageAcceptMode getAcceptMode()
setAcceptMode
public final MessageSubscribe setAcceptMode(MessageAcceptMode value)
acceptMode
public final MessageSubscribe acceptMode(MessageAcceptMode value)
hasAcquireMode
public final boolean hasAcquireMode()
clearAcquireMode
public final MessageSubscribe clearAcquireMode()
getAcquireMode
public final MessageAcquireMode getAcquireMode()
setAcquireMode
public final MessageSubscribe setAcquireMode(MessageAcquireMode value)
acquireMode
public final MessageSubscribe acquireMode(MessageAcquireMode value)
hasExclusive
public final boolean hasExclusive()
clearExclusive
public final MessageSubscribe clearExclusive()
getExclusive
public final boolean getExclusive()
setExclusive
public final MessageSubscribe setExclusive(boolean value)
exclusive
public final MessageSubscribe exclusive(boolean value)
hasResumeId
public final boolean hasResumeId()
clearResumeId
public final MessageSubscribe clearResumeId()
getResumeId
public final String getResumeId()
setResumeId
public final MessageSubscribe setResumeId(String value)
resumeId
public final MessageSubscribe resumeId(String value)
hasResumeTtl
public final boolean hasResumeTtl()
clearResumeTtl
public final MessageSubscribe clearResumeTtl()
getResumeTtl
public final long getResumeTtl()
setResumeTtl
public final MessageSubscribe setResumeTtl(long value)
resumeTtl
public final MessageSubscribe resumeTtl(long value)
hasArguments
public final boolean hasArguments()
clearArguments
public final MessageSubscribe clearArguments()
getArguments
public final Map<String,Object> getArguments()
setArguments
public final MessageSubscribe setArguments(Map<String,Object> value)
arguments
public final MessageSubscribe arguments(Map<String,Object> value)
write
public void write(Encoder enc)
- Description copied from interface:
Encodable
- Encodes this encodable using the given encoder.
- Specified by:
write
in interface Encodable
- Specified by:
write
in class Struct
- Parameters:
enc
- the encoder.
read
public void read(Decoder dec)
- Description copied from interface:
Encodable
- Decodes this encodable using the given decoder.
- Specified by:
read
in interface Encodable
- Specified by:
read
in class Struct
- Parameters:
dec
- the decoder.
getFields
public Map<String,Object> getFields()
- Specified by:
getFields
in class Struct
Licensed to the Apache Software Foundation