public abstract class SaslTransportPlugin extends Object implements ITransportPlugin
Modifier and Type | Class and Description |
---|---|
static class |
SaslTransportPlugin.User |
Modifier and Type | Field and Description |
---|---|
protected Configuration |
login_conf |
Constructor and Description |
---|
SaslTransportPlugin() |
Modifier and Type | Method and Description |
---|---|
org.apache.thrift.server.TServer |
getServer(int port,
org.apache.thrift.TProcessor processor)
Create a server associated with a given port and service handler
|
protected abstract org.apache.thrift.transport.TTransportFactory |
getServerTransportFactory()
All subclass must implement this method
|
void |
prepare(Map storm_conf,
Configuration login_conf)
Invoked once immediately after construction
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect
protected Configuration login_conf
public void prepare(Map storm_conf, Configuration login_conf)
prepare
in interface ITransportPlugin
conf
- Storm configurationlogin_conf
- login configurationpublic org.apache.thrift.server.TServer getServer(int port, org.apache.thrift.TProcessor processor) throws IOException, org.apache.thrift.transport.TTransportException
ITransportPlugin
getServer
in interface ITransportPlugin
port
- listening portprocessor
- service handlerIOException
org.apache.thrift.transport.TTransportException
protected abstract org.apache.thrift.transport.TTransportFactory getServerTransportFactory() throws IOException
IOException
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.