I made the change you suggested. However, I am getting the same error. :-(
Do you have any other suggestions?
Claus Ibsen-2 wrote:
Hi
You should use the ActiveMQ component instead of the generic
JmsComponent. Its optimized for AMQ.
http://camel.apache.org/activemq.html
On Mon, Mar 16, 2009 at 9:37 PM, greenbean kevin.urci...@ngc.com wrote:
Apache Camel 2.0 Snapshot
Apache ActiveMQ 5.2
When I started Apache Camel I see repeated connect/disconnect events in
activemq. Is there something I have done incorrectly to have activemq do
this? I use ActiveMQ other places (outside of camel) and everything
works
fine.
Below is the XML configuration and the DEBUG log information from
ActiveMQ.
-
camel:camelContext id=camel
camel:route
camel:from uri=activemq:queue:testa /
camel:policy ref=PROPAGATION_REQUIRED /
camel:process ref=myProcessor /
camel:to uri=activemq:queue:testb /
/camel:route
/camel:camelContext
bean id=myProcessor
class=com.ngc.ident1.example.camel.CamelProcessor
/bean
bean id=activemq
class=org.apache.camel.component.jms.JmsComponent
property name=connectionFactory
bean
class=org.apache.activemq.ActiveMQXAConnectionFactory
property name=brokerURL
value${local.broker.url}/value
/property
/bean
/property
property name=cacheLevelName value=CACHE_NONE /
property name=transacted value=true /
property name=transactionManager
ref=transactionManager
/
/bean
bean id=PROPAGATION_REQUIRED
class=org.apache.camel.spring.spi.SpringTransactionPolicy
constructor-arg
bean
class=org.springframework.transaction.support.TransactionTemplate
property name=transactionManager
ref=transactionManager /
/bean
/constructor-arg
/bean
-
2009-03-16 20:34:08,482 DEBUG
[org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Task)
Sending: WireFormatInfo { version=3, properties={CacheSize=1024,
CacheEnabled=true, SizePrefixDisabled=false,
MaxInactivityDurationInitalDelay=1, TcpNoDelayEnabled=true,
MaxInactivityDuration=3, TightEncodingEnabled=true,
StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2009-03-16 20:34:08,485 DEBUG
[org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport
Initiator: /127.0.0.1:59998) Sending: WireFormatInfo { version=3,
properties={CacheSize=1024, CacheEnabled=true, SizePrefixDisabled=false,
MaxInactivityDurationInitalDelay=1, TcpNoDelayEnabled=true,
MaxInactivityDuration=3, TightEncodingEnabled=true,
StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2009-03-16 20:34:08,485 DEBUG
[org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport:
tcp:///127.0.0.1:59998) Received WireFormat: WireFormatInfo { version=3,
properties={CacheSize=1024, CacheEnabled=true, SizePrefixDisabled=false,
MaxInactivityDurationInitalDelay=1, TcpNoDelayEnabled=true,
MaxInactivityDuration=3, TightEncodingEnabled=true,
StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2009-03-16 20:34:08,485 DEBUG
[org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport:
tcp:///127.0.0.1:59998) tcp:///127.0.0.1:59998 before negotiation:
OpenWireFormat{version=3, cacheEnabled=false, stackTraceEnabled=false,
tightEncodingEnabled=false, sizePrefixDisabled=false}
2009-03-16 20:34:08,485 DEBUG
[org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport:
tcp:///127.0.0.1:59998) tcp:///127.0.0.1:59998 after negotiation:
OpenWireFormat{version=3, cacheEnabled=true, stackTraceEnabled=true,
tightEncodingEnabled=true, sizePrefixDisabled=false}
2009-03-16 20:34:08,486 DEBUG
[org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport:
tcp://localhost/127.0.0.1:61616) Received WireFormat: WireFormatInfo {
version=3, properties={CacheSize=1024, CacheEnabled=true,
SizePrefixDisabled=false, MaxInactivityDurationInitalDelay=1,
TcpNoDelayEnabled=true, MaxInactivityDuration=3,
TightEncodingEnabled=true, StackTraceEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
2009-03-16 20:34:08,486 DEBUG
[org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport:
tcp://localhost/127.0.0.1:61616) tcp://localhost/127.0.0.1:61616 before
negotiation: OpenWireFormat{version=3, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
2009-03-16 20:34:08,486 DEBUG
