Class: Deimos::Utils::InlineConsumer

Inherits:
Object
  • Object
show all
Defined in:
sig/defs.rbs

Overview

Class which can process/consume messages inline.

Constant Summary collapse

MAX_MESSAGE_WAIT_TIME =

Returns:

  • (Integer) 

      
        
MAX_TOPIC_WAIT_TIME =
          

  

    

  





  

Returns:


    
  
    
  • 
      
      
        (Integer)
      
      
      
    
    • 
  





        

        

      
    

  







  
    

      Class Method Summary
      collapse
    


    
    
  



  

    
Class Method Details


    
      

  

  
    .consume  ⇒ void 
  

  

  


  

    
This method returns an undefined value.
Consume the last X messages from a topic.


@param topic


@param frk_consumer


@param num_messages — If this number is >= the number of messages in the topic, all messages will be consumed.


  





  
Parameters:


    
  
    
  • 
      
        topic:
      
      
        (String)
      
      
      
    
    • 
  
    
  • 
      
        frk_consumer:
      
      
        (Class)
      
      
      
    
    • 
  
    
  • 
      
        num_messages:
      
      
        (Integer)
      
      
      
    
    • 
  






  

    
      


1145

    		
    
      
# File 'sig/defs.rbs', line 1145

def self.consume: (topic: String, frk_consumer: Class, ?num_messages: Integer) -> void

    		
  





    
      

  

  
    .get_messages_for  ⇒ Object 
  

  

  


  

    
Get the last X messages from a topic. You can specify a subclass of
Deimos::Consumer or Deimos::Producer, or provide the
schema, namespace and key_config directly.


@param topic


@param config_class


@param schema


@param namespace


@param key_config


@param num_messages


  





  



  

    
      


1129

    		
    
      
# File 'sig/defs.rbs', line 1129

def self.get_messages_for: (