Package tigase.push.fcm

Class FcmHttpV1Provider

java.lang.Object

tigase.push.AbstractProvider

tigase.push.fcm.FcmHttpV1Provider

All Implemented Interfaces:

tigase.kernel.beans.config.ConfigurationChangedAware, IPushProvider, tigase.stats.ComponentStatisticsProvider, tigase.stats.StatisticsProviderIfc

@Bean(name="fcm-http-v1",
      parent=PushNotificationsComponent.class,
      active=false)
public class FcmHttpV1Provider
extends AbstractProvider
implements IPushProvider, tigase.kernel.beans.config.ConfigurationChangedAware

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FcmHttpV1Provider.FcmSecretsChangedEvent

Nested classes/interfaces inherited from interface tigase.push.api.IPushProvider

IPushProvider.Feature

Constructor Summary

Constructors

Constructor	Description
FcmHttpV1Provider()

Method Summary

Modifier and Type	Method	Description
void	beanConfigurationChanged(Collection<String> collection)
protected CompletableFuture<AccessToken>	getCurrentAccessToken()
String	getDescription()
protected Map<String,Object>	preparePayload(INotification notification)
CompletableFuture<String>	pushNotification(IPushSettings.IDevice device, INotification notification)
void	reloadSecrets(FcmHttpV1Provider.FcmSecretsChangedEvent event)
protected CompletableFuture<String>	send(Map<String,Object> fcmNotification)
protected CompletableFuture<String>	sendWithRetry(Map<String,Object> fcmNotification, int tryNo)
void	setServiceAccountContent(String serviceAccountContent)
protected boolean	shouldRetry(Throwable ex)

Methods inherited from class tigase.push.AbstractProvider

everyHour, everyMinute, everySecond, getData, getDataMap, getName, getStatistics, pushFailed, removeData, sendingPush, setData, setUserRepository, unregisterDevice

Methods inherited from class java.lang.Object

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

Methods inherited from interface tigase.stats.ComponentStatisticsProvider

belongsTo

Methods inherited from interface tigase.push.api.IPushProvider

getName, maxPayloadSize, supportedFeatures

Constructor Details

FcmHttpV1Provider

public FcmHttpV1Provider()

Method Details

beanConfigurationChanged

public void beanConfigurationChanged(Collection<String> collection)

Specified by:

beanConfigurationChanged in interface tigase.kernel.beans.config.ConfigurationChangedAware

getDescription

public String getDescription()

Specified by:

getDescription in interface IPushProvider

setServiceAccountContent

public void setServiceAccountContent(String serviceAccountContent)
                              throws tigase.db.TigaseDBException

Throws:

tigase.db.TigaseDBException

getCurrentAccessToken

protected CompletableFuture<AccessToken> getCurrentAccessToken()

pushNotification

public CompletableFuture<String> pushNotification(IPushSettings.IDevice device,
 INotification notification)

Specified by:

pushNotification in interface IPushProvider

Returns:

notification ID as String

sendWithRetry

protected CompletableFuture<String> sendWithRetry(Map<String,Object> fcmNotification,
 int tryNo)

shouldRetry

protected boolean shouldRetry(Throwable ex)

send

protected CompletableFuture<String> send(Map<String,Object> fcmNotification)

preparePayload

protected Map<String,Object> preparePayload(INotification notification)

reloadSecrets

@HandleEvent(filter=remote)
public void reloadSecrets(FcmHttpV1Provider.FcmSecretsChangedEvent event)