Versions in this module Expand all Collapse all v1 v1.1.3 Feb 23, 2022 v1.1.2 Jan 24, 2022 v1.1.1 Jan 24, 2022 Changes in this version + const Version + var DefaultConnectTimeout = 5 * time.Second + var DefaultQueueName = `qcat` + var DefaultServerAddress = `:17684` + type AMQP struct + AutoAck bool + Autodelete bool + ClientProperties map[string]interface{} + ConnectTimeout time.Duration + Durable bool + ExchangeName string + Exclusive bool + Headers map[string]interface{} + HeartbeatInterval time.Duration + Host string + ID string + Immediate bool + Mandatory bool + Password string + Port int + Prefetch int + PrefetchBytes int + PrefetchGlobal bool + QueueName string + RoutingKey string + TLS *tls.Config + Username string + Vhost string + func NewAMQP(uri string) (*AMQP, error) + func (self *AMQP) Acknowledge(tag uint64) error + func (self *AMQP) Close() error + func (self *AMQP) Connect() error + func (self *AMQP) Err() <-chan error + func (self *AMQP) Publish(data []byte, header MessageHeader) error + func (self *AMQP) PublishJSON(body interface{}, header MessageHeader) error + func (self *AMQP) PublishLines(reader io.Reader, header MessageHeader) error + func (self *AMQP) Receive() <-chan *Message + func (self *AMQP) Reject(tag uint64) error + func (self *AMQP) Requeue(tag uint64) error + func (self *AMQP) Subscribe() error + func (self *AMQP) SubscribeRaw() (<-chan amqp.Delivery, error) + type DeliveryMode int + const Persistent + const Transient + type HttpServer struct + BaseHeader MessageHeader + func NewHttpServer(amqpClient *AMQP) *HttpServer + func (self *HttpServer) ListenAndServe(address string) error + func (self *HttpServer) Respond(w http.ResponseWriter, code int, payload interface{}, err error) + func (self *HttpServer) ServeHTTP(w http.ResponseWriter, req *http.Request) + type Message struct + Body []byte + Header MessageHeader + Timestamp time.Time + func (self *Message) Acknowledge(multiple ...bool) error + func (self *Message) Decode(into interface{}) error + func (self *Message) DeliveryTag() uint64 + func (self *Message) ID() string + func (self *Message) Reject(multiple ...bool) error + func (self *Message) Requeue(multiple ...bool) error + func (self *Message) ShouldAck() bool + type MessageHeader struct + ContentEncoding string + ContentType string + DeliveryMode DeliveryMode + Expiration time.Duration + Headers map[string]interface{} + ID string + Priority int