Documentation
¶
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConsumerProvider ¶
func NewConsumerProvider() messagequeue.ConsumerProvider
NewConsumerProvider returns a no-op ConsumerProvider.
func NewPublisher ¶
func NewPublisher() messagequeue.Publisher
NewPublisher returns a no-op Publisher.
Example ¶
package main
import (
"context"
"fmt"
"github.com/verygoodsoftwarenotvirus/platform/v4/messagequeue/noop"
)
func main() {
pub := noop.NewPublisher()
defer pub.Stop()
err := pub.Publish(context.Background(), map[string]string{"event": "user.created"})
fmt.Println(err)
}
Output: <nil>
func NewPublisherProvider ¶
func NewPublisherProvider() messagequeue.PublisherProvider
NewPublisherProvider returns a no-op PublisherProvider.
Example ¶
package main
import (
"context"
"fmt"
"github.com/verygoodsoftwarenotvirus/platform/v4/messagequeue/noop"
)
func main() {
provider := noop.NewPublisherProvider()
defer provider.Close()
pub, err := provider.ProvidePublisher(context.Background(), "user-events")
if err != nil {
panic(err)
}
fmt.Println(pub != nil)
}
Output: true
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.