Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultQueueName = `qcat`
View Source
var DefaultServerAddress = `:17684`
Functions ¶
This section is empty.
Types ¶
type AmqpClient ¶
type AmqpClient struct {
ID string
Host string
Port int
Username string
Password string
Vhost string
ExchangeName string
RoutingKey string
QueueName string
Durable bool
Autodelete bool
Exclusive bool
Mandatory bool
Immediate bool
// contains filtered or unexported fields
}
func NewAmqpClient ¶
func NewAmqpClient(uri string) (*AmqpClient, error)
func (*AmqpClient) Close ¶
func (self *AmqpClient) Close() error
func (*AmqpClient) Connect ¶
func (self *AmqpClient) Connect() error
func (*AmqpClient) Publish ¶
func (self *AmqpClient) Publish(reader io.Reader, header MessageHeader) error
func (*AmqpClient) Subscribe ¶
func (self *AmqpClient) Subscribe() (<-chan string, error)
func (*AmqpClient) SubscribeRaw ¶
func (self *AmqpClient) SubscribeRaw() (<-chan amqp.Delivery, error)
type HttpServer ¶
type HttpServer struct {
BaseHeader MessageHeader
// contains filtered or unexported fields
}
func NewHttpServer ¶
func NewHttpServer(amqpClient *AmqpClient) *HttpServer
func (*HttpServer) ListenAndServe ¶
func (self *HttpServer) ListenAndServe(address string) error
func (*HttpServer) Respond ¶
func (self *HttpServer) Respond(w http.ResponseWriter, code int, payload interface{}, err error)
func (*HttpServer) ServeHTTP ¶
func (self *HttpServer) ServeHTTP(w http.ResponseWriter, req *http.Request)
Click to show internal directories.
Click to hide internal directories.