smallrye/smallrye-reactive-messaging

Issues

• smallrye-reactive-messaging - Delayed Retry Topic

  #2876 opened 7 days ago by joystuffs
  1

• Set Rabbitmq Metadata on DLQ messages after nack

  #2877 opened 11 days ago by BrianH85
  0

• Exchange binding is not created for @Outgoing channel

  #2829 opened 12 days ago by elmodeer
  1

• RabbitMQ and Quarkus Dev Mode restart keeps previous connections

  #2853 opened 12 days ago by kdubb
  5

• Backport VertX qualifier to 4.24.x

  #2842 opened 12 days ago by kabir
  1

• MQTT consumer silently stops consuming data

  #2764 opened 3 months ago by marc-batto
  0

• AWS SQS support more flexible deserialization

  #2789 opened 3 months ago by kerkhofsd
  0

• Missing consumer options for RabbitMQ incoming channels

  #2803 opened a month ago by ozangunalp
  0

• Attach exceptions to spans in error handlers for better Observability

  #2782 opened 3 months ago by michalcukierman
  1

• Kafka - transactional.id for horizontally scalable consume-transform-produce

  #2820 opened 2 months ago by kerkhofsd
  1

• Messager companions - method for getting all available messages

  #2794 opened 2 months ago by GregJohnStewart
  1

• [Enhancement] Tries to inject Vertx instance from CDI using a qualifier

  #2771 opened 2 months ago by gaol
  2

• AWS SQS NACK doing nothing?

  #2635 opened 7 months ago by spc16670
  5

• Mqtt TLS test no longer can start the container eclipse-mosquitto:2.0

  #2785 opened 3 months ago by ozangunalp
  0

• Suggestion: Incoming- & OutgoingKafkaRecord should override Message#addMetadata & Message#with*

  #2777 opened 3 months ago by slinstaedt-hlag
  2

• Kafka DLQ config doesn't work will concurrency enabled topics

  #2766 opened 3 months ago by ozangunalp
  0

• Lambda Snapstart kafka connection errors

  #2715 opened 5 months ago by hamburml
  11

• KafkaCompanion does not configure Serializer/Deserializer

  #2756 opened 4 months ago by diversit
  3

• Feature Request: Support for error queues for rabbitmq

  #2707 opened 5 months ago by jonsalvas
  0

• KafkaRequestReply fails with ` java.lang.IllegalStateException` if the partition assignment takes longer than `replyTimeout` at startup

  #2714 opened 3 months ago by Malandril
  3

• How to publish messages to a topic in Solace broker using AMQP

  #2751 opened 4 months ago by elmodeer
  4

• Allow conversion to JsonObject to be optional during amqp message deserialization

  #2619 opened 4 months ago by ylepikhov
  1

• Ack related docs issues

  #2733 opened 4 months ago by pawel-boguski-ds
  0

• The NACK handler for incoming messages is not executed when an exception occurs during processing while using a signature method that receives a single payload and produces a stream of payloads

  #2732 opened 4 months ago by pawel-boguski-ds
  0

• Deprecated method io.smallrye.reactive.messaging.MutinyEmitter.send(M) result in ambigus method call

  #2738 opened 4 months ago by s4iko
  1

• Pulsar: out of direct buffer memory during failure handling with nack strategy and DLQ while pool message is enabled.

  #2698 opened 5 months ago by kamilchociej
  1

• 'Targeted' does not support null values

  #2687 opened 6 months ago by marekczajkowski
  1

• RabbitMQ should allow configure explicitly Retry Failure for nack when using Publish Confirm

  #2726 opened 4 months ago by gcuisinier
  2

• JMS - Message acknowledgement

  #2575 opened 9 months ago by dankristensen
  3

• Rabbitmq: Concept of error queues after n retries

  #2641 opened 7 months ago by jonsalvas
  2

• Is not possible to add a custom batchReceivePolicy to the consumer

  #2631 opened 5 months ago by hermeswaldemarin
  3

• Add configuration to outgoing MQTT connector to set retain property

  #2663 opened 5 months ago by diversit
  3

• Logging password on startup

  #2653 opened 6 months ago by nojomyth-dev
  0

• AWS SQS add support for deleting and sending messages in batch mode

  #2672 opened 6 months ago by arturluzgin
  0

• Kafka Companion: Which is the best way to verify messages are commited?

  #2668 opened 6 months ago by cj19
  1

• Kafka Companion clearing the topics for the component tests

  #2658 opened 6 months ago by cj19
  1

• Configuration via env variables not working correctly anymore since Quarkus 3.11

  #2659 opened 6 months ago by panphg
  4

• Support for GenericPayload while returning multiple outgoings

  #2645 opened 7 months ago by pawel-boguski-ds
  3

• Version 3.x problem with Vert.x 4.5.4

  #2647 opened 7 months ago by LucaT75
  6

• Kafka Compaion connects to multiple bootstrap servers at the start of the test

  #2650 opened 7 months ago by cj19
  4

• Suspected memory leak in KafkaThrottledLatestProcessedCommit

  #2623 opened 7 months ago by tilakchowdary
  13

• IncomingJmsMessage assumes message type it won't be empty

  #2625 opened 7 months ago by neazevedo
  5

• Connect to different brokers per topic - no events are consumed

  #2621 opened 7 months ago by duckdeer
  3

• How to use companion.consumeXYZ() twice?

  #2605 opened 8 months ago by octopus-prime
  2

• Caching dependencies

  #2606 opened 8 months ago by dankristensen
  2

• IncomingConnector has no downstream

  #2593 opened 8 months ago by pengxo
  11

• [Kafka Companion] Assertion of produced messages

  #2590 opened 8 months ago by Inithron
  0

• Kafka consumer gets into a rebalance loop

  #2589 opened 8 months ago by marksouletheprogrammer
  3

• Kafka delayed retry topic not retrying after initial produce

  #2566 opened 9 months ago by nielsvhaldvb
  4

• Pulsar backpressure mechanism ignores client's memory limit setting

  #2573 opened 9 months ago by marekczajkowski
  0