kubemq-community

(★ 664)

KubeMQ is a Kubernetes native message queue broker

File Explorer

Download Latest Version (.zip)

- - ActionButtons.28ebda64.js
  - ActionButtons.50e07f63.js
  - ActionButtons.c8f061f8.js
  - ActionButtons.d44386d2.js
  - AddChannel.741ba0f9.js
  - AddChannel.vue_vue_type_script_setup_true_lang.ccd0b81d.js
  - Channel.14f90cea.css
  - Channel.358248bf.css
  - Channel.636ea152.js
  - Channel.697b7c5c.js
  - ChannelActions.9a554781.js
  - ChannelActions.ca05a0c5.js
  - ChannelActions.d777ac1b.js
  - ChannelActions.vue_vue_type_script_setup_true_lang.053b1621.js
  - ChannelActions.vue_vue_type_script_setup_true_lang.070eaed0.js
  - ChannelActions.vue_vue_type_script_setup_true_lang.c1acab02.js
  - ChannelReceive.ec2f02f2.js
  - Channels.337c9695.js
  - Channels.97bbb0d2.js
  - Channels.acea90ab.js
  - Channels.vue_vue_type_script_setup_true_lang.07a193b4.js
  - Channels.vue_vue_type_script_setup_true_lang.c44d198d.js
  - Channels.vue_vue_type_script_setup_true_lang.ef1ee30f.js
  - ChannelStream.aec3567a.js
  - ChannelSubscribe.07fe356d.js
  - ChannelSubscribe.116d1233.js
  - ChannelSubscribe.vue_vue_type_script_setup_true_lang.5dbf0592.js
  - ChannelSubscribe.vue_vue_type_script_setup_true_lang.d40a12e1.js
  - ClearQueue.ae2dd2de.js
  - ClearQueue.vue_vue_type_script_setup_true_lang.ec57e7f4.js
  - Clients.9610de02.js
  - Clients.vue_vue_type_script_setup_true_lang.b56898b2.js
  - CodeEditor.a3b038a7.js
  - color.473bc8ca.png
  - composables.0bc75d07.js
  - cqrs_request.ce51b25c.js
  - DataField.289d4d35.js
  - DataField.vue_vue_type_script_setup_true_lang.9a1a6859.js
  - default.b5462131.js
  - default.f8046d6f.css
  - entry.2f78082d.css
  - entry.7307fc4c.js
  - error-404.23f2309d.css
  - error-404.7b872028.js
  - error-500.6bb0d5c7.js
  - error-500.aa16ed4d.css
  - error-component.eacb24fe.js
  - Field.48326aec.js
  - Field.vue_vue_type_script_setup_true_lang.0d667ec2.js
  - HostInfo.242f56f1.js
  - index.1d8124a5.js
  - index.4667df00.js
  - index.4f407d37.js
  - index.5b74e62e.js
  - index.a4aa3727.js
  - index.ae45c57a.css
  - index.b2384337.css
  - index.d0013172.css
  - index.d173604e.css
  - index.e32370d3.css
  - index.esm.ec6caf95.js
  - index.f31f6ea3.js
  - InputCalander.89249c95.js
  - InputDropbox.b713c747.js
  - InputNumber.432bd6c1.js
  - InputText.a5d51f5e.js
  - logo-cluster.3849cb97.svg
  - logo-community.66c3462e.svg
  - logo-server.95fa749d.svg
  - logo.93427c33.svg
  - Monitor.b147d523.js
  - primeicons.131bc3bf.ttf
  - primeicons.3824be50.woff2
  - primeicons.5e10f102.svg
  - primeicons.90a58d3a.woff
  - primeicons.ce852338.eot
  - Queue.664b5c31.css
  - Queue.fc625e3e.js
  - queues_request.a3bea49d.js
  - ReceivedMessage.c8b2b157.js
  - ReceivedMessage.df20389e.js
  - ReceivedMessage.vue_vue_type_script_setup_true_lang.0d343b85.js
  - ReceivedMessage.vue_vue_type_script_setup_true_lang.ccb5e7f5.js
  - ReplyCommandMessage.733fef27.js
  - ReplyQueryMessage.24f4b580.js
  - request.fce72d22.js
  - send_response.a4e33ce2.js
  - SendMessage.3473bbe6.js
  - SendMessage.40c86465.js
  - SendMessage.e97cd65c.js
  - StatCard.574b63cf.js
  - StatStripCard.06dc0e4b.css
  - StatStripCard.60db0370.js
  - StatStripCard.vue_vue_type_style_index_0_scoped_b87ef05f_lang.ef632115.js
  - StatStripCardBox.9b7bff0f.js
  - stream.cbe555aa.js
  - TopChannelsCard.df8832ff.js
  - UseMemory.673b90bb.js
  - useToastMessage.47adc00c.js
  - welcome.70ace0f7.js
- - index.html
- - index.html
- - index.html
- - index.html
- - index.html
- 200.html
- 404.html
- index.html
- kubemq-icon.png
- - attach.go
  - commands.go
  - helper.go
  - receive.go
  - send.go
- - attach.go
  - events.go
  - helper.go
  - receive.go
  - send.go
- - attach.go
  - events_store.go
  - helper.go
  - list.go
  - receive.go
  - send.go
- - attach.go
  - helper.go
  - queries.go
  - receive.go
  - send.go
- - ack.go
  - attach.go
  - helper.go
  - list.go
  - peek.go
  - queue.go
  - receive.go
  - send.go
  - stream.go
- - root.go
- - server.go
- api.go
- api_test.go
- authentication.go
- authentication_test.go
- authorization.go
- authorization_test.go
- broker.go
- broker_test.go
- client.go
- config.go
- config_test.go
- env.go
- env_test.go
- error.go
- grpc.go
- grpc_test.go
- log.go
- log_test.go
- queue.go
- queue_test.go
- resource.go
- resource_test.go
- rest.go
- rest_test.go
- routing.go
- routing_test.go
- security.go
- security_test.go
- store.go
- store_test.go
- validation.go
- - kubemq.md
  - kubemq_commands.md
  - kubemq_commands_attach.md
  - kubemq_commands_receive.md
  - kubemq_commands_send.md
  - kubemq_events.md
  - kubemq_events_attach.md
  - kubemq_events_receive.md
  - kubemq_events_send.md
  - kubemq_events_store.md
  - kubemq_events_store_attach.md
  - kubemq_events_store_list.md
  - kubemq_events_store_receive.md
  - kubemq_events_store_send.md
  - kubemq_queries.md
  - kubemq_queries_attach.md
  - kubemq_queries_receive.md
  - kubemq_queries_send.md
  - kubemq_queues.md
  - kubemq_queues_ack.md
  - kubemq_queues_attach.md
  - kubemq_queues_list.md
  - kubemq_queues_peek.md
  - kubemq_queues_receive.md
  - kubemq_queues_send.md
  - kubemq_queues_stream.md
  - kubemq_server.md
- dashboard.png
- pub-sub-2.png
- pub-sub.png
- send-queue-message.png
- - client.go
  - config.yaml
  - grpc.go
  - security_test.go
  - server.go
  - server_test.go
- - config.yaml
  - handlers.go
  - response.go
  - security_test.go
  - server.go
  - server_test.go
  - traffic.go
- - messages_fixtures.go
  - ping.http
  - requests_fixtures.go
- interfaces.go
- - base_value_dto.go
  - base_values.go
  - channel_dto.go
  - client_dto.go
  - db.go
  - entities_family.go
  - entities_group.go
  - entity.go
  - family_dto.go
  - group_dto.go
  - host_info_dto.go
  - info.go
  - snapshot.go
  - snapshot_dto.go
  - stat_card_dto.go
  - system.go
  - top_channels_dto.go
  - web_group.go
- - client.go
  - client_test.go
  - config.yaml
  - dispatcher.go
  - dispatcher_test.go
  - helpers.go
  - options.go
  - queue.go
  - queue_downstream.go
  - queue_downstream_test.go
  - queue_pool.go
  - queue_test.go
  - validatation.go
- - concurrent_map.go
  - concurrent_map_test.go
- - errors.go
  - types.go
- - client.go
- - echologger.go
  - factory.go
  - logger.go
- - config.yaml
  - handler.go
  - handler_test.go
  - helpers.go
  - middleware.go
  - middleware_test.go
  - monitor.go
  - monitor_test.go
  - pool.go
  - request.go
  - response_error.go
  - transport.go
  - transport_dto.go
- - attach.go
  - client.go
  - errors.go
  - helpers.go
  - writer.go
- - uuid.go
- - entities.go
  - handlers.go
  - response.go
  - server.go
  - service.go
- - array.go
  - array_queues_downstream.go
  - array_queues_downstream_test.go
  - array_queues_upstream.go
  - array_queues_upstream_test.go
  - array_test.go
  - command_receiver.go
  - command_sender.go
  - config.yaml
  - events_receiver.go
  - events_sender.go
  - eventsstore_receiver.go
  - eventsstore_sender.go
  - query_receiver.go
  - query_sender.go
  - queue_ack_all.go
  - queue_batch_sender.go
  - queue_receiver.go
  - queue_sender.go
  - response_sender.go
- - broker.go
  - health.go
  - metrics.go
  - service.go
  - status.go
- - channel_stats.go
  - clients_stats.go
  - counters.go
  - exporter.go
  - exporter_test.go
  - prom2json.go
  - prom_metric.go
  - report_metric.go
  - snapshot.go
  - stats.go
- - report.go
  - service.go
  - signature.go
- services.go
.dockerignore
.gitignore
.goreleaser.yml
Dockerfile
entrypoint.sh
go.mod
go.sum
LICENSE
main.go
README.md
Taskfile.yml

# Installation Guide

1. Get the code

git clone https://github.com/kubemq-io/kubemq-community

Downloads the entire project code from GitHub to your computer.

cd kubemq-community

Moves into the project folder you just downloaded.

2. Docker

Easy Recommended

Prerequisites

Git Needed to download the project code from GitHub.
Docker Desktop Needed to build and run containers. Install it and keep it running in the background.

docker build -t kubemq-community .

Builds a runnable image based on the Dockerfile.

docker run -p 8080:80 kubemq-community

Runs the built image as an actual container.

✅ Run docker compose ps to check the containers are Up. If the README mentions a port, open http://localhost:PORT in your browser.

3. Go

Medium

Prerequisites

Git Needed to download the project code from GitHub.
Go The Go compiler and toolchain.

go build ./...

Compiles the Go program into an executable.

go run .

Runs the Go program directly without a separate build step.

✅ If the build finishes without errors, it worked. If you used go run ., check the terminal output.