Modifier and Type | Class and Description |
---|---|
class |
ProtocolSessionImpl
Basic implementation of
ProtocolSession |
Modifier and Type | Method and Description |
---|---|
<T extends ProtocolSession> |
ProtocolSession.pushLineHandler(LineHandler<T> overrideCommandHandler)
Put a new line handler in the chain
|
<T extends ProtocolSession> |
ProtocolSessionImpl.pushLineHandler(LineHandler<T> overrideCommandHandler) |
Modifier and Type | Method and Description |
---|---|
ProtocolSession |
Protocol.newSession(ProtocolTransport transport)
Create a new
ProtocolSession for the given ProtocolTransport |
ProtocolSession |
ProtocolImpl.newSession(ProtocolTransport transport) |
Modifier and Type | Method and Description |
---|---|
void |
ProtocolTransport.pushLineHandler(LineHandler<? extends ProtocolSession> overrideCommandHandler,
ProtocolSession session)
Push a
LineHandler in. |
void |
ProtocolTransport.writeResponse(Response response,
ProtocolSession session)
Write the
Response to the ProtocolTransport which will forward it to the connected
peer |
void |
AbstractProtocolTransport.writeResponse(Response response,
ProtocolSession session) |
protected void |
AbstractProtocolTransport.writeResponseToClient(Response response,
ProtocolSession session)
Write the
Response to the client |
protected abstract void |
AbstractProtocolTransport.writeToClient(byte[] bytes,
ProtocolSession session,
boolean startTLS)
Write the given
byte's to the remote peer |
protected abstract void |
AbstractProtocolTransport.writeToClient(InputStream in,
ProtocolSession session,
boolean startTLS)
Write the given
InputStream to the remote peer |
Modifier and Type | Method and Description |
---|---|
void |
ProtocolTransport.pushLineHandler(LineHandler<? extends ProtocolSession> overrideCommandHandler,
ProtocolSession session)
Push a
LineHandler in. |
Modifier and Type | Class and Description |
---|---|
class |
CommandDispatcher<Session extends ProtocolSession>
A CommandDispatcher is responsible to call the right
CommandHandler for a given Command |
interface |
CommandHandler<Session extends ProtocolSession>
Custom command handlers must implement this interface
The command handlers will be Server wide common to all the handlers,
therefore the command handlers must store all the state information
in the Session object
|
interface |
ConnectHandler<Session extends ProtocolSession>
Custom connect handlers must implement this interface
The connect handlers will be server-wide common to all the Handlers ,
therefore the handlers must store all the state information
in the Session object
|
interface |
DisconnectHandler<S extends ProtocolSession>
A
DisconnectHandler will get called once a client gets disconnected from the server |
interface |
LineHandler<Session extends ProtocolSession>
Implementations of this Interface will get called after a full line (terminated with
getLineDelimiter() ) was received. |
class |
MultiLineHandler<S extends ProtocolSession>
A special
LineHandler which will "buffer" the received lines till a point and the push them all at
one to the MultiLineHandler.onLines(ProtocolSession, Collection) method |
interface |
ProtocolHandlerResultHandler<R extends Response,S extends ProtocolSession>
An special
ProtocolHandler which allows to intercept returned Response 's and act on them. |
class |
UnknownCommandHandler<S extends ProtocolSession>
A special
CommandHandler implementation which should be extended by CommandHandler 's which should get called for unknown command. |
Modifier and Type | Method and Description |
---|---|
protected List<CommandHandler<Session>> |
CommandDispatcher.getCommandHandlers(String command,
ProtocolSession session)
Returns all the configured CommandHandlers for the specified command
|
protected void |
CommandHandlerResultLogger.log(ProtocolSession session,
Response response,
String logmessage)
Log the given logmessage
|
Response |
CommandHandlerResultLogger.onResponse(ProtocolSession session,
Response response,
long executionTime,
ProtocolHandler handler) |
Response |
ProtocolHandlerResultHandler.onResponse(ProtocolSession session,
R response,
long executionTime,
ProtocolHandler handler)
Get called when a
Response was returned from the ProtocolHandler |
Constructor and Description |
---|
ContextualLogger(ProtocolSession session,
Logger logger) |
Modifier and Type | Interface and Description |
---|---|
interface |
IMAPSession |
Modifier and Type | Class and Description |
---|---|
class |
LineHandlerUpstreamHandler<S extends ProtocolSession>
ChannelUpstreamHandler implementation which will call a given LineHandler implementation |
Modifier and Type | Method and Description |
---|---|
protected ProtocolSession |
BasicChannelUpstreamHandler.createSession(org.jboss.netty.channel.ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
NettyProtocolTransport.pushLineHandler(LineHandler<? extends ProtocolSession> overrideCommandHandler,
ProtocolSession session) |
protected void |
NettyProtocolTransport.writeToClient(byte[] bytes,
ProtocolSession session,
boolean startTLS) |
protected void |
NettyProtocolTransport.writeToClient(InputStream in,
ProtocolSession session,
boolean startTLS) |
Modifier and Type | Method and Description |
---|---|
void |
NettyProtocolTransport.pushLineHandler(LineHandler<? extends ProtocolSession> overrideCommandHandler,
ProtocolSession session) |
Modifier and Type | Interface and Description |
---|---|
interface |
POP3Session
All the handlers access this interface to communicate with POP3Handler object
|
Modifier and Type | Class and Description |
---|---|
class |
POP3SessionImpl
POP3Session implementation which use Netty |
Modifier and Type | Method and Description |
---|---|
ProtocolSession |
POP3Protocol.newSession(ProtocolTransport transport) |
Modifier and Type | Interface and Description |
---|---|
interface |
SMTPSession
All the handlers access this interface to communicate with
SMTPHandler object
|
Modifier and Type | Class and Description |
---|---|
class |
SMTPSessionImpl
SMTPSession implementation |
Modifier and Type | Method and Description |
---|---|
ProtocolSession |
SMTPProtocol.newSession(ProtocolTransport transport) |
Copyright © 2010-2012 The Apache Software Foundation. All Rights Reserved.