Package energy.eddie.regionconnector.de.eta.permission.handlers

Class AccountingPointDataHandler

java.lang.Object

energy.eddie.regionconnector.de.eta.permission.handlers.AccountingPointDataHandler

All Implemented Interfaces:

EventHandler<AcceptedEvent>

@Component
public class AccountingPointDataHandler
extends Object
implements EventHandler<AcceptedEvent>

Handles AcceptedEvents for permission requests whose data need is AccountingPointDataNeed. Performs a single-shot fetch against the accounting-point endpoint, publishes the payload to AccountingPointDataStream, and commits the corresponding terminal event.

On 401 the handler attempts one in-flight refresh of the customer's access token using the refresh token persisted on the AcceptedEvent; the refreshed token is held only for the duration of the retry and is not persisted.

Constructor Summary

Constructors

Constructor	Description
AccountingPointDataHandler(EventBus eventBus, DePermissionRequestRepository repository, DataNeedsService dataNeedsService, EtaPlusApiClient apiClient, EtaAuthService authService, AccountingPointDataStream stream, Outbox outbox)

Method Summary

Modifier and Type	Method	Description
void	accept(AcceptedEvent event)	Subscription method for the event bus

Methods inherited from class java.lang.Object

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

Constructor Details

AccountingPointDataHandler

public AccountingPointDataHandler(EventBus eventBus,
 DePermissionRequestRepository repository,
 DataNeedsService dataNeedsService,
 EtaPlusApiClient apiClient,
 EtaAuthService authService,
 AccountingPointDataStream stream,
 Outbox outbox)

Method Details

accept

public void accept(AcceptedEvent event)

Description copied from interface: EventHandler

Subscription method for the event bus

Specified by:

accept in interface EventHandler<AcceptedEvent>

Parameters:

event - event that indicates that a permission request has been changed