Package org.springframework.cloud.stream.binder

Class AbstractTestBinder<C extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,CP,PP>,CP extends org.springframework.cloud.stream.binder.ConsumerProperties,PP extends org.springframework.cloud.stream.binder.ProducerProperties>

java.lang.Object
org.springframework.cloud.stream.binder.AbstractTestBinder<C,CP,PP>
Type Parameters:
C - binder type
CP - consumer properties type
PP - producer properties type
All Implemented Interfaces:
org.springframework.cloud.stream.binder.Binder<org.springframework.messaging.MessageChannel,CP,PP>
Direct Known Subclasses:
AbstractPollableConsumerTestBinder
public abstract class AbstractTestBinder<C extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,CP,PP>,CP extends org.springframework.cloud.stream.binder.ConsumerProperties,PP extends org.springframework.cloud.stream.binder.ProducerProperties> extends Object implements org.springframework.cloud.stream.binder.Binder<org.springframework.messaging.MessageChannel,CP,PP>
Abstract class that adds test support for Binder.
Author:
Ilayaperumal Gopinathan, Gary Russell, Mark Fisher, Oleg Zhurakousky, Byungjun You

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected Set<String>
    queues
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    AbstractTestBinder()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.springframework.cloud.stream.binder.Binding<org.springframework.messaging.MessageChannel>
    bindConsumer(String name, String group, org.springframework.messaging.MessageChannel moduleInputChannel, CP properties)
     
    org.springframework.cloud.stream.binder.Binding<org.springframework.messaging.MessageChannel>
    bindProducer(String name, org.springframework.messaging.MessageChannel moduleOutputChannel, PP properties)
     
    abstract void
    cleanup()
     
    C
    getBinder()
     
    C
    getCoreBinder()
     
    void
    setBinder(C binder)
     

    Methods inherited from class java.lang.Object

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

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

    getBinderIdentity

  • Field Details

  • Constructor Details

    • AbstractTestBinder

      public AbstractTestBinder()

  • Method Details

    • bindConsumer

      public org.springframework.cloud.stream.binder.Binding<org.springframework.messaging.MessageChannel> bindConsumer(String name, String group, org.springframework.messaging.MessageChannel moduleInputChannel, CP properties)
      Specified by:
      bindConsumer in interface org.springframework.cloud.stream.binder.Binder<C extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,CP,PP>,CP extends org.springframework.cloud.stream.binder.ConsumerProperties,PP extends org.springframework.cloud.stream.binder.ProducerProperties>

    • bindProducer

      public org.springframework.cloud.stream.binder.Binding<org.springframework.messaging.MessageChannel> bindProducer(String name, org.springframework.messaging.MessageChannel moduleOutputChannel, PP properties)
      Specified by:
      bindProducer in interface org.springframework.cloud.stream.binder.Binder<C extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,CP,PP>,CP extends org.springframework.cloud.stream.binder.ConsumerProperties,PP extends org.springframework.cloud.stream.binder.ProducerProperties>

    • getCoreBinder

      public C getCoreBinder()

    • cleanup

      public abstract void cleanup()

    • getBinder

      public C getBinder()

    • setBinder

      public void setBinder(C binder)