org.otfeed.protocol.connector
Class LoginStreamerFactory

java.lang.Object
  org.otfeed.protocol.connector.LoginStreamerFactory

All Implemented Interfaces:

ISessionStreamerFactory

public class LoginStreamerFactory
extends java.lang.Object
implements ISessionStreamerFactory

Constructor Summary

LoginStreamerFactory()

LoginStreamerFactory(IBufferAllocator all)

Method Summary

org.otfeed.protocol.connector.ISessionStreamer	connect()
org.otfeed.protocol.connector.ISessionStreamer	connect(IConnectionStateListener listener) Creates a connection.
long	getConnectTimeoutMillis()
java.util.List<OTHost>	getHostList()
java.lang.String	getPassword()
IStreamerFactory	getStreamerFactory()
java.lang.String	getUsername()
void	setConnectTimeoutMillis(long val)
void	setHostList(java.util.List<OTHost> val)
void	setPassword(java.lang.String val)
void	setStreamerFactory(IStreamerFactory val)
void	setUsername(java.lang.String val)
void	shutdown() Shuts down connection factory.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LoginStreamerFactory

public LoginStreamerFactory(IBufferAllocator all)

LoginStreamerFactory

public LoginStreamerFactory()

Method Detail

getHostList

public java.util.List<OTHost> getHostList()

setHostList

public void setHostList(java.util.List<OTHost> val)

getUsername

public java.lang.String getUsername()

setUsername

public void setUsername(java.lang.String val)

getPassword

public java.lang.String getPassword()

setPassword

public void setPassword(java.lang.String val)

setConnectTimeoutMillis

public void setConnectTimeoutMillis(long val)

getConnectTimeoutMillis

public long getConnectTimeoutMillis()

getStreamerFactory

public IStreamerFactory getStreamerFactory()

setStreamerFactory

public void setStreamerFactory(IStreamerFactory val)

connect

public org.otfeed.protocol.connector.ISessionStreamer connect()
                                                       throws java.io.IOException,
                                                              org.otfeed.protocol.connector.LoginFailureException

Throws:

java.io.IOException

org.otfeed.protocol.connector.LoginFailureException

connect

public org.otfeed.protocol.connector.ISessionStreamer connect(IConnectionStateListener listener)
                                                       throws java.io.IOException,
                                                              org.otfeed.protocol.connector.LoginFailureException

Description copied from interface: ISessionStreamerFactory

Creates a connection. This is an asynchronous call, that will not block. To monitor connection progress, use listener parameter.

Specified by:

connect in interface ISessionStreamerFactory

Parameters:

listener - a listener to receive connection state change events.

Throws:

java.io.IOException

org.otfeed.protocol.connector.LoginFailureException

shutdown

public void shutdown()

Description copied from interface: ISessionStreamerFactory

Shuts down connection factory. If a connect is in progress, it will be interrupted.

Specified by:

shutdown in interface ISessionStreamerFactory