Package energy.eddie.outbound.kafka.agnostic

Class PermissionCommandKafkaConnector

java.lang.Object

energy.eddie.outbound.kafka.agnostic.PermissionCommandKafkaConnector

All Implemented Interfaces:

PermissionCommandOutboundConnector

@Component
public class PermissionCommandKafkaConnector
extends Object
implements PermissionCommandOutboundConnector

Constructor Summary

Constructors

Constructor	Description
PermissionCommandKafkaConnector()

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<PermissionCommand>	getPermissionCommands()	A flux of PermissionCommands, to route the permission commands to the correct region-connector.
void	process(PermissionCommand payload)

Methods inherited from class java.lang.Object

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

Constructor Details

PermissionCommandKafkaConnector

public PermissionCommandKafkaConnector()

Method Details

getPermissionCommands

public reactor.core.publisher.Flux<PermissionCommand> getPermissionCommands()

Description copied from interface: PermissionCommandOutboundConnector

A flux of PermissionCommands, to route the permission commands to the correct region-connector.

Specified by:

getPermissionCommands in interface PermissionCommandOutboundConnector

Returns:

Contains the regionConnectorId, the permissionID, the timestamp and additional properties per command action

process

@KafkaListener(groupId="permission-command-group",
               id="eddie-permission-command-listener",
               topics="fw.${outbound-connector.kafka.eddie-id}.agnostic.permission-command",
               containerFactory="permissionCommandListenerContainerFactory")
public void process(@Payload
 PermissionCommand payload)