[rabbitmq-discuss] 2.5.0 stomp ssl Windows 2008R2
Sam Domonkos
sam at pfgltd.com
Wed Jun 15 17:04:47 BST 2011
Hello,
Looks like Massimo.Paladin at cern.ch is further along in his question.
Maybe I just have ssl setup wrong which I suspect because of the following:
=ERROR REPORT==== 15-Jun-2011::10:22:27 ===
SSL: hello: ./ssl_handshake.erl:247:Fatal error: internal error
I am trying to use the stomp plugin-2.5.0 with ssl (no certificates yet)
on RabbitMQ-2.5.0 on a Windows 2008R2 server. I have openssl-32bit
installed with VS 2008 Redistributables. Stomp with ssl is a requirement
in our search for the right mq broker.
I know this is not in the docs yet, but I see some unit tests using ssl
with stomp so just seeing if this is fully functional as of 2.5.0.
Thanks in advance for any direction.
-Sam
################ rabbitmq.config #################################
[
{rabbitmq_stomp, [{ssl_listeners, [61614]}]},
{rabbit, [
{ssl_listeners, [5671]},
{ssl_options, [{verify,verify_none},
{fail_if_no_peer_cert,false}]}
]}
].
################ stomp_ssl_test.py ###############################
#!/usr/bin/env python
import stomp # using stomp.py
import time
import logging
import sys
import random
import yaml
logging.basicConfig()
class MyListener(object):
def on_error(self, headers, message):
print 'received an error %s' % message
def on_message(self, headers, message):
print 'received a message %s' % message
dest='/queue/test'
host='192.168.0.108'
# port=61614
# ssl=True
port=61613
ssl=False
conn=stomp.Connection(host_and_ports=[(host,port)], user='guest',
passcode='guest',use_ssl=ssl)
print('set up Connection')
conn.set_listener('somename',MyListener())
print('Set up listener')
conn.start()
print('started connection')
conn.connect(wait=True, headers={'login':'guest', 'passcode':'guest'})
print('connected')
conn.subscribe(destination=dest, ack='auto', headers={})
print('subscribed')
message = 'hi'
headers = {'destination':dest,
'type':'textMessage',
'id': str(random.randint(0,65535)),
'routing_key':'xxxxxx'}
conn.send(message=message, destination=dest,headers=headers,ack='auto')
print('sent message')
time.sleep(2)
print('slept')
conn.disconnect()
print('disconnected')
########################## rabbitmq logging
#######################################
=INFO REPORT==== 15-Jun-2011::10:22:27 ===
accepted TCP connection on 0.0.0.0:61614 from 192.168.0.30:64098
=ERROR REPORT==== 15-Jun-2011::10:22:27 ===
SSL: hello: ./ssl_handshake.erl:247:Fatal error: internal error
=ERROR REPORT==== 15-Jun-2011::10:22:27 ===
** Generic server <0.531.0> terminating
** Last message in was {inet_async,#Port<0.5451>,572,{ok,#Port<0.6286>}}
** When Server state == {state,
{rabbit_stomp_sup,start_ssl_client,
[[{verify,verify_none},
{fail_if_no_peer_cert,false}]]},
#Port<0.5451>,572}
** Reason for termination ==
** {{badmatch,{error,{ssl_upgrade_error,"internal error"}}},
[{rabbit_stomp_sup,start_ssl_client,2},
{tcp_acceptor,handle_info,2},
{gen_server,handle_msg,5},
{proc_lib,init_p_do_apply,3}]}
##################################################################################
More information about the rabbitmq-discuss
mailing list