Documentation ¶
Overview ¶
Copyright © 2022 NAME HERE <EMAIL ADDRESS>
Copyright © 2022 André Branco Veiga <@__aveiga>
Index ¶
- func Execute()
- func SetupComplexConsumer(client *amqp.MessagingClient, declaration DeclarationJson)
- func SetupComplexProducer(client *amqp.MessagingClient, payload []byte, declaration DeclarationJson)
- func SetupSimpleConsumer(client *amqp.MessagingClient)
- func SetupSimpleProducer(client *amqp.MessagingClient, payload []byte)
- type DeclarationJson
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Execute ¶
func Execute()
Execute adds all child commands to the root command and sets flags appropriately. This is called by main.main(). It only needs to happen once to the rootCmd.
func SetupComplexConsumer ¶
func SetupComplexConsumer(client *amqp.MessagingClient, declaration DeclarationJson)
func SetupComplexProducer ¶
func SetupComplexProducer(client *amqp.MessagingClient, payload []byte, declaration DeclarationJson)
func SetupSimpleConsumer ¶
func SetupSimpleConsumer(client *amqp.MessagingClient)
func SetupSimpleProducer ¶
func SetupSimpleProducer(client *amqp.MessagingClient, payload []byte)
Types ¶
type DeclarationJson ¶
type DeclarationJson struct { ExchangeName string ExchangeType string Durable bool AutoDelete bool Internal bool NoWait bool Arguments []struct { ArgumentKey string ArgumentValue string } Queue struct { QueueName string Durable bool AutoDelete bool Exclusive bool NoWait bool Arguments []struct { ArgumentKey string ArgumentValue string } } }
Click to show internal directories.
Click to hide internal directories.