class NettyHttpDatabusBootstrapConnection extends AbstractNettyHttpConnection implements DatabusBootstrapConnection {

  @Override
  public void requestStream(String sourcesIdList, DbusKeyFilter filter,
		  					int freeBufferSpace, Checkpoint cp,
                            DatabusBootstrapConnectionStateMessage stateReuse)
  {
    _checkpoint = cp;
    _callbackStateReuse = stateReuse;
    _sourcesIdList = sourcesIdList;
    _freeBufferSpace = freeBufferSpace;
    _filter = filter;
    _handler = null;

    if (!hasConnection())
    {
      connect(State.STREAM_REQUEST_CONNECT);
    }
    else
    {
      onStreamConnectSuccess();
    }
  }

  public  NettyHttpDatabusBootstrapConnection(ServerInfo server,
                                         ActorMessageQueue callback,
                                         ClientBootstrap bootstrap,
                                         ContainerStatisticsCollector containerStatsCollector,
                                         RemoteExceptionHandler remoteExceptionHandler,
                                         Timer timeoutTimer,
                                         long writeTimeoutMs,
                                         long readTimeoutMs,
                                         int protocolVersion,
                                         ChannelGroup channelGroup);
  public  NettyHttpDatabusBootstrapConnection(ServerInfo relay,
                                             ActorMessageQueue callback,
                                             ChannelFactory channelFactory,
                                             ContainerStatisticsCollector containerStatsCollector,
                                             RemoteExceptionHandler remoteExceptionHandler,
                                             Timer timeoutTimer,
                                             long writeTimeoutMs,
                                             long readTimeoutMs,
                                             int protocolVersion,
                                             ChannelGroup channelGroup);

}