CollectOperationManager { public static void storeOperationParameters(MethodInvocationProceedingJoinPoint joinPoint, Long returnValue) { if (!enabledDataCollection()) { return; } try { Map<String, Object> operation = getCommonParameters(joinPoint); operation.put(CollectionConstants.TASK_ID, returnValue); synchronized (operations) { operations.add(operation); } } catch (Throwable t) { logger.error("Got exception when store operation parameters.", t); } }  void sendData(Map<String, Object> rawOperationData); ITimelyCollectionService getTimelyCollectionService(); void setTimelyCollectionService(
         ITimelyCollectionService timelyCollectionService); static void storeOperationParameters(MethodInvocationProceedingJoinPoint joinPoint, Long returnValue); static void storeOperationParameters(MethodInvocationProceedingJoinPoint joinPoint); CollectionDriverManager getCollectionDriverManager(); void setCollectionDriverManager(
         CollectionDriverManager collectionDriverManager); List<Map<String, Object>> consumeOperations();  }
@Test(groups = { "TestCollectOperationManager" }) public void testStoreOperationParameters() { CollectOperationManager.storeOperationParameters(joinPoint); List<Map<String, Object>> restData = collectOperationManager.consumeOperations(); assertEquals(restData.size(), 1); assertEquals(restData.get(0).size(), 6); assertEquals(restData.get(0).get("operation_name"), "getClusters"); assertEquals(restData.get(0).get("operation_status"), "COMPLETED"); List params = (List)restData.get(0).get("operation_parameters"); assertEquals(params.get(0), false); }