Documentation
¶
Index ¶
- type ChannelClient
- func (t *ChannelClient) CreateChannel(name string)
- func (t *ChannelClient) CreateExchange(name string, typex string)
- func (t *ChannelClient) Name() string
- func (t *ChannelClient) QueueBind(exchange string, key string)
- func (t *ChannelClient) QueueDeclare(name string)
- func (t *ChannelClient) ReceiveMessages()
- func (t *ChannelClient) SendMessage(exchange string)
- func (t *ChannelClient) SendWorkMessage(msg []string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChannelClient ¶
type ChannelClient struct {
Conn *amqp.Connection
Channel *amqp.Channel
Queue amqp.Queue
Durable bool
Exclusive bool // durable
Del_when_used bool // delete when unused
No_wait bool // no-wait
}
func NewChannel ¶
func NewChannel() *ChannelClient
Constructs a new channelClient with the given framing rules
func (*ChannelClient) CreateChannel ¶
func (t *ChannelClient) CreateChannel(name string)
create a channel, which is where most of the API
func (*ChannelClient) CreateExchange ¶
func (t *ChannelClient) CreateExchange(name string, typex string)
* * Available types: direct, topic, headers, fanout * fanout - simple broadcasts all messages it receives to all the queues (good for logger) * direct - simple messaing to queues that binding key match routing_key of message
func (*ChannelClient) Name ¶
func (t *ChannelClient) Name() string
func (*ChannelClient) QueueBind ¶
func (t *ChannelClient) QueueBind(exchange string, key string)
func (*ChannelClient) QueueDeclare ¶
func (t *ChannelClient) QueueDeclare(name string)
func (*ChannelClient) ReceiveMessages ¶
func (t *ChannelClient) ReceiveMessages()
func (*ChannelClient) SendMessage ¶
func (t *ChannelClient) SendMessage(exchange string)
function thats send simple message to named channel (Directly)
func (*ChannelClient) SendWorkMessage ¶
func (t *ChannelClient) SendWorkMessage(msg []string)
Source Files
Click to show internal directories.
Click to hide internal directories.