amqpsender

Documentation

Index

• func NewMessage(data []byte, props map[string]interface{}) *amqp.Message
• func SendMessages(hostname, port, filename, username, password string, topics []string, num int)
• type EventMessage

Functions

func NewMessage

func NewMessage(data []byte, props map[string]interface{}) *amqp.Message

func SendMessages

func SendMessages(hostname, port, filename, username, password string, topics []string, num int)

SendMessages ....

Types

type EventMessage

type EventMessage struct {
	Payload               map[string]interface{} `json:"payload"`
	ApplicationProperties map[string]interface{} `json:"properties"`
}

EventMessage message bluprint to send to bus