diff --git a/calexium_lib/net_services/CXM_net_services.anubis b/calexium_lib/net_services/CXM_net_services.anubis index 430b4dd..5c7befa 100644 --- a/calexium_lib/net_services/CXM_net_services.anubis +++ b/calexium_lib/net_services/CXM_net_services.anubis @@ -116,6 +116,9 @@ define One MessageQueue queue, List(NetService) net_services ) = + if queue.quit_requested(uniqe) then + unique + else println("PRE SERVICE message_receiver "+"["+virtual_machine_id + "]"); if queue.get_next_received_Message(1) is { diff --git a/calexium_lib/net_services_protocols/ftp_client.anubis b/calexium_lib/net_services_protocols/ftp_client.anubis index 91e1667..49f306c 100644 --- a/calexium_lib/net_services_protocols/ftp_client.anubis +++ b/calexium_lib/net_services_protocols/ftp_client.anubis @@ -142,7 +142,9 @@ public define Maybe(One) with queue = create_MessageQueue, message_transceiver(conn, queue); if request_for_service(queue) then - get_file(queue, remote_file, local_file) + with result = get_file(queue, remote_file, local_file), + queue.quit(unique); + result else println("Service not found");failure } -- libgit2 0.21.4