Class PubSubConfiguration

java.lang.Object

org.chenile.pubsub.configuration.PubSubConfiguration

@Configuration
public class PubSubConfiguration
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
(package private) String	basePublishTopic
private String	baseSubscribeTopic	This is the base topic name that will pre-pended for all subscriptions.
private boolean	mqttEnabled

Constructor Summary

Constructors

Constructor	Description
PubSubConfiguration()

Method Summary

Modifier and Type	Method	Description
ChenilePubSubInitializer	chenilePubSubInitializer(WildCardsTopic wildCardsTopic)
ExternalApiPublisher	externalApiPublisher(ObjectProvider<ChenilePub> chenilePubProvider, ExternalApiProperties externalApiProperties)
(package private) Map<String,String>	pubSubConfig()	A topic to service map. This map is internally used to route a message that arrives at a topic to a service. This map is populated during the initialization phase. It is used during runtime to invoke the appropriate operation in a service
PubSubEntryPoint	pubSubEntryPoint()
PubSubInfoProvider	pubSubInfoProvider()

Methods inherited from class Object

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

Field Details

basePublishTopic

@Value("${mqtt.publish.base.topic:chenile}")
String basePublishTopic

baseSubscribeTopic

@Value("${mqtt.subscribe.base.topic:chenile}")
private String baseSubscribeTopic

This is the base topic name that will pre-pended for all subscriptions. (default: chenile)

mqttEnabled

@Value("${pubsub.enabled:true}")
private boolean mqttEnabled

Constructor Details

PubSubConfiguration

public PubSubConfiguration()

Method Details

pubSubInfoProvider

@Bean
public PubSubInfoProvider pubSubInfoProvider()

chenilePubSubInitializer

@Bean
public ChenilePubSubInitializer chenilePubSubInitializer(WildCardsTopic wildCardsTopic)

pubSubConfig

@Bean
Map<String,String> pubSubConfig()

A topic to service map.
This map is internally used to route a message that arrives at a topic to a service.
This map is populated during the initialization phase.
It is used during runtime to invoke the appropriate operation in a service

Returns:

a configuration that maps a route to a service.

pubSubEntryPoint

@Bean
public PubSubEntryPoint pubSubEntryPoint()

externalApiPublisher

@Bean
@ConditionalOnBean(ExternalApiProperties.class)
@ConditionalOnMissingBean(ExternalApiPublisher.class)
@ConditionalOnProperty(prefix="chenile.external-api.logging",
                       name="publisher",
                       havingValue="pubsub")
public ExternalApiPublisher externalApiPublisher(ObjectProvider<ChenilePub> chenilePubProvider,
 ExternalApiProperties externalApiProperties)