org.apache.qpid.proton.hawtdispatch.api

Class AmqpReceiver

java.lang.Object

org.apache.qpid.proton.hawtdispatch.impl.WatchBase

org.apache.qpid.proton.hawtdispatch.api.AmqpLink

org.apache.qpid.proton.hawtdispatch.api.AmqpReceiver

public class AmqpReceiver
extends AmqpLink

Author:

Hiram Chirino

Constructor Summary

Constructors

Constructor and Description
AmqpReceiver(AmqpSession parent, Receiver receiver2, QoS qos)

Method Summary

Modifier and Type	Method and Description
protected void	assertExecuting()
protected static void	assertNotOnDispatchQueue()
protected void	attach()
void	close()
protected void	defer(Defer defer)
void	drain()
protected AmqpConnection	getConnection()
AmqpDeliveryListener	getDeliveryListener()
protected Receiver	getEndpoint()
protected AmqpSession	getParent()
Future<ErrorCondition>	getRemoteCloseFuture()
ErrorCondition	getRemoteError()
Future<Void>	getRemoteOpenFuture()
EndpointState	getRemoteState()
protected AmqpTransport	getTransport()
protected void	onMessage(Delivery delivery, org.fusesource.hawtbuf.Buffer buffer)
void	onRemoteClose(Callback<ErrorCondition> cb)
void	onRemoteOpen(Callback<Void> cb)
protected void	processDelivery(Delivery delivery)
protected void	pumpOut()
protected org.fusesource.hawtdispatch.DispatchQueue	queue()
void	resume()
void	setDeliveryListener(AmqpDeliveryListener deliveryListener)
void	suspend()
protected static ErrorCondition	toError(Throwable value)
ErrorCondition	waitForRemoteClose()
void	waitForRemoteOpen()

Methods inherited from class org.apache.qpid.proton.hawtdispatch.impl.WatchBase

addWatch, fireWatches

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AmqpReceiver

public AmqpReceiver(AmqpSession parent,
                    Receiver receiver2,
                    QoS qos)

Method Detail

getEndpoint

protected Receiver getEndpoint()

getParent

protected AmqpSession getParent()

processDelivery

protected void processDelivery(Delivery delivery)

Specified by:

processDelivery in class AmqpLink

onMessage

protected void onMessage(Delivery delivery,
                         org.fusesource.hawtbuf.Buffer buffer)

drain

public void drain()

resume

public void resume()

suspend

public void suspend()

getDeliveryListener

public AmqpDeliveryListener getDeliveryListener()

setDeliveryListener

public void setDeliveryListener(AmqpDeliveryListener deliveryListener)

getConnection

protected AmqpConnection getConnection()

getTransport

protected AmqpTransport getTransport()

queue

protected org.fusesource.hawtdispatch.DispatchQueue queue()

assertExecuting

protected void assertExecuting()

waitForRemoteOpen

public void waitForRemoteOpen()
                       throws Exception

Throws:

Exception

getRemoteOpenFuture

public Future<Void> getRemoteOpenFuture()

onRemoteOpen

public void onRemoteOpen(Callback<Void> cb)

waitForRemoteClose

public ErrorCondition waitForRemoteClose()
                                  throws Exception

Throws:

Exception

getRemoteCloseFuture

public Future<ErrorCondition> getRemoteCloseFuture()

onRemoteClose

public void onRemoteClose(Callback<ErrorCondition> cb)

close

public void close()

getRemoteState

public EndpointState getRemoteState()

getRemoteError

public ErrorCondition getRemoteError()

toError

protected static ErrorCondition toError(Throwable value)

attach

protected void attach()

defer

protected void defer(Defer defer)

pumpOut

protected void pumpOut()

assertNotOnDispatchQueue

protected static void assertNotOnDispatchQueue()