GeoRegisterManager

public class GeoRegisterManager extends RegisterManager

Constructors

GeoRegisterManager

public GeoRegisterManager()

Methods

beforePull

public void beforePull(EntityManager entityManager, ImportMetadata importMetadata)

getBaseEndpoint

public URI getBaseEndpoint()

getChecksumFetcher

protected Communicator getChecksumFetcher()

getConfigurationManager

public GeoConfigurationManager getConfigurationManager()

getDeletionInterface

public URI getDeletionInterface(EntityManager entityManager)

getEventFetcher

protected Communicator getEventFetcher()

getEventInterface

public URI getEventInterface(EntityManager entityManager)

getListChecksumInterface

public URI getListChecksumInterface(String schema, OffsetDateTime from)

getLog

protected Logger getLog()

getObjectMapper

protected ObjectMapper getObjectMapper()

getPlugin

public Plugin getPlugin()

getPullCronSchedule

public String getPullCronSchedule()

getSessionManager

public SessionManager getSessionManager()

init

public void init()

RegisterManager initialization; set up dk.magenta.datafordeler.geo.configuration and source fetcher. We store fetched data in a local cache, so create a random folder for that.

parseEventResponse

protected ItemInputStream<? extends PluginSourceData> parseEventResponse(InputStream rawData, EntityManager entityManager)

pullRawData

public ImportInputStream pullRawData(URI eventInterface, EntityManager entityManager, ImportMetadata importMetadata)

pullsEventsCommonly

public boolean pullsEventsCommonly()

removeDeleted

public void removeDeleted(GeoEntityManager entityManager, ImportMetadata importMetadata)