public final class MessageSubscribe extends Method
Method.CompletionListener
Modifier and Type | Field and Description |
---|---|
static int |
TYPE |
Constructor and Description |
---|
MessageSubscribe() |
MessageSubscribe(String queue,
String destination,
MessageAcceptMode acceptMode,
MessageAcquireMode acquireMode,
String resumeId,
long resumeTtl,
Map<String,Object> arguments,
Option... _options) |
complete, create, delegate, getBody, getBodySize, getChannel, getHeader, getId, hasCompletionListener, isBatch, isSync, isUnreliable, setBody, setChannel, setCompletionListener, setHeader, setSync, toString
getEncodedType, isDirty, setDirty
public static final int TYPE
public MessageSubscribe()
public MessageSubscribe(String queue, String destination, MessageAcceptMode acceptMode, MessageAcquireMode acquireMode, String resumeId, long resumeTtl, Map<String,Object> arguments, Option... _options)
public final int getStructType()
getStructType
in class Struct
public final int getSizeWidth()
getSizeWidth
in class Struct
public final int getPackWidth()
getPackWidth
in class Struct
public final boolean hasPayload()
hasPayload
in class Method
public final byte getEncodedTrack()
getEncodedTrack
in interface ProtocolEvent
getEncodedTrack
in class Method
public final boolean isConnectionControl()
public <C> void dispatch(C context, MethodDelegate<C> delegate)
public final boolean hasQueue()
public final MessageSubscribe clearQueue()
public final String getQueue()
public final MessageSubscribe setQueue(String value)
public final MessageSubscribe queue(String value)
public final boolean hasDestination()
public final MessageSubscribe clearDestination()
public final String getDestination()
public final MessageSubscribe setDestination(String value)
public final MessageSubscribe destination(String value)
public final boolean hasAcceptMode()
public final MessageSubscribe clearAcceptMode()
public final MessageAcceptMode getAcceptMode()
public final MessageSubscribe setAcceptMode(MessageAcceptMode value)
public final MessageSubscribe acceptMode(MessageAcceptMode value)
public final boolean hasAcquireMode()
public final MessageSubscribe clearAcquireMode()
public final MessageAcquireMode getAcquireMode()
public final MessageSubscribe setAcquireMode(MessageAcquireMode value)
public final MessageSubscribe acquireMode(MessageAcquireMode value)
public final boolean hasExclusive()
public final MessageSubscribe clearExclusive()
public final boolean getExclusive()
public final MessageSubscribe setExclusive(boolean value)
public final MessageSubscribe exclusive(boolean value)
public final boolean hasResumeId()
public final MessageSubscribe clearResumeId()
public final String getResumeId()
public final MessageSubscribe setResumeId(String value)
public final MessageSubscribe resumeId(String value)
public final boolean hasResumeTtl()
public final MessageSubscribe clearResumeTtl()
public final long getResumeTtl()
public final MessageSubscribe setResumeTtl(long value)
public final MessageSubscribe resumeTtl(long value)
public final boolean hasArguments()
public final MessageSubscribe clearArguments()
public final MessageSubscribe setArguments(Map<String,Object> value)
public final MessageSubscribe arguments(Map<String,Object> value)
public void write(Encoder enc)
Encodable
public void read(Decoder dec)
Encodable
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.