Package com.rabbitmq.client.impl

Class AMQImpl.Basic.Consume

java.lang.Object

com.rabbitmq.client.impl.Method

com.rabbitmq.client.impl.AMQImpl.Basic.Consume

All Implemented Interfaces:

AMQP.Basic.Consume, Method

Enclosing class:

AMQImpl.Basic

public static class AMQImpl.Basic.Consume
extends Method
implements AMQP.Basic.Consume

Nested Class Summary

Nested classes/interfaces inherited from interface com.rabbitmq.client.AMQP.Basic.Consume

AMQP.Basic.Consume.Builder

Field Summary

Fields

Modifier and Type	Field	Description
static final int	INDEX

Constructor Summary

Constructors

Constructor	Description
Consume(int ticket, String queue, String consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait, Map<String,Object> arguments)
Consume(MethodArgumentReader rdr)

Method Summary

Modifier and Type	Method	Description
void	appendArgumentDebugStringTo(StringBuilder acc)	Public API - debugging utility
boolean	equals(Object o)
Map<String,Object>	getArguments()
String	getConsumerTag()
boolean	getExclusive()
boolean	getNoAck()
boolean	getNoLocal()
boolean	getNowait()
String	getQueue()
int	getTicket()
boolean	hasContent()	Tell if content is present.
int	hashCode()
int	protocolClassId()	Retrieve the protocol class ID
int	protocolMethodId()	Retrieve the protocol method ID
String	protocolMethodName()	Retrieve the method name
Object	visit(AMQImpl.MethodVisitor visitor)	Visitor support (double-dispatch mechanism).
void	writeArgumentsTo(MethodArgumentWriter writer)	Private API - Autogenerated writer for this method.

Methods inherited from class com.rabbitmq.client.impl.Method

toFrame, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

INDEX

public static final int INDEX

See Also:

• Constant Field Values

Constructor Details

Consume

public Consume(int ticket,
 String queue,
 String consumerTag,
 boolean noLocal,
 boolean noAck,
 boolean exclusive,
 boolean nowait,
 Map<String,Object> arguments)

Consume

public Consume(MethodArgumentReader rdr)
        throws IOException

Throws:

IOException

Method Details

getTicket

public int getTicket()

Specified by:

getTicket in interface AMQP.Basic.Consume

getQueue

public String getQueue()

Specified by:

getQueue in interface AMQP.Basic.Consume

getConsumerTag

public String getConsumerTag()

Specified by:

getConsumerTag in interface AMQP.Basic.Consume

getNoLocal

public boolean getNoLocal()

Specified by:

getNoLocal in interface AMQP.Basic.Consume

getNoAck

public boolean getNoAck()

Specified by:

getNoAck in interface AMQP.Basic.Consume

getExclusive

public boolean getExclusive()

Specified by:

getExclusive in interface AMQP.Basic.Consume

getNowait

public boolean getNowait()

Specified by:

getNowait in interface AMQP.Basic.Consume

getArguments

public Map<String,Object> getArguments()

Specified by:

getArguments in interface AMQP.Basic.Consume

protocolClassId

public int protocolClassId()

Description copied from class: Method

Retrieve the protocol class ID

Specified by:

protocolClassId in interface Method

Specified by:

protocolClassId in class Method

Returns:

the AMQP protocol class ID of this Method

protocolMethodId

public int protocolMethodId()

Description copied from class: Method

Retrieve the protocol method ID

Specified by:

protocolMethodId in interface Method

Specified by:

protocolMethodId in class Method

Returns:

the AMQP protocol method ID of this Method

protocolMethodName

public String protocolMethodName()

Description copied from class: Method

Retrieve the method name

Specified by:

protocolMethodName in interface Method

Specified by:

protocolMethodName in class Method

Returns:

the AMQP protocol method name of this Method

hasContent

public boolean hasContent()

Description copied from class: Method

Tell if content is present.

Specified by:

hasContent in class Method

Returns:

true if the wire-protocol for this method should involve a content header and body, or false if it should just involve a single method frame.

visit

public Object visit(AMQImpl.MethodVisitor visitor)
             throws IOException

Description copied from class: Method

Visitor support (double-dispatch mechanism).

Specified by:

visit in class Method

Parameters:

visitor - the visitor object

Returns:

the result of the "visit" operation

Throws:

IOException - if an error is encountered

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

appendArgumentDebugStringTo

public void appendArgumentDebugStringTo(StringBuilder acc)

Description copied from class: Method

Public API - debugging utility

Overrides:

appendArgumentDebugStringTo in class Method

Parameters:

acc - the buffer to append debug data to

writeArgumentsTo

public void writeArgumentsTo(MethodArgumentWriter writer)
                      throws IOException

Description copied from class: Method

Private API - Autogenerated writer for this method.

Specified by:

writeArgumentsTo in class Method

Parameters:

writer - interface to an object to write the method arguments

Throws:

IOException - if an error is encountered