Documentation ¶
Index ¶
- Variables
- func SendRequest(queue string, data interface{}) (*reply.Reply, error)
- type IMessagingClient
- type MessagingClient
- func (m *MessagingClient) Close()
- func (m *MessagingClient) ConnectToBroker(connectionString string)
- func (m *MessagingClient) Publish(body []byte, exchangeName string, exchangeType string) error
- func (m *MessagingClient) PublishOnQueue(body []byte, queueName string) error
- func (m *MessagingClient) PublishOnQueueWaitReply(body []byte, queueName string) ([]byte, error)
- func (m *MessagingClient) Subscribe(exchangeName string, exchangeType string, consumerName string, ...) error
- func (m *MessagingClient) SubscribeToQueue(queueName string, consumerName string, handlerFunc func(amqp.Delivery)) error
- func (m *MessagingClient) SubscribeToQueueAndReply(queueName string, consumerName string, handlerFunc func(amqp.Delivery) []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var TimeEX error = fmt.Errorf("time exceed")
Functions ¶
Types ¶
type IMessagingClient ¶
type IMessagingClient interface { ConnectToBroker(connectionString string) Publish(msg []byte, exchangeName string, exchangeType string) error PublishOnQueue(msg []byte, queueName string) error PublishOnQueueWaitReply(msg []byte, queueName string) ([]byte, error) Subscribe(exchangeName string, exchangeType string, consumerName string, handlerFunc func(amqp.Delivery)) error SubscribeToQueue(queueName string, consumerName string, handlerFunc func(amqp.Delivery)) error SubscribeToQueueAndReply(queueName string, consumerName string, handlerFunc func(amqp.Delivery) []byte) error Close() }
Defines our interface for connecting and consuming messages.
var Client IMessagingClient
type MessagingClient ¶
type MessagingClient struct {
// contains filtered or unexported fields
}
Real implementation, encapsulates a pointer to an amqp.Connection
func (*MessagingClient) Close ¶
func (m *MessagingClient) Close()
func (*MessagingClient) ConnectToBroker ¶
func (m *MessagingClient) ConnectToBroker(connectionString string)
func (*MessagingClient) Publish ¶
func (m *MessagingClient) Publish(body []byte, exchangeName string, exchangeType string) error
func (*MessagingClient) PublishOnQueue ¶
func (m *MessagingClient) PublishOnQueue(body []byte, queueName string) error
func (*MessagingClient) PublishOnQueueWaitReply ¶
func (m *MessagingClient) PublishOnQueueWaitReply(body []byte, queueName string) ([]byte, error)
func (*MessagingClient) SubscribeToQueue ¶
func (*MessagingClient) SubscribeToQueueAndReply ¶
Click to show internal directories.
Click to hide internal directories.