@StreamListener(target = Sink.INPUT, condition = "headers['eventType']=='EmployeeTransferredEvent'"

General Discussions
15

This is my current .yml . Please also note that my queue is exclusive.

 spring:  
    cloud: 
      function: 
        definition: myFunction
        routing:
          enabled: true
  
stream:
  poller:
    fixed-delay: 1000
  binders:  
  #This section of the configuration tells the solace binder how to connect to the solace event broker/mesh 
    local-solace:  
      type: solace 
      environment: 
        solace: 
          java: 
         
            
  bindings:  
  #The bindings section is used to define your input and output channels. 
    myFunction-in-0: 
      destination: Test
      routing-expression: headers['System']== 'abc' ? 'myFunction'  
      group: exclusive
     
       
    
  solace: 
  #The solace bindings section allows for solace specific configurations to be applied to a channel. A common example is adding topic subscriptions to a queue as shown below. 
    bindings: 
      myFunction-in-0: 
        consumer: 
          autoBindErrorQueue: false
          provisionDurableQueue: false
          queueNamePrefix: ""
          useFamiliarityInQueueName: false
          useDestinationEncodingInQueueName: false
          useGroupNameInQueueName: false
          queueAdditionalSubscriptions: testing/test1
          queue-access-type: 1