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(OTConnectionSpec spec)
org.otfeed.protocol.connector.ISessionStreamer	connect(OTConnectionSpec spec, IConnectionStateListener listener) Creates a connection.
long	getConnectTimeoutMillis()
IStreamerFactory	getStreamerFactory()
void	setConnectTimeoutMillis(long val)
void	setStreamerFactory(IStreamerFactory 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

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(OTConnectionSpec spec)
                                                       throws org.otfeed.protocol.connector.LoginFailureException,
                                                              java.io.IOException

Throws:

org.otfeed.protocol.connector.LoginFailureException

java.io.IOException

connect

public org.otfeed.protocol.connector.ISessionStreamer connect(OTConnectionSpec spec,
                                                              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:

spec - connection specifications.

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