Documentation ¶
Index ¶
- type Config
- func (c *Config) Channel() (*amqp.Channel, error)
- func (c *Config) Close() error
- func (c *Config) ConsumerChannel() (*amqp.Channel, *amqp.Connection, error)
- func (c *Config) DeclareSimpleQueue(name string) error
- func (c *Config) GetQueueInfo(queue string) (*amqp.Queue, error)
- func (c *Config) Ping() bool
- func (c *Config) PublishJson(queue string, msg interface{}) error
- func (c *Config) QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (*amqp.Queue, error)
- func (c *Config) ServerStart() error
- type Error
- type QInfo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { MqHost string `json:"Host"` MqPort string `json:"Port"` MqUsername string `json:"Username"` MqPassword string `json:"Password"` // contains filtered or unexported fields }
func InitConfig ¶
func InitConfig() *Config
func (*Config) ConsumerChannel ¶
func (*Config) DeclareSimpleQueue ¶
func (*Config) PublishJson ¶
func (*Config) QueueDeclare ¶
func (*Config) ServerStart ¶
Click to show internal directories.
Click to hide internal directories.