Class PubSubConfiguration

java.lang.Object
org.chenile.pubsub.configuration.PubSubConfiguration
@Configuration public class PubSubConfiguration extends Object

  • 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()