INNER CODE UNIT · Java

NewAssociationPublisher

righettod/poc-graphql · src/main/java/eu/righettod/graphqlpoc/publishers/NewAssociationPublisher.java:23

public class NewAssociationPublisher {

    /**
     * Accessor to business data,
     * will be injected via Spring via the single constructor because BusinessDataRepository is managed by Spring
     */
    private BusinessDataRepository businessDataRepository;

    /** Event publisher*/
    private final Flowable<String> publisher;

    /** Local cache used for the example*/
    private Map<String, String> cacheAssociation = new HashMap<>();

    /**
     * Constructor - Init the publishing of the events
     */
    public NewAssociationPublisher(BusinessDataRepository bDataRepository) {

View source record →