Package | Description |
---|---|
org.apache.qpid.proton | |
org.apache.qpid.proton.engine | |
org.apache.qpid.proton.example.reactor | |
org.apache.qpid.proton.reactor | |
org.apache.qpid.proton.reactor.impl |
Modifier and Type | Method and Description |
---|---|
static Reactor |
Proton.reactor(Handler... handlers) |
Modifier and Type | Class and Description |
---|---|
class |
BaseHandler
BaseHandler
|
Modifier and Type | Method and Description |
---|---|
Handler |
HandlerException.getHandler() |
static Handler |
BaseHandler.getHandler(Extendable ext) |
static Handler |
BaseHandler.getHandler(Record r) |
Modifier and Type | Method and Description |
---|---|
Iterator<Handler> |
Handler.children() |
Iterator<Handler> |
BaseHandler.children() |
Modifier and Type | Method and Description |
---|---|
void |
Handler.add(Handler child) |
void |
BaseHandler.add(Handler child) |
void |
Event.dispatch(Handler handler) |
static void |
BaseHandler.setHandler(Extendable ext,
Handler handler) |
static void |
BaseHandler.setHandler(Record r,
Handler handler) |
Constructor and Description |
---|
HandlerException(Handler handler,
Throwable cause) |
Modifier and Type | Class and Description |
---|---|
class |
Cat |
class |
Counter |
class |
CountRandomly |
class |
Delegates |
class |
Echo |
class |
GlobalLogger |
class |
GoodbyeWorld |
class |
HelloWorld |
class |
ReactorLogger |
static class |
ReactorLogger.Logger |
class |
Recv |
class |
Scheduling |
class |
Send |
class |
Unhandled |
Constructor and Description |
---|
Delegates(Handler... handlers) |
Modifier and Type | Class and Description |
---|---|
class |
FlowController
A handler that applies flow control to a connection.
|
class |
Handshaker
A handler that mirrors the actions of the remote end of a connection.
|
Modifier and Type | Method and Description |
---|---|
Handler |
Reactor.getGlobalHandler() |
Handler |
Reactor.getHandler() |
Modifier and Type | Method and Description |
---|---|
Acceptor |
Reactor.acceptor(String host,
int port,
Handler handler)
Creates a new acceptor.
|
Connection |
Reactor.connection(Handler handler)
Creates a new out-bound connection.
|
Task |
Reactor.schedule(int delay,
Handler handler)
Schedules execution of a task to take place at some point in the future.
|
void |
Reactor.setGlobalHandler(Handler handler)
Sets a new global handler.
|
void |
Reactor.setHandler(Handler handler)
Sets a new handler, that will receive any events not handled by a child
of the reactor.
|
Modifier and Type | Class and Description |
---|---|
class |
IOHandler |
Modifier and Type | Method and Description |
---|---|
Handler |
ReactorImpl.getGlobalHandler() |
Handler |
ReactorImpl.getHandler() |
Modifier and Type | Method and Description |
---|---|
Acceptor |
ReactorImpl.acceptor(String host,
int port,
Handler handler) |
Connection |
ReactorImpl.connection(Handler handler) |
Task |
ReactorImpl.schedule(int delay,
Handler handler) |
void |
ReactorImpl.setGlobalHandler(Handler handler) |
void |
ReactorImpl.setHandler(Handler handler) |
Constructor and Description |
---|
AcceptorImpl(Reactor reactor,
String host,
int port,
Handler handler) |
Copyright © 2015 The Apache Software Foundation. All rights reserved.