org.apache.qpid.proton.examples

Class Driver

java.lang.Object

org.apache.qpid.proton.engine.BaseHandler

org.apache.qpid.proton.examples.Driver

All Implemented Interfaces:

CoreHandler, Handler

public class Driver
extends BaseHandler

Driver

Constructor Summary

Constructors

Constructor and Description
Driver(Collector collector, Handler... handlers)

Method Summary

Modifier and Type	Method and Description
void	listen(String host, int port)
void	onConnectionLocalOpen(Event evt)
void	onTransport(Event evt)
void	processEvents()
void	run()

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

add, children, getHandler, getHandler, handle, onConnectionBound, onConnectionFinal, onConnectionInit, onConnectionLocalClose, onConnectionRemoteClose, onConnectionRemoteOpen, onConnectionUnbound, onDelivery, onLinkFinal, onLinkFlow, onLinkInit, onLinkLocalClose, onLinkLocalDetach, onLinkLocalOpen, onLinkRemoteClose, onLinkRemoteDetach, onLinkRemoteOpen, onReactorFinal, onReactorInit, onReactorQuiesced, onSelectableError, onSelectableExpired, onSelectableFinal, onSelectableInit, onSelectableReadable, onSelectableUpdated, onSelectableWritable, onSessionFinal, onSessionInit, onSessionLocalClose, onSessionLocalOpen, onSessionRemoteClose, onSessionRemoteOpen, onTimerTask, 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

Driver

public Driver(Collector collector,
              Handler... handlers)
       throws IOException

Throws:

IOException

Method Detail

listen

public void listen(String host,
                   int port)
            throws IOException

Throws:

IOException

run

public void run()
         throws IOException

Throws:

IOException

processEvents

public void processEvents()

onTransport

public void onTransport(Event evt)

Specified by:

onTransport in interface CoreHandler

Overrides:

onTransport in class BaseHandler

onConnectionLocalOpen

public void onConnectionLocalOpen(Event evt)

Specified by:

onConnectionLocalOpen in interface CoreHandler

Overrides:

onConnectionLocalOpen in class BaseHandler