Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for its (0.14 sec)

  1. internal/event/target/amqp.go

    			Headers:      headers,
    			ContentType:  "application/json",
    			DeliveryMode: target.args.DeliveryMode,
    			Body:         data,
    		}); err != nil {
    		return err
    	}
    
    	// check for publisher confirms only if its enabled
    	if target.args.PublisherConfirms {
    		confirmed := <-confirms
    		if !confirmed.Ack {
    			return fmt.Errorf("failed delivery of delivery tag: %d", confirmed.DeliveryTag)
    		}
    	}
    
    	return nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 10K bytes
    - Viewed (0)
Back to top