0
Erste Benutzer von Kamel/JMS/acivemq.kann 'camel route zu JMs active mq arbeiten
Ich habe eine JMS-Kamel-Route eingerichtet und ich versuche, als Test-Text zu senden und es in der aktiven mq GUI http://127.0.0.1:8161/admin/topics.jsp zu sehen, aber ich sehe nichts. Dies ist das erste Mal, dass ich versuche, das alles zum Laufen zu bringen und wirklich etwas in active mq zu sehen, um zu beweisen, dass es richtig funktioniert. Hier
ist das Kamel Route
<cm:property-placeholder persistent-id="com.srcinc.ogre.alerts">
<cm:default-properties>
<cm:property name="jmsHostName" value="localhost" />
<cm:property name="jmsPort" value="61616" />
<cm:property name="jmsUserName" value="system" />
<cm:property name="jmsPassword" value="manager" />
</cm:default-properties>
</cm:property-placeholder>
<bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://${jmsHostName}:${jmsPort}" />
<property name="userName" value="${jmsUserName}" />
<property name="password" value="${jmsPassword}" />
</bean>
<bean id="pooledJmsConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
init-method="start" destroy-method="stop">
<property name="maxConnections" value="8" />
<property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>
<bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
<property name="connectionFactory" ref="pooledJmsConnectionFactory" />
<property name="concurrentConsumers" value="10" />
</bean>
<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="configuration" ref="jmsConfig" />
</bean>
<camelContext xmlns="http://camel.apache.org/schema/blueprint">
<route id="AlertProcessorJMSDistributionRoute">
<from uri="vm:send-jms-alert?multipleConsumers=true" />
<to uri="activemq:topic:Alerts" />
</route>
</camelContext>
Hier ist mein Java-Code, der die entsprechende Kamel Route verweist.
private static final String VM__JMS_ROUTE = "vm::send-jms-alert";
private ProducerTemplate mProducer;
mProducer = new DefaultCamelContext().createProducerTemplate();
mProducer.sendBody(VM__JMS_ROUTE, "Testing 123");
Es gibt keine Notwendigkeit für so viele Ausrufezeichen, anstatt auf Ihre Frage auszuarbeiten. – kaveh
bevor ich mich immer darum sorgen musste, dass ich meine Fragen nicht zu lang machte, so versuchte ich immer, meine Fragen nicht allzu ernst zu halten. Ich bin nie auf dieses Problem mit zu viel Code gestoßen. Irgendwelche Ideen irgendjemand? Ich kann ActiveMQAdvisory.Connection-Nachrichten sehen, die in Active MQ eingereiht sind, aber ich sehe meine Warteschlange oder mein Thema nicht – user3470688