org.apache.qpid.proton.examples

Class Drain

java.lang.Object

org.apache.qpid.proton.engine.BaseHandler

org.apache.qpid.proton.examples.Drain

All Implemented Interfaces:

CoreHandler, Handler

public class Drain
extends BaseHandler

Constructor Summary

Constructors

Constructor and Description
Drain(int count, boolean block, boolean quiet)

Method Summary

Modifier and Type	Method and Description
static void	main(String[] argv)
void	onConnectionRemoteClose(Event evt)
void	onDelivery(Event evt)
void	onLinkFlow(Event evt)
void	onLinkLocalOpen(Event evt)

Methods inherited from class org.apache.qpid.proton.engine.BaseHandler

add, children, getHandler, getHandler, handle, onConnectionBound, onConnectionFinal, onConnectionInit, onConnectionLocalClose, onConnectionLocalOpen, onConnectionRemoteOpen, onConnectionUnbound, onLinkFinal, onLinkInit, onLinkLocalClose, onLinkLocalDetach, onLinkRemoteClose, onLinkRemoteDetach, onLinkRemoteOpen, onReactorFinal, onReactorInit, onReactorQuiesced, onSelectableError, onSelectableExpired, onSelectableFinal, onSelectableInit, onSelectableReadable, onSelectableUpdated, onSelectableWritable, onSessionFinal, onSessionInit, onSessionLocalClose, onSessionLocalOpen, onSessionRemoteClose, onSessionRemoteOpen, onTimerTask, onTransport, onTransportClosed, onTransportError, onTransportHeadClosed, onTransportTailClosed, onUnhandled, setHandler, setHandler

Methods inherited from class java.lang.Object

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

Constructor Detail

Drain

public Drain(int count,
             boolean block,
             boolean quiet)

Method Detail

onLinkLocalOpen

public void onLinkLocalOpen(Event evt)

Specified by:

onLinkLocalOpen in interface CoreHandler

Overrides:

onLinkLocalOpen in class BaseHandler

onLinkFlow

public void onLinkFlow(Event evt)

Specified by:

onLinkFlow in interface CoreHandler

Overrides:

onLinkFlow in class BaseHandler

onDelivery

public void onDelivery(Event evt)

Specified by:

onDelivery in interface CoreHandler

Overrides:

onDelivery in class BaseHandler

onConnectionRemoteClose

public void onConnectionRemoteClose(Event evt)

Specified by:

onConnectionRemoteClose in interface CoreHandler

Overrides:

onConnectionRemoteClose in class BaseHandler

main

public static void main(String[] argv)
                 throws Exception

Throws:

Exception