You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by balderman <ba...@gmail.com> on 2008/06/03 09:40:00 UTC

Problem using http transportConnector

I am using http tansport in order to cross firewall.
I have message broker configured to support http.

activemq.xml snippet:
~~~~~~~~~~~~~~~~~~~~
	...
	<transportConnectors>
            <transportConnector name="openwire" uri="tcp://localhost:61616"
discoveryUri="multicast://default"/>
            <transportConnector name="ssl" uri="ssl://localhost:61617"/>
            <transportConnector name="stomp" uri="stomp://localhost:61613"/>
            <transportConnector name="xmpp" uri="xmpp://localhost:61222"/>
            <transportConnector name="http"
uri="http://172.16.233.50:61618"/>
        </transportConnectors>
	...
and have 2 java programs: "Sender" and "Receiver". I am using Spring JMS
template and Spring MDP.
The "Sender" send messages without a problem (I can browse thw queue with
the admin console).
But the "Receiver" is not getting the message. When I change the "Receiver"
configuration from http to tcp the "Receiver" gets the messages.

Sender configuration:
~~~~~~~~~~~~~~~~~~~~~
...
  <bean id="myJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory">
      <ref bean="jmsFactory"/>
    </property>
  </bean>

  <bean id="jmsFactory"
class="org.apache.activemq.pool.PooledConnectionFactory"
destroy-method="stop">
    <property name="connectionFactory">
      <bean class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL">
          <value>http://172.16.233.50:61618</value>
        </property>
      </bean>
    </property>
  </bean>
  
  
  <bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
    <constructor-arg value="MyQ"/>
  </bean

Receiver configuration:
~~~~~~~~~~~~~~~~~~~~~~~
...
	<!-- this is the Message Driven POJO (MDP) -->
	<bean id="messageListener"
		class="com.bmc.disco.jms.poc.MessgeDrivenPojo" />

	<bean id="connectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL">
		        <value>http://172.16.233.50:61618</value>
		</property>
	</bean>

	<!-- and this is the message listener container -->
	<bean id="jmsContainer"
		class="org.springframework.jms.listener.DefaultMessageListenerContainer">
		<property name="connectionFactory" ref="connectionFactory" />
		<property name="destination" ref="destination" />
		<property name="messageListener" ref="messageListener" />
	</bean>

	  <bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
	    <constructor-arg value="MyQ"/>
	  </bean
...


The classpath of "Sender" and  "Receiver": 
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
activeio-core-3.1.0-tests.jar
activeio-core-3.1.0.jar
activemq-core-5.1.0.jar
activemq-jmdns_1.0-5.1.0.jar
activemq-optional-5.1.0.jar
activemq-rar-5.1.0.rar
activemq-xmpp-5.1.0.jar
commons-beanutils-1.6.1.jar
commons-collections-3.1.jar
commons-dbcp-1.2.jar
commons-httpclient-2.0.1.jar
commons-logging-1.1.jar
commons-pool-1.4.jar
derby-10.1.3.1.jar
geronimo-j2ee-connector_1.5_spec-2.0.0.jar
geronimo-j2ee-management_1.0_spec-1.0.jar
geronimo-jta_1.0.1B_spec-1.0.1.jar
jms.jar
log4j-1.2.14.jar
spring-2.5.jar
spring-beans-2.5.1.jar
spring-context-2.5.1.jar
spring-core-2.5.1.jar
spring-jms-2.5.1.jar
spring-tx-2.5.1.jar
xbean-spring-3.3.jar
xmlpull-1.1.3.4d_b4_min.jar
xstream-1.2.jar


Thanks

Avishay
-- 
View this message in context: http://www.nabble.com/Problem-using-http-transportConnector-tp17617888s2354p17617888.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.