Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewReaderFactory ¶
func NewReaderFactory(config ReaderFactoryConfig) queue.ReaderFactory
NewReaderFactory returns an an AMQP-based implementation of the queue.ReaderFactory interface.
Types ¶
type ReaderFactoryConfig ¶
type ReaderFactoryConfig struct { // Address is the address of the AMQP-based messaging server. Address string // Username is the SASL username to use when connecting to the AMQP-based // messaging server. Username string // Password is the SASL password to use when connection to the AMQP-based // messaging server. Password string }
ReaderFactoryConfig encapsulates details required for connecting an AMQP-based implementation of the queue.ReaderFactory interface to an underlying AMQP-based messaging service.
Click to show internal directories.
Click to hide internal directories.