activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ngcdan12 <gameoperati...@hotmail.com>
Subject Re: MapMessages from Python to Java
Date Wed, 04 Nov 2009 22:38:09 GMT

Great thanks for the help.

I can send and receive messages from python to java now :).

Dan


James Casey-2 wrote:
> 
> Hi Dan,
> 
> The code should look like :
> 
> import stomp
> 
> dest='/queue/MQ-X.1234.X-1.RadarTracks'
>      # [1]
> conn = stomp.Connection([('localhost',61616)])
>        # [2]
> conn.start()
> conn.connect()
> message = {'field1' : 'foo', 'field2' : 'bar'}
> 
> conn.send(message, destination=dest, headers={'transformation' :
>    'jms-map-xml'}, ack='auto')
> conn.disconnect()
> 
> Note:
> [1] For STOMP you need to specific '/topic' or '/queue' as appropriate
> in the destination
> 
> [2] You only need to specify 'localhost', no need for a full URL
> 
> For the logging warning, check what version of stomp.py you're using -
> the issue with the logger is fixed in more recent versions (e.g.
> 2.0.4)
> 
> Finally, note that you can have your java consumer listen via openwire
> and your python producer send via STOMP, you just need to add 2
> network connectors (normally 'tcp://' connector is on port 61616 and
> 'stomp://' connector is on port 61613.
> 
> cheers,
> 
> James.
> 
> 2009/11/2 ngcdan12 <gameoperative2@hotmail.com>:
>>
>> Hey guys,
>>
>> Thanks for the response.  I made a Python script with the above code.
>>
>> import stomp
>>
>> dest='MQ-X.1234.X-1.RadarTracks'
>> conn = stomp.Connection([('stomp:\\localhost',61616)])
>> conn.start()
>> conn.connect()
>> message = {'field1' : 'foo', 'field2' : 'bar'}
>>
>> conn.send(message, destination=dest, headers={'transformation' :
>>    'jms-map-xml'}, ack='auto')
>> conn.disconnect()
>>
>> When I run this script I get a
>> No handlers could be found for logger "stomp.py", warning message/error.
>>
>> I do not seem to be receiving any messages from my java message listener
>> either.  Is this an error I should be worried about?  Also on my java
>> listener I put the url as "stomp://localhost:61616"; which seems to run
>> ok.
>> I then connect to the broker using ActiveMQConnectionFactory class. I had
>> to
>> also enable the Stomp connector in the activemq.xml file stored in the
>> activemq directory, by adding
>> <transportConnector name="stomp" uri="stomp://localhost:61616"/>
>>
>> Thanks,
>>
>> Dan
>> --
>> View this message in context:
>> http://old.nabble.com/MapMessages-from-Python-to-Java-tp26070536p26157767.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
> 
> 

-- 
View this message in context: http://old.nabble.com/MapMessages-from-Python-to-Java-tp26070536p26205924.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message