Event Bus Spring Configuration with ActiveMQ & AMQP Terminal

[Abhishek Biswas]

Hi,

Can anyone please help on what needs to be done to configure an event bus with ActiveMQ and AMQP Terminal?

Thanks | Abhishek

[Chirdeep Tomar]

Are you using xml or java configuration? 

[Abhishek Biswas]

xml it is!

[Allard Buijze]

Hi,

here's a configuration file used in the test cases:

https://github.com/AxonFramework/AxonFramework/blob/master/amqp/src/test/resources/META-INF/spring/amqp-namespace-context.xml

It shows the configuration of a terminal and custom amqp configuration for a cluster. 

You'll need to pass a reference to the cluster in your <axon:event-bus terminal=""/> element.

Cheers,

Allard

On Fri, Mar 13, 2015 at 8:12 PM, Abhishek Biswas <abhishek...@gmail.com> wrote:

xml it is!

--
You received this message because you are subscribed to the Google Groups "Axon Framework Users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to axonframewor...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[Siva Sekhar Nalluri]

Hi Allard,

 

I am new to axon and trying to use the activeMQ for eventbus from test case I tried to use below config but giving error

 

please suggest me the right way to configure the amqp in event bus.

 

 

 

<bean id="connectionFactory" class ="org.apache.qpid.amqp_1_0.jms.impl.ConnectionFactoryImpl">

<constructor-arg value="${ACTIVEMQ_HOST}" />

<constructor-arg value="${ACTIVEMQ_PORT}" />

<constructor-arg value="${ACTIVEMQ_USER}" />

<constructor-arg value="${ACTIVEMQ_PASSWORD}" />

</bean>

<amqp:terminal id="terminal" exchange-name="Exchange" durable="true" transactional="false"

connection-factory="connectionFactory" message-converter="messageConverter"

routing-key-resolver="routingKeyResolver" serializer="serializer">

<!-- wait-for-publisher-ack="true" -->

<amqp:default-configuration transaction-size="20" transaction-manager="transactionManager"/>

</amqp:terminal>

<amqp:configuration id="fullConfig"

acknowledge="manual" advice-chain="mockAdviceChain" concurrency="1" queue-name="Queue"

executor="executor" error-handler="errorHandler" receive-timeout="10"

recovery-interval="1000" shutdown-timeout="10" transaction-manager="transactionManager"

exclusive="true" transaction-size="200" prefetch="1000"/>

<axon:cluster id="testCluster" default="true">

<axon:meta-data>

<entry key="AMQP.Config">

<amqp:configuration transaction-size="20000"/>

</entry>

</axon:meta-data>

</axon:cluster>

<axon:event-bus id="eventBus" terminal="terminal" />

[Allard Buijze]

Hi,

can you provide a bit more detail about the error? Stack trace for example?

A quick glance reveils you're using an AMQP 1.0 connector. I have only tested against 0.9.x (1.0 is under a lot of debate) myself, so I don't know how that works out.

Cheers,

Allard

[Siva Sekhar Nalluri]

 

 

Cannot convert value of type [org.apache.qpid.amqp_1_0.jms.impl.ConnectionFactoryImpl] to required type [org.springframework.amqp.rabbit.connection.ConnectionFactory] for property 'connectionFactory': no matching editors or conversion strategy found

 

this the error I getting.

 

 

Thanks,

Siva

[Allard Buijze]

Ah. That's because the Spring Amqp connector expects a rabbit client. Note that thus client should be able to talk to other amqp servers as well.