org.apache.lucene.replicator.http

Class HttpReplicator

java.lang.Object

org.apache.lucene.replicator.http.HttpClientBase

org.apache.lucene.replicator.http.HttpReplicator

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Replicator

public class HttpReplicator
extends HttpClientBase
implements Replicator

An HTTP implementation of Replicator. Assumes the API supported by ReplicationService.

Field Summary

Fields inherited from class org.apache.lucene.replicator.http.HttpClientBase

DEFAULT_CONNECTION_TIMEOUT, DEFAULT_SO_TIMEOUT, url

Constructor Summary

Constructors

Constructor and Description
HttpReplicator(java.lang.String host, int port, java.lang.String path, org.apache.http.conn.HttpClientConnectionManager conMgr) Construct with specified connection manager.

Method Summary

Modifier and Type	Method and Description
SessionToken	checkForUpdate(java.lang.String currVersion) Check whether the given version is up-to-date and returns a SessionToken which can be used for fetching the revision files, otherwise returns null.
java.io.InputStream	obtainFile(java.lang.String sessionID, java.lang.String source, java.lang.String fileName) Returns an InputStream for the requested file and source in the context of the given session.
void	publish(Revision revision) Publish a new Revision for consumption by clients.
void	release(java.lang.String sessionID) Notify that the specified SessionToken is no longer needed by the caller.

Methods inherited from class org.apache.lucene.replicator.http.HttpClientBase

close, doAction, doAction, ensureOpen, executeGET, executePOST, isClosed, responseInputStream, responseInputStream, throwKnownError, verifyStatus

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

HttpReplicator

public HttpReplicator(java.lang.String host,
                      int port,
                      java.lang.String path,
                      org.apache.http.conn.HttpClientConnectionManager conMgr)

Construct with specified connection manager.

Method Detail

checkForUpdate

public SessionToken checkForUpdate(java.lang.String currVersion)
                            throws java.io.IOException

Description copied from interface: Replicator

Check whether the given version is up-to-date and returns a SessionToken which can be used for fetching the revision files, otherwise returns null.

NOTE: when the returned session token is no longer needed, you should call Replicator.release(String) so that the session resources can be reclaimed, including the revision files.

Specified by:

checkForUpdate in interface Replicator

Throws:

java.io.IOException

obtainFile

public java.io.InputStream obtainFile(java.lang.String sessionID,
                                      java.lang.String source,
                                      java.lang.String fileName)
                               throws java.io.IOException

Description copied from interface: Replicator

Returns an InputStream for the requested file and source in the context of the given session.

NOTE: it is the caller's responsibility to close the returned stream.

Specified by:

obtainFile in interface Replicator

Throws:

SessionExpiredException - if the specified session has already expired

java.io.IOException

publish

public void publish(Revision revision)
             throws java.io.IOException

Description copied from interface: Replicator

Publish a new Revision for consumption by clients. It is the caller's responsibility to verify that the revision files exist and can be read by clients. When the revision is no longer needed, it will be released by the replicator.

Specified by:

publish in interface Replicator

Throws:

java.io.IOException

release

public void release(java.lang.String sessionID)
             throws java.io.IOException

Description copied from interface: Replicator

Notify that the specified SessionToken is no longer needed by the caller.

Specified by:

release in interface Replicator

Throws:

java.io.IOException