def cast(context, topic, msg):
    return _get_impl().cast(CONF, context, topic, msg)
Stopping the service while waiting to reconnect should abort.
dataset/ETHPy150Open Havate/havate-openstack/proto-build/gui/horizon/Horizon_GUI/openstack_dashboard/openstack/common/rpc/__init__.py/cast--crossover with--dataset/ETHPy150Open dustin/twitty-twister/twittytwister/test/test_twitter.py/TwitterMonitorTest.test_stopServiceConnected