Skip to content
gRPC based messages broker
Go Dockerfile
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
broker map based queue Aug 16, 2019
examples Dockerfile Aug 6, 2019
protocol Dockerfile Aug 6, 2019
transport Hello cruel world Aug 1, 2019
vendor/qpid.apache.org Hello cruel world Aug 1, 2019
Dockerfile Dockerfile Aug 6, 2019
README.md Dockerfile Aug 6, 2019
go.mod HTTP push/pull server Aug 2, 2019
go.sum Dockerfile Aug 6, 2019
qubs.go Dockerfile Aug 6, 2019

README.md

Simple messages broker built for DEVELOPMENT purposes on top of gRPC. Has gRPC and HTTP/2 endpoints.

Run gRPC example:

go run cmd/cmd.go --debug --proto=grpc

or

docker run --rm -p 7171:7171 trntv/qubs:latest --proto=grpc
go run examples/grpc/consumer.go
go run examples/grpc/producer.go

Run HTTP example:

go run cmd/cmd.go --debug --proto=http --port=8181

or

docker run --rm -p 8181:8181 trntv/qubs:latest --proto=http --port=8181
curl -X POST \
  http://127.0.0.1:8181/some-queue-name \
  -d '{
	"payload": "VGVzdCBQYXlsb2Fk"
}'
curl http://127.0.0.1:8181/some-queue-name

TODO:

  • docker image
  • auth
  • messages metadata
  • ack/noack
  • client (consumer, producer)
  • embedded broker
  • usage
  • tests
  • ... a lot of other items already done ...
You can’t perform that action at this time.