Queues options allows to configure KubeMQ Queues defaults.
Flags
--queue-max-receive-messages-request
Set max of sending / receiving batch of queue message
--queue-max-wait-timeout-seconds
Set max wait timeout allowed for message
--queue-max-expiration-seconds
Set max expiration allowed for message
--queue-max-delay-seconds
set max delay seconds allowed for message
Set max retires to receive message before discard
--queue-max-visibility-seconds
Set max time of hold received message before returning to queue
--queue-default-visibility-seconds
Set default time of hold received message before returning to queue
-- queue-default-wait-timeout-seconds
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
queue.maxReceiveMessagesRequest
Set max of sending / receiving batch of queue message
queue.maxWaitTimeoutSeconds
Set max wait timeout allowed for message
queue.maxExpirationSeconds
Set max expiration allowed for message
set max delay seconds allowed for message
Set max retires to receive message before discard
queue.maxVisibilitySeconds
Set max time of hold received message before returning to queue
queue.defaultVisibilitySeconds
Set default time of hold received message before returning to queue
queue.defaultWaitTimeoutSeconds
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
maxReceiveMessagesRequest
Set max of sending / receiving batch of queue message
Set max wait timeout allowed for message
Set max expiration allowed for message
set max delay seconds allowed for message
Set max retires to receive message before discard
Set max time of hold received message before returning to queue
Set default time of hold received message before returning to queue
defaultWaitTimeoutSeconds
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