Documentation ¶
Index ¶
- func Client(body string, connection Connection, queueSetting QueueSetting, ...) (errorResponse error)
- func RPCClient(body string, connection Connection, queueSetting QueueSetting, ...) (response string, errorResponse error)
- func RPCServer(connection Connection, queueSetting QueueSetting, qosSetting QosSetting, ...)
- func Server(connection Connection, queueSetting QueueSetting, ...)
- type AMQPChannel
- type AMQPConnection
- type ActionFunc
- type Connection
- type ConsumeSetting
- type OtherSetting
- type QosSetting
- type QueueSetting
- type RouteFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Client ¶ added in v1.2.0
func Client(body string, connection Connection, queueSetting QueueSetting, otherSetting OtherSetting) (errorResponse error)
func RPCClient ¶
func RPCClient(body string, connection Connection, queueSetting QueueSetting, consumeSetting ConsumeSetting, otherSetting OtherSetting) (response string, errorResponse error)
func RPCServer ¶ added in v1.1.0
func RPCServer(connection Connection, queueSetting QueueSetting, qosSetting QosSetting, consumeSetting ConsumeSetting, otherSetting OtherSetting, routeFunc RouteFunc)
func Server ¶ added in v1.3.0
func Server(connection Connection, queueSetting QueueSetting, consumeSetting ConsumeSetting, actionFunc ActionFunc)
Types ¶
type AMQPChannel ¶ added in v1.1.1
func (*AMQPChannel) Close ¶ added in v1.1.1
func (channel *AMQPChannel) Close() error
func (*AMQPChannel) IsClosed ¶ added in v1.1.1
func (channel *AMQPChannel) IsClosed() bool
type AMQPConnection ¶ added in v1.1.1
type AMQPConnection struct {
*amqp.Connection
}
func Dial ¶ added in v1.1.1
func Dial(url string) (*AMQPConnection, error)
func (*AMQPConnection) Channel ¶ added in v1.1.1
func (connection *AMQPConnection) Channel() (*AMQPChannel, error)
type ActionFunc ¶ added in v1.3.1
type ActionFunc func(string)
type Connection ¶
type Connection struct {
Host, Port, Username, Password, VirtualHost string
}
type ConsumeSetting ¶
type OtherSetting ¶
type QosSetting ¶ added in v1.1.0
type QueueSetting ¶
Click to show internal directories.
Click to hide internal directories.