Package com.cumulocity.microservice.subscription.service.impl

Class MicroserviceSubscriptionsServiceImpl

java.lang.Object

com.cumulocity.microservice.subscription.service.impl.MicroserviceSubscriptionsServiceImpl

All Implemented Interfaces:

MicroserviceSubscriptionsService

@Service
public class MicroserviceSubscriptionsServiceImpl
extends Object
implements MicroserviceSubscriptionsService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MicroserviceSubscriptionsServiceImpl.MicroserviceChangedListener<T>

Constructor Summary

Constructors

Constructor	Description
MicroserviceSubscriptionsServiceImpl(PlatformProperties properties, org.springframework.context.ApplicationEventPublisher eventPublisher, MicroserviceSubscriptionsRepository repository, MicroserviceMetadataRepresentation microserviceMetadataRepresentation, ContextService<MicroserviceCredentials> contextService)

Method Summary

Modifier and Type	Method	Description
<T> T	callForTenant(String tenant, Callable<T> runnable)	Invokes runnable in context of subscribed tenant.
Collection<MicroserviceCredentials>	getAll()	Gets current microservice subscriptions' credentials
Optional<MicroserviceCredentials>	getCredentials(String tenant)	Gets microservice credentials of the given tenant. NOTE: this method may return stale data if the refreshing subscription process is in progress.
CompletableFuture<Optional<MicroserviceCredentials>>	getCredentialsAsync(String tenant)	Asynchronously gets microservice credentials of the given tenant.
String	getTenant()	Returns current tenant.
boolean	isRegisteredSuccessfully()
void	listen(MicroserviceSubscriptionsServiceImpl.MicroserviceChangedListener listener)
<T> void	listen(Class<T> clazz, MicroserviceSubscriptionsServiceImpl.MicroserviceChangedListener<T> listener)
void	runForEachTenant(Runnable runnable)	Invokes runnable in context of all subscribed tenants.
void	runForTenant(String tenant, Runnable runnable)	Invokes runnable in context of subscribed tenant.
void	subscribe()	Fetches microservice subscriptions and emits MicroserviceSubscriptionRemovedEvent, MicroserviceSubscriptionAddedEvent to the MicroserviceChangedListener listeners

Methods inherited from class java.lang.Object

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

Constructor Details

MicroserviceSubscriptionsServiceImpl

@Autowired
public MicroserviceSubscriptionsServiceImpl(PlatformProperties properties,
 org.springframework.context.ApplicationEventPublisher eventPublisher,
 MicroserviceSubscriptionsRepository repository,
 MicroserviceMetadataRepresentation microserviceMetadataRepresentation,
 ContextService<MicroserviceCredentials> contextService)

Method Details

listen

public void listen(MicroserviceSubscriptionsServiceImpl.MicroserviceChangedListener listener)

listen

public <T> void listen(Class<T> clazz,
 MicroserviceSubscriptionsServiceImpl.MicroserviceChangedListener<T> listener)

subscribe

public void subscribe()

Description copied from interface: MicroserviceSubscriptionsService

Fetches microservice subscriptions and emits MicroserviceSubscriptionRemovedEvent, MicroserviceSubscriptionAddedEvent to the MicroserviceChangedListener listeners

If a listener throws exception during event execution, the event is created again in the next call to the method.

Specified by:

subscribe in interface MicroserviceSubscriptionsService

getAll

public Collection<MicroserviceCredentials> getAll()

Description copied from interface: MicroserviceSubscriptionsService

Gets current microservice subscriptions' credentials

Specified by:

getAll in interface MicroserviceSubscriptionsService

Returns:

collection of microservice credentials

getCredentials

public Optional<MicroserviceCredentials> getCredentials(String tenant)

Description copied from interface: MicroserviceSubscriptionsService

Gets microservice credentials of the given tenant.
NOTE: this method may return stale data if the refreshing subscription process is in progress. Please use MicroserviceSubscriptionsService.getCredentialsAsync(String) to get the most up-to-date credentials.

Specified by:

getCredentials in interface MicroserviceSubscriptionsService

Parameters:

tenant - tenant id

Returns:

Optional.of microservice credentials if tenant is found in current subscriptions; Optional.<MicroserviceCredentials>empty() otherwise

getCredentialsAsync

public CompletableFuture<Optional<MicroserviceCredentials>> getCredentialsAsync(String tenant)

Description copied from interface: MicroserviceSubscriptionsService

Asynchronously gets microservice credentials of the given tenant. Returns a CompletableFuture that will be completed when the subscription process finishes. This method guarantees the most up-to-date credentials, waiting for any ongoing subscription refresh process to complete.

Specified by:

getCredentialsAsync in interface MicroserviceSubscriptionsService

Parameters:

tenant - tenant id

Returns:

CompletableFuture that completes with Optional microservice credentials for the requested tenant

getTenant

public String getTenant()

Description copied from interface: MicroserviceSubscriptionsService

Returns current tenant.

Specified by:

getTenant in interface MicroserviceSubscriptionsService

Returns:

current tenant id

runForEachTenant

public void runForEachTenant(Runnable runnable)

Description copied from interface: MicroserviceSubscriptionsService

Invokes runnable in context of all subscribed tenants.

Specified by:

runForEachTenant in interface MicroserviceSubscriptionsService

Parameters:

runnable - runnable to execute

runForTenant

public void runForTenant(String tenant,
 Runnable runnable)

Description copied from interface: MicroserviceSubscriptionsService

Invokes runnable in context of subscribed tenant.

Specified by:

runForTenant in interface MicroserviceSubscriptionsService

Parameters:

tenant - tenant id

runnable - runnable to execute

callForTenant

public <T> T callForTenant(String tenant,
 Callable<T> runnable)

Description copied from interface: MicroserviceSubscriptionsService

Invokes runnable in context of subscribed tenant.

Specified by:

callForTenant in interface MicroserviceSubscriptionsService

Type Parameters:

T - generic type of expected result object

Parameters:

tenant - tenant id

runnable - callable to execute

Returns:

result object

isRegisteredSuccessfully

public boolean isRegisteredSuccessfully()

Specified by:

isRegisteredSuccessfully in interface MicroserviceSubscriptionsService