org.apache.qpid.proton.examples

Class Spout

java.lang.Object

org.apache.qpid.proton.engine.BaseHandler

org.apache.qpid.proton.examples.Spout

All Implemented Interfaces:

CoreHandler, Handler

public class Spout
extends BaseHandler

Constructor Summary

Constructors

Constructor and Description
Spout(int count, 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)

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, onLinkLocalOpen, 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

Spout

public Spout(int count,
             boolean quiet)

Method Detail

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