HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
test_transport_ServerConnectionBuilder.py
Go to the documentation of this file.
1 '''
2 Created on Feb 25, 2014
3 
4 @author: igor
5 '''
6 
7 import unittest
8 from mock import MagicMock, call
9 import zmq
10 from transport.ServerConnectionBuilder import ServerConnectionBuilder
11 from transport.Connection import ConnectionParams
12 
13 
14 class TestServerConnectionBuilder(unittest.TestCase):
15 
16 
18  ctx_mock = MagicMock(spec=zmq.Context)
19  socket_mock = MagicMock(spec=zmq.Socket)
20 
21  ctx_mock_cfg = {"socket.return_value":socket_mock}
22  ctx_mock.configure_mock(**ctx_mock_cfg)
23 
24  socket_expect_calls = [call.bind("tcp://10.0.0.1:1024")]
25 
26  connect_params = ConnectionParams("tcp://10.0.0.1", 1024)
27  server_connect_builder = ServerConnectionBuilder()
28 
29  server_connect_builder.zmq_context = ctx_mock
30 
31  server_connect = server_connect_builder.build(connect_params)
32 
33  self.assertIn(socket_expect_calls, socket_mock.mock_calls,
34  "server connect is wrong initialized")
It's a wrapper for building server side endpoint.