KubeMQ Docs
KubeMQ.ioLogin / Register
  • Introduction
  • What's New
  • Getting Started
    • Quick Start
    • Build & Deploy
    • Create Cluster
      • Build & Deploy
      • Helm
      • Openshift
    • Create Connector
      • Build & Deploy
      • Helm
      • Openshift
    • Message Patterns
      • Queues
      • Pub/Sub
      • RPC
  • Learn
    • The Basics
      • Channels
      • Smart Routing
      • Grouping
    • Message Patterns
      • Queues
      • Pub/Sub
      • RPC
    • Access Control
      • Authentication
      • Authorization
      • Notifications
    • Clustering and HA
    • Connectors
      • KubeMQ Targets
      • KubeMQ Sources
      • KubeMQ Bridges
  • Configuration
    • Cluster
      • Set Cluster Name
      • Set Cluster Namespace
      • Set Persistent Volume
      • Set Cluster Replicas
      • Set Cluster Image
      • Set Cluster Security
      • Set Authentication
      • Set Authorization
      • Set Notification
      • Set License
      • Set gRPC Interface
      • Set Rest Interface
      • Set Api Interface
      • Set Store Settings
      • Set Queues Settings
      • Set Routing
      • Set Health Probe
      • Set Resources Limits
      • Set Logs
      • Set Node Selectors
    • Connectors
      • KubeMQ Targets
        • Standalone
          • Redis
          • Memcached
          • Postgres
          • Mysql
          • MSSql
          • Percona
          • Aerospike
          • ReThinkDB
          • MongoDB
          • Elastic Search
          • Cassandra
          • Couchbase
          • CockroachDB
          • Kafka
          • Nats
          • MQTT
          • ActiveMQ
          • IBM-MQ
          • Minio/S3
          • OpenFaas
          • HTTP
        • AWS
          • Athena
          • DynamoDB
          • Elastic Search
          • KeySpaces
          • MariaDB
          • MSSql
          • MySQL
          • Postgres
          • RedShift
          • RedShift Service
          • AmazonMQ
          • MSK
          • Kinesis
          • SQS
          • SNS
          • S3
          • Lambda
          • CloudWatch Logs
          • CloudWatch Events
          • CloudWatch Metrics
        • GCP
          • Redis
          • Memcached
          • Postgres
          • Mysql
          • BigQuery
          • BigTable
          • Firestore
          • Spanner
          • Firebase
          • Pub/Sub
          • Storage
          • Functions
        • Azure
          • Azure SQL
          • Mysql
          • Postgres
          • Blob
          • Files
          • Queue
          • Events Hub
          • Service Bus
        • Sources
          • Queue
          • Events
          • Events Store
          • Command
          • Query
      • KubeMQ Sources
        • HTTP
        • Messaging
          • Kafka
          • RabbitMQ
          • MQTT
          • ActiveMQ
          • IBM-MQ
          • Nats
        • AWS
          • AmazonMQ
          • MSK
          • SQS
        • GCP
          • Pub/Sub
        • Azure
          • EventHubs
          • ServiceBus
        • Targets
          • Queue
          • Events
          • Events Store
          • Command
          • Query
      • KubeMQ Bridges
        • Targets
          • Queue
          • Events
          • Events Store
          • Command
          • Query
        • Sources
          • Queue
          • Events
          • Events Store
          • Command
          • Query
    • Docker
  • HOW TO
    • Connect Your Cluster
    • Show Dashboard
    • Get Cluster Status
    • Get Cluster Logs
  • SDK
    • Java
    • Java (Springboot)
    • C# (.NET)
    • Go
    • Python
    • Node
    • Rest
  • Troubleshooting
    • Start Here
  • License
    • Open Source Software Notices
Powered by GitBook
On this page

Was this helpful?

  1. Configuration
  2. Cluster

Set Queues Settings

Queues options allows to configure KubeMQ Queues defaults.

Flags

Flag

Type/Options

Default

Description

--queue-max-receive-messages-request

int

1024

Set max of sending / receiving batch of queue message

--queue-max-wait-timeout-seconds

int

3600

Set max wait timeout allowed for message

--queue-max-expiration-seconds

int

43200

Set max expiration allowed for message

--queue-max-delay-seconds

int

43200

set max delay seconds allowed for message

--queue-max-requeue

int

1024

Set max retires to receive message before discard

--queue-max-visibility-seconds

int

43200

Set max time of hold received message before returning to queue

--queue-default-visibility-seconds

int

60

Set default time of hold received message before returning to queue

-- queue-default-wait-timeout-seconds

int

1

Set default time to wait for a message in a queue

Examples

Set max delay seconds allowed to no more than one hour:

kubemqctl create cluster --queue-max-delay-seconds 3600

Change default of visibility to 3 minutes:

kubemqctl create cluster --queue-default-visibility-seconds 180

Values

Value

Type/Options

Default

Description

queue.maxReceiveMessagesRequest

int

1024

Set max of sending / receiving batch of queue message

queue.maxWaitTimeoutSeconds

int

3600

Set max wait timeout allowed for message

queue.maxExpirationSeconds

int

43200

Set max expiration allowed for message

queue.maxDelaySeconds

int

43200

set max delay seconds allowed for message

queue.maxReQueues

int

1024

Set max retires to receive message before discard

queue.maxVisibilitySeconds

int

43200

Set max time of hold received message before returning to queue

queue.defaultVisibilitySeconds

int

60

Set default time of hold received message before returning to queue

queue.defaultWaitTimeoutSeconds

int

1

Set default time to wait for a message in a queue

Examples

Set max delay seconds allowed to no more than one hour:

helm install kubemq-cluster  --set queue.maxDelaySeconds=3600 kubemq-charts/kubemq

Change default of visibility to 3 minutes:

helm install kubemq-cluster  --set queue.defaultVisibilitySeconds=180 kubemq-charts/kubemq

Fields

Field

Type/Options

Default

Description

maxReceiveMessagesRequest

int

1024

Set max of sending / receiving batch of queue message

maxWaitTimeoutSeconds

int

3600

Set max wait timeout allowed for message

maxExpirationSeconds

int

43200

Set max expiration allowed for message

maxDelaySeconds

int

43200

set max delay seconds allowed for message

maxReQueues

int

1024

Set max retires to receive message before discard

maxVisibilitySeconds

int

43200

Set max time of hold received message before returning to queue

defaultVisibilitySeconds

int

60

Set default time of hold received message before returning to queue

defaultWaitTimeoutSeconds

int

1

Set default time to wait for a message in a queue

Examples

Set max delay seconds allowed to no more than one hour:

Run:

kubectl apply -f {below-yaml-file}
apiVersion: core.k8s.kubemq.io/v1alpha1
kind: KubemqCluster
metadata:
  name: kubemq-cluster
  namesapce: kubemq
  labels:
    app: kubemq-cluster
spec:
  replicas: 3
  queue:
    maxDelaySeconds: 3600

Change default of visibility to 3 minutes:

Run:

kubectl apply -f {below-yaml-file}
apiVersion: core.k8s.kubemq.io/v1alpha1
kind: KubemqCluster
metadata:
  name: kubemq-cluster
  namesapce: kubemq
  labels:
    app: kubemq-cluster
spec:
  replicas: 3
  queue:
    defaultVisibilitySeconds: 180
PreviousSet Store SettingsNextSet Routing

Last updated 5 years ago

Was this helpful?