jazz alternatives and similar packages
Based on the "Messaging" category.
Alternatively, view jazz alternatives based on common mentions on social networks and blogs.
-
Centrifugo
Scalable real-time messaging server in a language-agnostic way. Set up once and forever. -
machinery
Machinery is an asynchronous task queue/job queue based on distributed message passing. -
NATS Go Client
Golang client for NATS, the cloud native messaging system. -
Confluent Kafka Golang Client
Confluent's Apache Kafka Golang client -
Mercure
An open, easy, fast, reliable and battery-efficient solution for real-time communications -
APNs2
⚡ HTTP/2 Apple Push Notification Service (APNs) push provider for Go — Send push notifications to iOS, tvOS, Safari and OSX apps, using the APNs HTTP/2 protocol. -
Uniqush-Push
Uniqush is a free and open source software system which provides a unified push service for server side notification to apps on mobile devices. -
Chanify
Chanify is a safe and simple notification tools. This repository is command line tools for Chanify. -
amqp
An AMQP 0-9-1 Go client maintained by the RabbitMQ team. Originally by @streadway: `streadway/amqp` -
mangos
mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols" -
PingMe
PingMe is a CLI which provides the ability to send messages or alerts to multiple messaging platforms & email. -
emitter
Emits events in Go way, with wildcard, predicates, cancellation possibilities and many other good wins -
Bus
🔊Minimalist message bus implementation for internal communication with zero-allocation magic on Emit -
redisqueue
redisqueue provides a producer and consumer of a queue that uses Redis streams -
go-mq
Declare AMQP entities like queues, producers, and consumers in a declarative way. Can be used to work with RabbitMQ. -
go-events
:mega: Pure nodejs EventEmmiter for the Go Programming Language. -
drone-line
Sending line notifications using a binary, docker or Drone CI. -
RapidMQ
RapidMQ is a pure, extremely productive, lightweight and reliable library for managing of the local messages queue -
Ratus
Ratus is a RESTful asynchronous task queue server. It translated concepts of distributed task queues into a set of resources that conform to REST principles and provides a consistent HTTP API for various backends based on embedded or external storage engines. -
go-notify
Package notify provides an implementation of the Gnome DBus Notifications Specification. -
structured pubsub
Publish and subscribe functionality within a single process in Go. -
go-longpoll
Parked: PubSub queuing with long-polling subscribers (not bound to http)
Clean code begins in your IDE with SonarLint
Do you think we are missing an alternative of jazz or a related project?
README
Jazz
Abstraction layer for quick and simple rabbitMQ connection, messaging and administration. Inspired by Jazz Jackrabbit and his eternal hatred towards slow turtles.
Usage
This library contains three major parts - exchange/queue scheme creation, publishing of messages and consuming of messages. The greatest benefit of this partitioning is that each part might be in separate application. Also due to dedicated administration part, publishing and consuming of messages is simplified to great extent.
Step 1: Connect to rabbit
import(
"github.com/socifi/jazz"
)
var dsn = "amqp://guest:[email protected]:5672/"
func main() {
// ...
c, err := jazz.Connect(dsn)
if err != nil {
t.Errorf("Could not connect to RabbitMQ: %v", err.Error())
return
}
//...
}
Step 2: Create scheme
Scheme specification is done via structure Settings
which can be easily specified in YAML. So generally you need to decode YAML and then create all queues and exchanges
It can be something really crazy like this!
var data = []byte(`
exchanges:
exchange0:
durable: true
type: topic
exchange1:
durable: true
type: topic
bindings:
- exchange: "exchange0"
key: "key1"
- exchange: "exchange0"
key: "key2"
exchange2:
durable: true
type: topic
bindings:
- exchange: "exchange0"
key: "key3"
- exchange: "exchange1"
key: "key2"
exchange3:
durable: true
type: topic
bindings:
- exchange: "exchange0"
key: "key4"
queues:
queue0:
durable: true
bindings:
- exchange: "exchange0"
key: "key4"
queue1:
durable: true
bindings:
- exchange: "exchange1"
key: "key2"
queue2:
durable: true
bindings:
- exchange: "exchange1"
key: "#"
queue3:
durable: true
bindings:
- exchange: "exchange2"
key: "#"
queue4:
durable: true
bindings:
- exchange: "exchange3"
key: "#"
queue5:
durable: true
bindings:
- exchange: "exchange0"
key: "#"
`)
func main() {
// ...
reader := bytes.NewReader(data)
scheme, err := DecodeYaml(reader)
if err != nil {
t.Errorf("Could not read YAML: %v", err.Error())
return
}
err = c.CreateScheme(scheme)
if err != nil {
t.Errorf("Could not create scheme: %v", err.Error())
return
}
//...
// Be nice and delete scheme (Not advisable in ).
err = c.DeleteScheme(scheme)
if err != nil {
t.Errorf("Could not delete scheme: %v", err.Error())
return
}
}
Step 3: Publish and/or consume messages
You can process each queue in separate application or everything together like this:
func main() {
// ...
f := func(msg []byte) {
fmt.Println(string(msg))
}
go c.ProcessQueue("queue1", f)
go c.ProcessQueue("queue2", f)
go c.ProcessQueue("queue3", f)
go c.ProcessQueue("queue4", f)
go c.ProcessQueue("queue5", f)
go c.ProcessQueue("queue6", f)
c.SendMessage("exchange0", "key1", "Hello World!")
c.SendMessage("exchange0", "key2", "Hello!")
c.SendMessage("exchange0", "key3", "World!")
c.SendMessage("exchange0", "key4", "Hi!")
c.SendMessage("exchange0", "key5", "Again!")
//...
}
Notes
No copyright infringement intended. The name Jazz Jackrabbit and artwork of Jazz Jackrabbit is intelectual property of Epic MegaGames and was taken over from wikipedia