Hello,
We are using Camel to manage our endpoint injection through spring for
activemq. We currently are very happy with it except for one issue that has
fallen in my lap that I can't quite seem to find the answer to. Essentially
what happens is once our app is up and running for a while everything is
working great; however, RIGHT when the app starts up, there are ~ 250-500
msgs that "get sent to amq" through an injected camel endpoint (using an
annotation), for some reason these messages never make it to amq (the queue
sizes don't change) and no errors etc occur. If anyone knows a good
direction to head in I would greatly appreciate it. Below are the sections
of my config that are surrounding this. By the way -- we are using Camel
1.3-SNAPSHOT right now. Also, I know that I could have the activemq
endpoint directly injected into my java class, but the reason I am using the
direct: uri is to allow additional route configuration without changing the
source. Thanks so much for your help!
------- JAVA CLASS THAT IS PRODUCER ------
public class BatchUpdateQueueProducer implements IMessageProducer
{
@org.apache.camel.EndpointInject(uri="direct:BatchUpdateQueue")
ProducerTemplate producer;
public void sendMessage(Object message)
{
if(message != null)
{
producer.sendBody(convertToMessage(message));
}
}
.....
}
------- SPRING CONFIGURATION ------
<beans ... >
<camelContext id="camel"
xmlns="http://activemq.apache.org/camel/schema/spring";>
<package>com.mydomain.camel</package>
<route>
<from uri="direct:BatchUpdateQueue"/>
<to uri="activemq:queue:BatchUpdateQueue"/>
</route>
</camelContext>
...
<bean id="activemq"
class="org.apache.camel.component.jms.JmsComponent">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL"
value="${jms.providerUrl}?wireFormat.maxInactivityDuration=10000"/>
<property name="redeliveryPolicy">
<bean
class="org.apache.activemq.RedeliveryPolicy">
<property name="initialRedeliveryDelay"
value="2000"/>
<property name="maximumRedeliveries"
value="15"/>
<property name="useCollisionAvoidance"
value="true"/>
</bean>
</property>
</bean>
</property>
</bean>
...
<bean id="camelBatchUpdateQueueProducer"
class="com.mydomain.camel.BatchUpdateQueueProducer" />
<beans>
--
View this message in context:
http://www.nabble.com/Camel--%3E-AMQ-issues-tp15220879s22882p15220879.html
Sent from the Camel - Users mailing list archive at Nabble.com.
