class ClientMessageEventListener extends Object implements I2CPMessageReader.I2CPMessageEventListener
| Modifier and Type | Field and Description |
|---|---|
protected RouterContext | _contextthe router context |
protected ClientConnectionRunner | _runnerthe client connection runner |
| Constructor and Description |
|---|
ClientMessageEventListener(RouterContext context,
ClientConnectionRunner runner,
boolean enforceAuth)Create a new event listener for the given client connection. |
| Modifier and Type | Method and Description |
|---|---|
void | disconnected(I2CPMessageReader reader)Notify the listener that the stream this reader was reading was
closed. |
protected void | handleCreateLeaseSet(CreateLeaseSetMessage message)Handle a CreateLeaseSet message. |
protected void | handleDestLookup(DestLookupMessage message)Handle a DestLookup message. |
protected void | handleGetBWLimits(GetBandwidthLimitsMessage message)Divide router limit by 1.5 for overhead. |
protected void | handleHostLookup(HostLookupMessage message)Handle a HostLookup message. |
void | messageReceived(I2CPMessageReader reader,
I2CPMessage message)Handle an incoming message and dispatch it to the appropriate handler |
void | readError(I2CPMessageReader reader,
Exception error)Handle notification that there was an error |
protected void | startCreateSessionJob(SessionConfig config)Override for testing |
protected final RouterContext _context
protected final ClientConnectionRunner _runner
public ClientMessageEventListener(RouterContext context, ClientConnectionRunner runner, boolean enforceAuth)
context - the router contextrunner - the client connection runnerenforceAuth - set false for in-JVM, true for socket accesspublic void disconnected(I2CPMessageReader reader)
I2CPMessageReader.I2CPMessageEventListenerdisconnected in interface I2CPMessageReader.I2CPMessageEventListenerreader - I2CPMessageReader to notifyprotected void handleCreateLeaseSet(CreateLeaseSetMessage message)
message - the messageprotected void handleDestLookup(DestLookupMessage message)
message - the messageprotected void handleGetBWLimits(GetBandwidthLimitsMessage message)
message - the messageprotected void handleHostLookup(HostLookupMessage message)
message - the messagepublic void messageReceived(I2CPMessageReader reader, I2CPMessage message)
messageReceived in interface I2CPMessageReader.I2CPMessageEventListenerreader - I2CPMessageReader to notifymessage - the I2CPMessagepublic void readError(I2CPMessageReader reader, Exception error)
readError in interface I2CPMessageReader.I2CPMessageEventListenerreader - I2CPMessageReader to notifyerror - Exception that was thrown, non-nullprotected void startCreateSessionJob(SessionConfig config)
config - the session config