Class ConsulBinder

java.lang.Object
org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel, org.springframework.cloud.stream.binder.ConsumerProperties, org.springframework.cloud.stream.binder.ProducerProperties>
org.springframework.cloud.consul.binder.ConsulBinder
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.cloud.stream.binder.Binder<org.springframework.messaging.MessageChannel, org.springframework.cloud.stream.binder.ConsumerProperties, org.springframework.cloud.stream.binder.ProducerProperties>, org.springframework.context.ApplicationContextAware
public class ConsulBinder extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel, org.springframework.cloud.stream.binder.ConsumerProperties, org.springframework.cloud.stream.binder.ProducerProperties>
Author:
Spencer Gibb

  • Field Summary

    Fields inherited from class org.springframework.cloud.stream.binder.AbstractBinder

    logger

  • Constructor Summary

    Constructors
    Constructor
    Description
    ConsulBinder(EventService eventService)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.springframework.cloud.stream.binder.Binding<org.springframework.messaging.MessageChannel>
    doBindConsumer(String name, String group, org.springframework.messaging.MessageChannel inputChannel, org.springframework.cloud.stream.binder.ConsumerProperties properties)
     
    protected org.springframework.cloud.stream.binder.Binding<org.springframework.messaging.MessageChannel>
    doBindProducer(String name, org.springframework.messaging.MessageChannel channel, org.springframework.cloud.stream.binder.ProducerProperties properties)
     

    Methods inherited from class org.springframework.cloud.stream.binder.AbstractBinder

    afterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildRetryTemplate, constructDLQName, getApplicationContext, getBeanFactory, getBindingServiceProperties, getEvaluationContext, groupedName, onInit, setApplicationContext

    Methods inherited from class Object

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

    Methods inherited from interface org.springframework.cloud.stream.binder.Binder

    getBinderIdentity

  • Constructor Details

    • ConsulBinder

      public ConsulBinder(EventService eventService)

  • Method Details

    • doBindConsumer

      protected org.springframework.cloud.stream.binder.Binding<org.springframework.messaging.MessageChannel> doBindConsumer(String name, String group, org.springframework.messaging.MessageChannel inputChannel, org.springframework.cloud.stream.binder.ConsumerProperties properties)
      Specified by:
      doBindConsumer in class org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel, org.springframework.cloud.stream.binder.ConsumerProperties, org.springframework.cloud.stream.binder.ProducerProperties>

    • doBindProducer

      protected org.springframework.cloud.stream.binder.Binding<org.springframework.messaging.MessageChannel> doBindProducer(String name, org.springframework.messaging.MessageChannel channel, org.springframework.cloud.stream.binder.ProducerProperties properties)
      Specified by:
      doBindProducer in class org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel, org.springframework.cloud.stream.binder.ConsumerProperties, org.springframework.cloud.stream.binder.ProducerProperties>