Documentation
¶
Index ¶
- func DeclareRealtimeExchange(amqpEndpoint string) error
- func DeclareSubscriberQueue(amqpEndpoint string, scope string, topic string, subscriber string) (*amqp.Connection, *amqp.Channel, error)
- func ExchangeNameRealtime() string
- func ExchangeNameTopic(scope string, topic string) string
- func Publish(amqpEndpoint string, body []byte, headers amqp.Table) error
- func QueueNameSubscriber(scope string, topic string, subscriber string) string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeclareRealtimeExchange ¶
func DeclareSubscriberQueue ¶
func ExchangeNameRealtime ¶
func ExchangeNameRealtime() string
func ExchangeNameTopic ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.