@@ -30,7 +30,8 @@ groups() ->
3030 parse_uri_case4 ,
3131 parse_uri_case5 ,
3232 parse_uri_case6 ,
33- parse_uri_case7
33+ parse_uri_case7 ,
34+ parse_uri_case8
3435 ]}
3536 ].
3637
@@ -51,60 +52,70 @@ parse_uri_case1(_) ->
5152 URI = " amqp://target.hostname:5672" ,
5253 {ok , Result } = amqp10_client :parse_uri (URI ),
5354
54- ? assertEqual (maps :get (address , Result ), " target.hostname " ),
55- ? assertEqual (maps :get (port , Result ), 5672 ),
56- ? assertEqual (maps :get (sasl , Result ), anon ),
57- ? assertEqual (maps :get (tls_opts , Result , undefined ), undefined ).
55+ ? assertEqual (" target.hostname " , maps :get (address , Result )),
56+ ? assertEqual (5672 , maps :get (port , Result ), 5672 ),
57+ ? assertEqual (anon , maps :get (sasl , Result ), anon ),
58+ ? assertEqual (undefined , maps :get (tls_opts , Result , undefined ), undefined ).
5859
5960parse_uri_case2 (_ ) ->
6061 URI = " amqps://target.hostname:5671" ,
6162 {ok , Result } = amqp10_client :parse_uri (URI ),
6263
63- ? assertEqual (maps :get (address , Result ), " target.hostname " ),
64- ? assertEqual (maps :get (port , Result ), 5671 ),
64+ ? assertEqual (" target.hostname " , maps :get (address , Result )),
65+ ? assertEqual (5671 , maps :get (port , Result )),
6566 ? assertMatch ({secure_port , _ }, maps :get (tls_opts , Result )).
6667
6768parse_uri_case3 (_ ) ->
6869 URI = " amqp://target.hostname" ,
6970 {ok , Result } = amqp10_client :parse_uri (URI ),
7071
71- ? assertEqual (maps :get (address , Result ), " target.hostname " ),
72- ? assertEqual (maps :get (port , Result ), 5672 ).
72+ ? assertEqual (" target.hostname " , maps :get (address , Result )),
73+ ? assertEqual (5672 , maps :get (port , Result )).
7374
7475parse_uri_case4 (_ ) ->
7576 URI = " amqp://username:[email protected] " ,
7677 {ok , Result } = amqp10_client :parse_uri (URI ),
7778
78- ? assertEqual (maps :get (address , Result ), " target.hostname " ),
79- ? assertEqual (maps :get (port , Result ), 5672 ),
80- ? assertEqual (maps : get ( sasl , Result ), {plain , <<" username" >>, <<" secre7" >>}).
79+ ? assertEqual (" target.hostname " , maps :get (address , Result )),
80+ ? assertEqual (5672 , maps :get (port , Result )),
81+ ? assertEqual ({plain , <<" username" >>, <<" secre7" >>}, maps : get ( sasl , Result ) ).
8182
8283parse_uri_case5 (_ ) ->
8384 URI = " amqp://username:[email protected] ?container_id=container9&hostname=vhost:abc" ,
8485 {ok , Result } = amqp10_client :parse_uri (URI ),
85- ct : pal ( " ~tp " , [ Result ]),
86- ? assertEqual (maps :get (address , Result ), " target.hostname " ),
87- ? assertEqual (maps :get (port , Result ), 5672 ),
88- ? assertEqual (maps : get ( sasl , Result ), {plain , <<" username" >>, <<" secre7" >>}),
89- ? assertEqual (maps :get (container_id , Result ), << " container9 " >> ),
90- ? assertEqual (maps : get ( hostname , Result ), <<" vhost:abc" >>).
86+
87+ ? assertEqual (" target.hostname " , maps :get (address , Result )),
88+ ? assertEqual (5672 , maps :get (port , Result )),
89+ ? assertEqual ({plain , <<" username" >>, <<" secre7" >>}, maps : get ( sasl , Result ) ),
90+ ? assertEqual (<< " container9 " >>, maps :get (container_id , Result )),
91+ ? assertEqual (<<" vhost:abc" >>, maps : get ( hostname , Result ) ).
9192
9293parse_uri_case6 (_ ) ->
9394 URI = " amqp://username:[email protected] ?container_id=container7&vhost=abc" ,
9495 {ok , Result } = amqp10_client :parse_uri (URI ),
95- ct : pal ( " ~tp " , [ Result ]),
96- ? assertEqual (maps :get (address , Result ), " target.hostname " ),
97- ? assertEqual (maps :get (port , Result ), 5672 ),
98- ? assertEqual (maps : get ( sasl , Result ), {plain , <<" username" >>, <<" secre7" >>}),
99- ? assertEqual (maps :get (container_id , Result ), << " container7 " >> ),
100- ? assertEqual (maps : get ( hostname , Result ), <<" vhost:abc" >>).
96+
97+ ? assertEqual (" target.hostname " , maps :get (address , Result )),
98+ ? assertEqual (5672 , maps :get (port , Result )),
99+ ? assertEqual ({plain , <<" username" >>, <<" secre7" >>}, maps : get ( sasl , Result ) ),
100+ ? assertEqual (<< " container7 " >>, maps :get (container_id , Result )),
101+ ? assertEqual (<<" vhost:abc" >>, maps : get ( hostname , Result ) ).
101102
102103parse_uri_case7 (_ ) ->
103104 URI = " amqp://username:[email protected] /abc?container_id=container5" ,
104105 {ok , Result } = amqp10_client :parse_uri (URI ),
105- ct :pal (" ~tp " , [Result ]),
106- ? assertEqual (maps :get (address , Result ), " target.hostname" ),
107- ? assertEqual (maps :get (port , Result ), 5672 ),
108- ? assertEqual (maps :get (sasl , Result ), {plain , <<" username" >>, <<" secre7" >>}),
109- ? assertEqual (maps :get (container_id , Result ), <<" container5" >>),
110- ? assertEqual (maps :get (hostname , Result ), <<" vhost:abc" >>).
106+
107+ ? assertEqual (" target.hostname" , maps :get (address , Result )),
108+ ? assertEqual (5672 , maps :get (port , Result )),
109+ ? assertEqual ({plain , <<" username" >>, <<" secre7" >>}, maps :get (sasl , Result )),
110+ ? assertEqual (<<" container5" >>, maps :get (container_id , Result )),
111+ ? assertEqual (<<" vhost:abc" >>, maps :get (hostname , Result )).
112+
113+ parse_uri_case8 (_ ) ->
114+ URI = " amqp://username:[email protected] /abc?container_id=container10&hostname=vhost:def&vhost=ghi" ,
115+ {ok , Result } = amqp10_client :parse_uri (URI ),
116+
117+ ? assertEqual (" target.hostname" , maps :get (address , Result )),
118+ ? assertEqual (5672 , maps :get (port , Result )),
119+ ? assertEqual ({plain , <<" username" >>, <<" secre7" >>}, maps :get (sasl , Result )),
120+ ? assertEqual (<<" container10" >>, maps :get (container_id , Result )),
121+ ? assertEqual (<<" vhost:ghi" >>, maps :get (hostname , Result )).
0 commit comments