@UriEndpoint(scheme="netty4", title="Netty4", syntax="netty4:protocol:host:port", consumerClass=NettyConsumer.class, label="networking,tcp,udp") public class NettyEndpoint extends DefaultEndpoint
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
NettyEndpoint(String endpointUri,
NettyComponent component,
NettyConfiguration configuration) |
| Modifier and Type | Method and Description |
|---|---|
Consumer |
createConsumer(Processor processor)
Creates a new Event
Driven Consumer which consumes messages from the endpoint using the
given processor
|
protected String |
createEndpointUri()
A factory method to lazily create the endpointUri if none is specified
|
Exchange |
createExchange(io.netty.channel.ChannelHandlerContext ctx,
Object message) |
Producer |
createProducer()
Creates a new producer which is used send messages into the endpoint
|
protected void |
enrichWithClientCertInformation(SSLSession sslSession,
Message message)
Enriches the message with client certificate details such as subject name, serial number etc.
|
NettyComponent |
getComponent()
Returns the component that created this endpoint.
|
NettyConfiguration |
getConfiguration() |
protected SSLSession |
getSSLSession(io.netty.channel.ChannelHandlerContext ctx) |
boolean |
isSingleton()
Whether this class supports being singleton or not.
|
void |
setConfiguration(NettyConfiguration configuration) |
protected void |
updateMessageHeader(Message in,
io.netty.channel.ChannelHandlerContext ctx) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspendpublic NettyEndpoint(String endpointUri, NettyComponent component, NettyConfiguration configuration)
public Consumer createConsumer(Processor processor) throws Exception
Endpointprocessor - the given processorException - can be thrownpublic Producer createProducer() throws Exception
EndpointException - can be thrownpublic Exchange createExchange(io.netty.channel.ChannelHandlerContext ctx, Object message) throws Exception
Exceptionpublic boolean isSingleton()
IsSingletonpublic NettyComponent getComponent()
DefaultEndpointgetComponent in class DefaultEndpointpublic NettyConfiguration getConfiguration()
public void setConfiguration(NettyConfiguration configuration)
protected String createEndpointUri()
DefaultEndpointcreateEndpointUri in class DefaultEndpointprotected SSLSession getSSLSession(io.netty.channel.ChannelHandlerContext ctx)
protected void updateMessageHeader(Message in, io.netty.channel.ChannelHandlerContext ctx)
protected void enrichWithClientCertInformation(SSLSession sslSession, Message message)
sslSession - the SSL sessionmessage - the message to enrichCopyright © 2007–2015 The Apache Software Foundation. All rights reserved.