msgqueue

Documentation

Index

• type Publisher
• type Subscriber

Types

type Publisher

type Publisher interface {
	Publish([]byte) error
}

Publisher is the interface that wraps the basic Publish method.

Publish publishes the message data to the specified queue.

type Subscriber

type Subscriber interface {
	Subscribe(handler.MSGHandlerFunc) error
}

Subscriber is the interface that wraps the basic Subscribe method.

Subscribe opens a connection to the specified queue, and triggers the handler function on each received message data. It is expected to block.