nmq

README

nmq

Message Queue based on Redis

See examples

Documentation

Overview

Package nmq provides definition of the NMQ(new message queue) based on Redis

Index

• type Config
• type Consumer
• type Message
• type Queue
  • func New(c *Config) (Queue, error)

Types

type Config

type Config struct {
	RedisAddress  string
	RedisPassword string
	Name          string
	RedisDB       int
}

Config defines configuration for NMQ

type Consumer

type Consumer interface {
	Do(*Message)
}

Consumer provides interface for consumer from queue

type Message

type Message struct {
	// contains filtered or unexported fields
}

Message defined delivered message

type Queue

type Queue interface {
	AddConsumer(string, Consumer) error
	AddChannel(string) error
	Publish(string, interface{}) error
	Start() error
}

Queue defines abstraction for nmq

func New

func New(c *Config) (Queue, error)

New provides initialization of the app