amqp10

Documentation

Index

• type AMQPSender
  • func NewAMQPSender(urlStr string, debug bool) *AMQPSender
  • func (as *AMQPSender) Close()
  • func (as *AMQPSender) Send(jsonmsg string)
• type AMQPServer
  • func MockAMQPSender(notifier chan string) *AMQPServer
  • func MockAmqpServer(notifier chan string) *AMQPServer
  • func NewAMQPServer(urlStr string, debug bool, msgcount int) *AMQPServer
  • func (s *AMQPServer) Close()
  • func (s *AMQPServer) GetNotifier() chan string
  • func (s *AMQPServer) GetStatus() chan int

Types

type AMQPSender

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

AMQPSender msgcount -1 is infinite

func NewAMQPSender

func NewAMQPSender(urlStr string, debug bool) *AMQPSender

NewAMQPSender ...

func (*AMQPSender) Close

func (as *AMQPSender) Close()

Close connections it is exported so users can force close

func (*AMQPSender) Send

func (as *AMQPSender) Send(jsonmsg string)

Send starts amqp server

type AMQPServer

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

AMQPServer msgcount -1 is infinite

func MockAMQPSender

func MockAMQPSender(notifier chan string) *AMQPServer

MockAMQPSender Create Mock AMQP server

func MockAmqpServer

func MockAmqpServer(notifier chan string) *AMQPServer

MockAmqpServer Create Mock AMQP server

func NewAMQPServer

func NewAMQPServer(urlStr string, debug bool, msgcount int) *AMQPServer

NewAMQPServer ...

func (*AMQPServer) Close

func (s *AMQPServer) Close()

Close connections it is exported so users can force close

func (*AMQPServer) GetNotifier

func (s *AMQPServer) GetNotifier() chan string

GetNotifier Get notifier

func (*AMQPServer) GetStatus

func (s *AMQPServer) GetStatus() chan int

GetStatus Get Status