GeoEntityManager¶

public abstract class GeoEntityManager<E extends GeoEntity, T extends RawData> extends EntityManager¶

Fields¶

geoConfigurationManager¶

GeoConfigurationManager geoConfigurationManager¶

log¶

protected Logger log¶

timer¶

Stopwatch timer¶

Constructors¶

GeoEntityManager¶

public GeoEntityManager()¶

Methods¶

createBasicEntity¶

protected abstract E createBasicEntity(T record, Session session)¶

filter¶

protected boolean filter(JsonNode record, ObjectNode importConfiguration)¶

generateUUID¶

protected abstract UUID generateUUID(T rawData)¶

getBaseEndpoint¶

public URI getBaseEndpoint()¶

getBaseName¶

protected abstract String getBaseName()¶

getConfiguration¶

protected GeoConfiguration getConfiguration()¶

getCustomerId¶

public int getCustomerId()¶

getDomain¶

public abstract String getDomain()¶

getEntityClass¶

protected abstract Class<E> getEntityClass()¶

getHandledURISubstrings¶

public Collection<String> getHandledURISubstrings()¶

getJobId¶

public int getJobId()¶

getListChecksumInterface¶

protected URI getListChecksumInterface(OffsetDateTime offsetDateTime)¶

getLocalSubscriptionFolder¶

public String getLocalSubscriptionFolder()¶

getLog¶

protected Logger getLog()¶

getObjectMapper¶

protected ObjectMapper getObjectMapper()¶

getRawClass¶

protected abstract Class<T> getRawClass()¶

getReceiptEndpoint¶

protected URI getReceiptEndpoint(Receipt receipt)¶

getReceiptSender¶

protected Communicator getReceiptSender()¶

getRegisterManager¶

public GeoRegisterManager getRegisterManager()¶

getRegistrationFetcher¶

protected Communicator getRegistrationFetcher()¶

getRegistrationInterface¶

public URI getRegistrationInterface(RegistrationReference reference)¶

handlesOwnSaves¶

public boolean handlesOwnSaves()¶

isSetupSubscriptionEnabled¶

public boolean isSetupSubscriptionEnabled()¶

parseChecksumResponse¶

protected ItemInputStream<? extends EntityReference> parseChecksumResponse(InputStream responseContent)¶

parseData¶

public List<? extends Registration> parseData(InputStream jsonData, ImportMetadata importMetadata)¶

parseDeletionData¶

public void parseDeletionData(InputStream jsonData)¶

parseJsonStream¶

public static long parseJsonStream(String jsonData, String searchKey, ObjectMapper objectMapper, Consumer<JsonNode> callback)¶

parseJsonStream¶

public static long parseJsonStream(InputStream jsonData, Charset charset, String searchKey, ObjectMapper objectMapper, Consumer<JsonNode> callback)¶

parseReference¶

public RegistrationReference parseReference(InputStream referenceData)¶

parseReference¶

public RegistrationReference parseReference(String referenceData, String charsetName)¶

parseReference¶

public RegistrationReference parseReference(URI uri)¶

pullEnabled¶

public boolean pullEnabled()¶: Should return whether the configuration is set so that pulls are enabled for this entitymanager

setRegisterManager¶

public void setRegisterManager(RegisterManager registerManager)¶

updateEntity¶

protected void updateEntity(E entity, T rawData, ImportMetadata importMetadata)¶