conf

Documentation

Index

• func NewConsumer(amqpURI, exchange, exchangeType, queue, key, ctag string) error
• func StartListener(appName string, amqpServer string, exchangeName string)
• type Consumer
  • func (c *Consumer) Shutdown() error
• type ResumeConfig
• type UpdateToken

Functions

func NewConsumer

func NewConsumer(amqpURI, exchange, exchangeType, queue, key, ctag string) error

func StartListener

func StartListener(appName string, amqpServer string, exchangeName string)

Types

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

func (*Consumer) Shutdown

func (c *Consumer) Shutdown() error

type ResumeConfig

type ResumeConfig struct {
	Name string
	Age  int
	Sex  string
}

var (
	Resume ResumeConfig
)

type UpdateToken

type UpdateToken struct {
	Type               string `json:"type"`
	Timestamp          int    `json:"timestamp"`
	OriginService      string `json:"originService"`
	DestinationService string `json:"destinationService"`
	Id                 string `json:"id"`
}

{"type":"RefreshRemoteApplicationEvent","timestamp":1494514362123,"originService":"config-server:docker:8888","destinationService":"xxxaccoun:**","id":"53e61c71-cbae-4b6d-84bb-d0dcc0aeb4dc"}