noop

package
v4.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 26, 2026 License: AGPL-3.0 Imports: 2 Imported by: 0

Documentation

Index

Examples

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewConsumer

func NewConsumer() messagequeue.Consumer

NewConsumer returns a no-op Consumer.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL