Documentation
¶
Index ¶
- Constants
- type RabbitMqAdapter
- func (a *RabbitMqAdapter) BindQueue(exchange string, routingKey string, queue string) (err error)
- func (a *RabbitMqAdapter) Close() (err error)
- func (a *RabbitMqAdapter) DeclareExchange(name string, kind string, durable bool) (err error)
- func (a *RabbitMqAdapter) DeclareQueue(name string, durable bool) (err error)
- func (a *RabbitMqAdapter) Publish(key string, message []byte) (err error)
- func (a *RabbitMqAdapter) PublishExchange(exchange string, key string, message []byte) (err error)
- func (a *RabbitMqAdapter) Setup() (err error)
- type RabbitMqConfig
Constants ¶
View Source
const ( RabbitMqPublishTimeoutMs = 5000 // TODO: make configurable NotifyChannelSize = 10 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitMqAdapter ¶ added in v0.2.3
type RabbitMqAdapter struct {
*adapter.BaseAdapter
// contains filtered or unexported fields
}
func NewRabbitMqAdapter ¶ added in v0.2.3
func NewRabbitMqAdapter(name string, config *RabbitMqConfig) *RabbitMqAdapter
func (*RabbitMqAdapter) BindQueue ¶ added in v0.3.0
func (a *RabbitMqAdapter) BindQueue(exchange string, routingKey string, queue string) (err error)
func (*RabbitMqAdapter) Close ¶ added in v0.2.3
func (a *RabbitMqAdapter) Close() (err error)
func (*RabbitMqAdapter) DeclareExchange ¶ added in v0.2.3
func (a *RabbitMqAdapter) DeclareExchange(name string, kind string, durable bool) (err error)
func (*RabbitMqAdapter) DeclareQueue ¶ added in v0.2.9
func (a *RabbitMqAdapter) DeclareQueue(name string, durable bool) (err error)
func (*RabbitMqAdapter) Publish ¶ added in v0.2.3
func (a *RabbitMqAdapter) Publish(key string, message []byte) (err error)
func (*RabbitMqAdapter) PublishExchange ¶ added in v0.2.3
func (a *RabbitMqAdapter) PublishExchange(exchange string, key string, message []byte) (err error)
func (*RabbitMqAdapter) Setup ¶ added in v0.2.3
func (a *RabbitMqAdapter) Setup() (err error)
type RabbitMqConfig ¶
type RabbitMqConfig struct {
Host string `json:"Host,omitempty" config:"Host,required"`
Port uint16 `json:"Port,omitempty" config:"Port,required"`
Username string `json:"Username,omitempty" config:"Username"`
Password string `json:"Password,omitempty" config:"Password"`
Exchange string `json:"Exchange,omitempty" config:"Exchange"`
}
Source Files
Click to show internal directories.
Click to hide internal directories.