Skip to content

Commit aaeedc3

Browse files
committed
bug fixed
1 parent a381aad commit aaeedc3

File tree

9 files changed

+6
-2
lines changed

9 files changed

+6
-2
lines changed

bigbang/api/config.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ def init(args, **kwargs):
2121
cfg.CONF.register_opts(api_opts, group=api_config_group)
2222
logging.register_options(cfg.CONF)
2323

24+
rpc.set_defaults(control_exchange='bigbang')
2425
cfg.CONF(args=args, project='bigbang', **kwargs)
2526
rpc.init(cfg.CONF)
2627

bigbang/api/config.pyc

56 Bytes
Binary file not shown.

bigbang/api/controller/v1/person.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,4 +12,5 @@ def index(self):
1212
context = pecan.request.context
1313
persons = pecan.request.rpcapi.get_all_person()
1414
LOG.info('need add person')
15-
return {'message': 'Need add person'}
15+
return persons
16+
# return {'message': 'Need add person'}
-39 Bytes
Binary file not shown.

bigbang/cmd/controller.pyc

0 Bytes
Binary file not shown.

bigbang/controller/api.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,3 +11,4 @@ def __init__(self, transport=None, context=None, topic=None):
1111
def get_all_person(self):
1212
LOG.info('send to MQ')
1313
return self._call('get_all_person')
14+
# return self._cast('get_all_person')

bigbang/controller/api.pyc

0 Bytes
Binary file not shown.

bigbang/controller/manager.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,8 @@
22

33
LOG = logging.getLogger(__name__)
44

5+
56
class Manager(object):
67
def get_all_person(self, context):
78
LOG.info('get message from MQ')
8-
return "there is no person"
9+
return {'message': "there is no person"}

bigbang/controller/manager.pyc

19 Bytes
Binary file not shown.

0 commit comments

Comments
 (0)