search

airtai / faststream

FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
https://faststream.airt.ai/latest/
Apache License 2.0
3.15k stars 161 forks source link

ActiveMQ support #1373

Open v2boardbot opened 7 months ago

v2boardbot commented 7 months ago

To suggest an idea or inquire about a new Message Broker supporting feature or any other enhancement, please follow this template:

Is your feature request related to a problem? Please describe. Provide a clear and concise description of the problem you've encountered. For example: "I'm always frustrated when..."

Describe the solution you'd like Clearly and concisely describe the desired outcome or solution.

Feature code example To help others understand the proposed feature, illustrate it with a FastStream code example:

from faststream import FastStream
...

Describe alternatives you've considered Provide a clear and concise description of any alternative solutions or features you've thought about.

Additional context Include any other relevant context or screenshots related to the feature request.

Lancetnik commented 7 months ago

What does "increase support" mean? ActiveMQ is working on top of AMQP/MQTT/STOMP (the same with RMQ), so these clients should support it as well. Does it have any specific features we should implement via separated broker?

v2boardbot commented 7 months ago

RabbitMQ's AMQP cannot be used directly on ActiveMQ

Bankass77 commented 6 months ago

Hi, please , I would upgrade my dependency in pom.xml of

org.apache.activemq 
        <artifactId>activemq-client</artifactId>
        <version>5.16.1</version>
    </dependency>   to  <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-client</artifactId>
        <version>5.18.3</version>
    </dependency>  and use 
    ActiveMQConnectionFactory  class, but i have this exception:

java.lang.IllegalStateException: java.lang.RuntimeException: java.lang.NullPointerException: Schema failover not found. How i can use failover, please ?