public static class AMQP.Basic.Consume extends AbstractMarshallingMethod
Modifier and Type | Field and Description |
---|---|
Map |
arguments
A set of arguments for the consume.
|
String |
consumerTag
Specifies the identifier for the consumer.
|
boolean |
exclusive
Request exclusive consumer access, meaning only this consumer can
access the queue.
|
static int |
INDEX |
boolean |
noAck |
boolean |
noLocal |
boolean |
noWait |
String |
queue
Specifies the name of the queue to consume from.
|
int |
reserved1 |
private static long |
serialVersionUID |
channelNumber, logger
Constructor and Description |
---|
AMQP.Basic.Consume() |
AMQP.Basic.Consume(int reserved1,
String queue,
String consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean noWait,
Map arguments)
This method asks the server to start a "consumer", which is a transient
request for messages from a specific queue.
|
Modifier and Type | Method and Description |
---|---|
int |
getClassId() |
String |
getClassName() |
int |
getMethodId() |
String |
getMethodName() |
void |
readFrom(AMQPInputStream in) |
String |
toString() |
void |
writeTo(AMQPOutputStream out) |
read, toFrame
private static final long serialVersionUID
public int reserved1
public String queue
public String consumerTag
public boolean noLocal
public boolean noAck
public boolean exclusive
public boolean noWait
public Map arguments
public static final int INDEX
public AMQP.Basic.Consume(int reserved1, String queue, String consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean noWait, Map arguments)
public AMQP.Basic.Consume()
public int getMethodId()
getMethodId
in class AbstractMarshallingMethod
public String getMethodName()
getMethodName
in class AbstractMarshallingMethod
public int getClassId()
getClassId
in class AbstractMarshallingMethod
public String getClassName()
getClassName
in class AbstractMarshallingMethod
public void readFrom(AMQPInputStream in) throws IOException, SyntaxErrorException
readFrom
in class AbstractMarshallingMethod
IOException
SyntaxErrorException
public void writeTo(AMQPOutputStream out) throws IOException
writeTo
in class AbstractMarshallingMethod
IOException
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.