mq

Implementations

Support these message queues:

Please make sure to initialize a Go module before installing core-go/mq:

go get -u github.com/core-go/mq

Import:

import "github.com/core-go/mq"

Build for confluent:

go build -buildmode=exe main.go

Consume a message from queue, then write the message to database (SQL, Mongo, Casandra, Dynamodb, Firestore, Elasticsearch)
Support these databases
- SQL
- Mongo
- Casandra
- Dynamodb
- Firestore
- Elasticsearch

Name		Name	Last commit message	Last commit date
Latest commit History 113 Commits
activemq		activemq
audit		audit
avro		avro
cassandra		cassandra
config		config
confluent		confluent
consumer		consumer
converter		converter
dynamodb		dynamodb
echo		echo
echo_v3		echo_v3
elasticsearch		elasticsearch
firestore		firestore
getter		getter
gin		gin
handler		handler
health		health
ibmmq		ibmmq
kafka		kafka
linkedin/avro		linkedin/avro
log		log
mongo		mongo
nats		nats
pubsub		pubsub
rabbitmq		rabbitmq
reader		reader
receiver		receiver
sarama		sarama
server		server
sql		sql
sqs		sqs
subscriber		subscriber
validator		validator
zap		zap
.gitignore		.gitignore
README.md		README.md
batch_handler.go		batch_handler.go
batch_worker.go		batch_worker.go
batch_worker_config.go		batch_worker_config.go
bytes_writer.go		bytes_writer.go
default_batch_worker.go		default_batch_worker.go
error_handler.go		error_handler.go
error_writer.go		error_writer.go
func.go		func.go
handler.go		handler.go
log.go		log.go
map_batch_handler.go		map_batch_handler.go
maps_writer.go		maps_writer.go
message.go		message.go
message_queue_writer.go		message_queue_writer.go
retry.go		retry.go
retry_sender.go		retry_sender.go
retry_service.go		retry_service.go
retry_writer.go		retry_writer.go
simple_retry_sender.go		simple_retry_sender.go
subscription.go		subscription.go
validator.go		validator.go