Skip to content
IRZU INSTITUTE

IRZU INSTITUTE

Inštitut za raziskovanje zvočnih umetnosti

  • EVENTS
    • ARTISTIC
    • EDUCATIONAL
    • INTERVIEWS
    • ONLINE
    • PRODUCTION
  • PRODUCTS
    • DIRECTIONAL AUDIO SPEAKERS
    • BREATHING EXERCISE GAMES
    • VIRTUAL REALITY
    • INTERACTIVE MIDI
    • SMARTDRUMS ANDROID SOFTWARE
    • SMARTGUITARS OPEN SOURCE
    • UNIVERSAL RECORDING CABLES
    • ANDROID TO SHEETS LOGGING
    • ANDROID TO CALENDAR LOGGING
    • WEBCAM LIE DETECTOR OVERLAY
  • RESEARCH
    • OPEN SOURCE BIOLOGY
    • ACOUSTICS & DSP
    • DATA MANAGEMENT
    • ELASTIC & LUCENE
    • FFT & WAVELETS
    • GAME DEVELOPMENT
    • JS, REACT, & NODE
    • KERNEL STREAMING
    • LINUX & ANDROID
    • LOW VOLTAGE IC
    • MEMS SYSTEMS
    • MQTT & IOT AUTOMATION
    • REST/HTTP & GRAPHQL
    • VIRTUALIZATION
    • 3D PRINTING & FABRICATION
  • EDUCATION
    • CRISPR WORKSHOP
    • TASKER WORKSHOP
    • PUREDATA WORKSHOP
    • SMARTDRUMS WORKSHOP
  • POSTDOCS
    • TELEMEDICINE & GAMIFICATION
    • EDC IN CLINICAL TRIALS
    • ARTIFICIAL INTELLIGENCE
  • INTERNSHIPS

[FIXED] Spring Cloud Stream + RabbitMQ

September 25, 2022admin

I have a RabbitMQ message broker running in a server, to which I’m trying to configure a Producer and a Consumer using Spring Cloud Stream. My Producer is creating messages in a queue every second, while my Consumer reads them at the same rate. However, if I stop my Consumer and the Producer keeps pushing messages, when I restart my Consumer again it is unable to retrieve the messages created in that period of time it was down, only picking up the messages produced from the time that it was started. How can I make my Consumer consume existing messages in the queue when it starts?

Here are my Consumer properties:

cloud:
    stream:
      bindings:
        input:
          destination: spring-cloud-stream-demo
          consumer:
            auto-bind-dlq: true
            republishToDlq: true
            maxAttempts: 5

And my Producer properties:

cloud:
    stream:
      bindings:
        output:
          destination: spring-cloud-stream-demo

Appreciate any help!

You need to add a group to the consumer (input) binding; otherwise it will bind an anonymous, auto-delete, queue to the exchange.

With a group, a permanent, durable, queue is bound instead.

Answered By – Gary Russell
Answer Checked By – Mary Flores (JavaFixing Volunteer)

Read more here: Source link

Post navigation

PreviousSlix 1.0 APK for Android
NextKubernetes Intro – HackMD

Categories

  • EVENTS (133)
    • ARTISTIC (93)
    • EDUCATIONAL (55)
    • INTERVIEWS (9)
    • POSTDOCS (3)
    • PRODUCTION (16)
  • INTERNSHIPS (15)
    • ANDROID APPS PERMISSION EDITING (1)
    • ANDROID AUTOMATION ENGINEER (1)
    • ARTIFICIAL INTELLIGENCE ARCHITECT (1)
    • EDITOR OR INTERN EDITOR (1)
    • NODE.JS AUTOMATION (1)
    • PUREDATA INTERACTIVE AUDIO PROGRAMMING (1)
    • RESEARCH COMMUNITY MANAGER (1)
    • SOCIAL MEDIA MANAGER (1)
    • SOCIAL MEDIA MANAGER AND STRATEGIST (1)
    • TESTING ENGINEER (1)
    • UNITY 3D C# GAME DEVELOPER (1)
    • UNITY 3D C# GAME DEVELOPER AND TESTING ENGINEER (1)
    • VIDEO ANIMATOR (1)
    • WEB AUTOMATION AND TESTING (1)
    • WORDPRESS MANAGER (1)
  • PRODUCTS (113)
    • AUGEMENTED REALITY (1)
    • BREATHING GAMES (90)
    • DIRECTIONAL SPEAKERS (4)
    • MARINE INTELLIGENCE (3)
    • RECORDING CABLES (1)
    • SMART DRUMS (11)
    • SMART GUITARS (9)
    • SMART PIANO (1)
    • VIRTUAL REALITY (9)
  • RESEARCH (22,320)
    • 3D MODELLING (166)
    • 3D PRINTING (1,497)
    • ACOUSTICS & DSP (2,805)
    • DATA MANAGEMENT (3,872)
    • ELASTIC & LUCENE (211)
    • FFT & WAVELETS (260)
    • GAME ENGINES (339)
    • GSR & BIOFEEDBACK (99)
    • JS, REACT, & NODE (1,170)
    • LINUX & ANDROID (243)
    • LOW VOLTAGE IC (459)
    • MEMS SYSTEMS (43)
    • MQTT & IOT AUTOMATION (554)
    • PUREDATA & MAX MSP (11)
    • REST/HTTP & GRAPHQL (97)
    • VIRTUALIZATION (159)
  • KERNEL STREAMING (19)
Copyright © 2025 IRZU INSTITUTE | Deneb by Firefly Themes
Scroll Up