Package org.localify.data.dispatch

Class GoogleDispatch

java.lang.Object

org.localify.data.dispatch.GoogleDispatch

@Component
public class GoogleDispatch
extends Object

A service for dispatching Google scraping requests.

Constructor Summary

Constructors

Constructor	Description
GoogleDispatch(RabbitSender rabbitSender, com.fasterxml.jackson.databind.ObjectMapper objectMapper, ArtistRepository artistRepository, jakarta.persistence.EntityManager entityManager, EventRepository eventRepository, CityRepository cityRepository)	Constructs a new GoogleDispatch.

Method Summary

Modifier and Type	Method	Description
void	dispatchCitiesGoogle(List<City> cities, int priority)	Dispatches a list of cities to be scraped from Google.
void	queueCitiesUpdatedBefore(Instant time, int limit)	Queues cities that were updated before a certain time.

Methods inherited from class java.lang.Object

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

Constructor Details

GoogleDispatch

public GoogleDispatch(RabbitSender rabbitSender,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 ArtistRepository artistRepository,
 jakarta.persistence.EntityManager entityManager,
 EventRepository eventRepository,
 CityRepository cityRepository)

Constructs a new GoogleDispatch.

Parameters:

rabbitSender - The RabbitMQ sender.

objectMapper - The object mapper.

artistRepository - The artist repository.

entityManager - The entity manager.

eventRepository - The event repository.

cityRepository - The city repository.

Method Details

dispatchCitiesGoogle

@Transactional
public void dispatchCitiesGoogle(List<City> cities,
 int priority)

Dispatches a list of cities to be scraped from Google.

Parameters:

cities - The list of cities to dispatch.

priority - The priority of the message.

queueCitiesUpdatedBefore

@Transactional(propagation=REQUIRES_NEW)
public void queueCitiesUpdatedBefore(Instant time,
 int limit)

Queues cities that were updated before a certain time.

Parameters:

time - The time to check against.

limit - The maximum number of cities to queue.