org.lsc.service

Class SyncReplSourceService

java.lang.Object

org.lsc.jndi.AbstractSimpleJndiService

org.lsc.jndi.SimpleJndiSrcService

org.lsc.service.SyncReplSourceService

All Implemented Interfaces:

Closeable, AutoCloseable, IAsynchronousService, IService

public class SyncReplSourceService
extends SimpleJndiSrcService
implements IAsynchronousService, Closeable

You will find there the SyncRepl source service that can attach to a compatible directory to get updates on the fly.

Author:

Sebastien Bahloul <seb@lsc-project.org>

Constructor Summary

Constructors

Constructor and Description
SyncReplSourceService(TaskType task)

Method Summary

Modifier and Type	Method and Description
void	close()
IBean	getBean(String id, LscDatasets pivotAttrs, boolean fromSameService) The simple object getter according to its identifier.
static org.apache.directory.ldap.client.api.LdapAsyncConnection	getConnection(LdapConnectionType ldapConn)
long	getInterval() The delay in milliseconds to look for available updates
Map<String,LscDatasets>	getListPivots() Returns a list of all the objects' identifiers.
Map.Entry<String,LscDatasets>	getNextId() This call is blocking until a data available on the data source
static org.apache.directory.api.ldap.model.message.Control	getSearchContinuationControl(LdapServerType serverType)

Methods inherited from class org.lsc.jndi.SimpleJndiSrcService

getFilterIdClean

Methods inherited from class org.lsc.jndi.AbstractSimpleJndiService

get, getAttrs, getAttrsId, getBaseDn, getBeanFromSR, getFilterAll, getFilterId, getJndiServices

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncReplSourceService

public SyncReplSourceService(TaskType task)
                      throws LscServiceConfigurationException

Throws:

LscServiceConfigurationException

Method Detail

getConnection

public static org.apache.directory.ldap.client.api.LdapAsyncConnection getConnection(LdapConnectionType ldapConn)
                                                                              throws LscServiceConfigurationException

Throws:

LscServiceConfigurationException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractSimpleJndiService

Throws:

IOException

getListPivots

public Map<String,LscDatasets> getListPivots()
                                      throws LscServiceException

Description copied from class: SimpleJndiSrcService

Returns a list of all the objects' identifiers.

Specified by:

getListPivots in interface IService

Overrides:

getListPivots in class SimpleJndiSrcService

Returns:

Map of all entries names that are returned by the directory with an associated map of attribute names and values (never null)

Throws:

LscServiceException

getBean

public IBean getBean(String id,
                     LscDatasets pivotAttrs,
                     boolean fromSameService)
              throws LscServiceException

The simple object getter according to its identifier.

Specified by:

getBean in interface IService

Overrides:

getBean in class SimpleJndiSrcService

Parameters:

id - Name of the entry to be returned, which is the name returned by getListPivots() (used for display only)

pivotAttrs - Map of attribute names and values, which is the data identifier in the source such as returned by getListPivots(). It must identify a unique entry in the source.

fromSameService - are the pivot attributes provided by the same service

Returns:

The bean, or null if not found

Throws:

LscServiceException - May throw a NamingException if the object is not found in the directory, or if more than one object would be returned.

getNextId

public Map.Entry<String,LscDatasets> getNextId()
                                        throws LscServiceException

Description copied from interface: IAsynchronousService

This call is blocking until a data available on the data source

Specified by:

getNextId in interface IAsynchronousService

Returns:

the next available bean

Throws:

LscServiceException

getSearchContinuationControl

public static org.apache.directory.api.ldap.model.message.Control getSearchContinuationControl(LdapServerType serverType)
                                                                                        throws LscServiceConfigurationException

Throws:

LscServiceConfigurationException

getInterval

public long getInterval()

Description copied from interface: IAsynchronousService

The delay in milliseconds to look for available updates

Specified by:

getInterval in interface IAsynchronousService

Returns:

the delay