test_class.declarator: operations
test_class.modifier: @Mock
test_class.original_string: @Mock
  	KafkaOps operations;
test_class.type: KafkaOps
test_class.var_name: operations
test_class.declarator: objectMapper
test_class.modifier: @MockBean
  	private
test_class.original_string: @MockBean
  	private ObjectMapper objectMapper;
test_class.type: ObjectMapper
test_class.var_name: objectMapper
test_class.declarator: entityTopicMap
test_class.modifier: @MockBean
  	private
test_class.original_string: @MockBean
  	private EntityTopicMap entityTopicMap;
test_class.type: EntityTopicMap
test_class.var_name: entityTopicMap
test_class.declarator: entityProducerChannel
test_class.modifier: @Mock
test_class.original_string: @Mock
  	EntityProducerChannel entityProducerChannel;
test_class.type: EntityProducerChannel
test_class.var_name: entityProducerChannel
test_class.declarator: entityService
test_class.modifier: @InjectMocks
  	@Spy
  	private
test_class.original_string: @InjectMocks
  	@Spy
  	private EntityService entityService;
test_class.type: EntityService
test_class.var_name: entityService
test_class.declarator: thrown = ExpectedException.none()
test_class.modifier: @Rule
  	public
test_class.original_string: @Rule
  	public ExpectedException thrown = ExpectedException.none();
test_class.type: ExpectedException
test_class.var_name: thrown
test_class.declarator: updatePayload
test_class.original_string: String updatePayload;
test_class.type: String
test_class.var_name: updatePayload
test_class.declarator: appendPayload
test_class.original_string: String appendPayload;
test_class.type: String
test_class.var_name: appendPayload
test_class.declarator: entityPayload
test_class.original_string: String entityPayload;
test_class.type: String
test_class.var_name: entityPayload
test_class.declarator: updatePartialAttributesPayload
test_class.original_string: String updatePartialAttributesPayload;
test_class.type: String
test_class.var_name: updatePartialAttributesPayload
test_class.declarator: updatePartialDefaultAttributesPayload
test_class.original_string: String updatePartialDefaultAttributesPayload;
test_class.type: String
test_class.var_name: updatePartialDefaultAttributesPayload
test_class.declarator: updateJsonNode
test_class.original_string: JsonNode updateJsonNode;
test_class.type: JsonNode
test_class.var_name: updateJsonNode
test_class.declarator: appendJsonNode
test_class.original_string: JsonNode appendJsonNode;
test_class.type: JsonNode
test_class.var_name: appendJsonNode
test_class.declarator: blankNode
test_class.original_string: JsonNode blankNode;
test_class.type: JsonNode
test_class.var_name: blankNode
test_class.declarator: payloadNode
test_class.original_string: JsonNode payloadNode;
test_class.type: JsonNode
test_class.var_name: payloadNode
test_class.declarator: updatePartialAttributesNode
test_class.original_string: JsonNode updatePartialAttributesNode;
test_class.type: JsonNode
test_class.var_name: updatePartialAttributesNode
test_class.declarator: updatePartialDefaultAttributesNode
test_class.original_string: JsonNode updatePartialDefaultAttributesNode;
test_class.type: JsonNode
test_class.var_name: updatePartialDefaultAttributesNode
test_class.file: Core/EntityManager/src/test/java/eu/neclab/ngsildbroker/entityhandler/services/EntityServiceTest.java
test_class.identifier: EntityServiceTest
test_case.body: @Test
  	public void updateMessageTest() throws Exception{
  		
  			EntityDetails entityDetails=Mockito.mock(EntityDetails.class);
  			byte[] messageByte=entityPayload.getBytes();
  			JsonNode resultJson = objectMapper.createObjectNode();
  			UpdateResult updateResult = new UpdateResult(updateJsonNode, resultJson);
  			updateResult.setStatus(true);
  			
  			Mockito.doReturn(entityDetails).when(entityTopicMap).get(any());
  			Mockito.doReturn(messageByte).when(operations).getMessage(any(), any(), any(Integer.class), any(Long.class));
  			Mockito.doReturn(payloadNode).when(objectMapper).readTree(any(String.class));
  			Mockito.doReturn(blankNode).when(objectMapper).createObjectNode();
  //			Mockito.doReturn(updateResult).when(entityService).updateFields(messageByte, updateJsonNode, null);
  			//TODO no assert. no usage of result 
  			Mockito.doReturn(updateResult).when(entityService).updateMessage(any(), any());
  			entityService.updateMessage("urn:ngsi-ld:Vehicle:A103", updatePayload);
  			verify(entityService, times(1)).updateMessage(any(),any());
  
  		
  	}
test_case.class_method_signature: EntityServiceTest.updateMessageTest()
test_case.full_signature: @Test public void updateMessageTest()
test_case.identifier: updateMessageTest
test_case.invocations: mock getBytes createObjectNode setStatus get when doReturn any getMessage when doReturn any any any any readTree when doReturn any createObjectNode when doReturn updateMessage when doReturn any any updateMessage updateMessage verify times any any
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void updateMessageTest()
focal_class.declarator: ENTITY_TOPIC
focal_class.modifier: @Value("${entity.topic}")
focal_class.original_string: @Value("${entity.topic}")
  	String ENTITY_TOPIC;
focal_class.type: String
focal_class.var_name: ENTITY_TOPIC
focal_class.declarator: ENTITY_CREATE_TOPIC
focal_class.modifier: @Value("${entity.create.topic}")
focal_class.original_string: @Value("${entity.create.topic}")
  	String ENTITY_CREATE_TOPIC;
focal_class.type: String
focal_class.var_name: ENTITY_CREATE_TOPIC
focal_class.declarator: ENTITY_APPEND_TOPIC
focal_class.modifier: @Value("${entity.append.topic}")
focal_class.original_string: @Value("${entity.append.topic}")
  	String ENTITY_APPEND_TOPIC;
focal_class.type: String
focal_class.var_name: ENTITY_APPEND_TOPIC
focal_class.declarator: ENTITY_UPDATE_TOPIC
focal_class.modifier: @Value("${entity.update.topic}")
focal_class.original_string: @Value("${entity.update.topic}")
  	String ENTITY_UPDATE_TOPIC;
focal_class.type: String
focal_class.var_name: ENTITY_UPDATE_TOPIC
focal_class.declarator: ENTITY_DELETE_TOPIC
focal_class.modifier: @Value("${entity.delete.topic}")
focal_class.original_string: @Value("${entity.delete.topic}")
  	String ENTITY_DELETE_TOPIC;
focal_class.type: String
focal_class.var_name: ENTITY_DELETE_TOPIC
focal_class.declarator: bootstrapServers
focal_class.modifier: @Value("${bootstrap.servers}")
focal_class.original_string: @Value("${bootstrap.servers}")
  	String bootstrapServers;
focal_class.type: String
focal_class.var_name: bootstrapServers
focal_class.declarator: appendOverwriteFlag
focal_class.modifier: @Value("${append.overwrite}")
focal_class.original_string: @Value("${append.overwrite}")
  	String appendOverwriteFlag;
focal_class.type: String
focal_class.var_name: appendOverwriteFlag
focal_class.declarator: ENTITY_INDEX
focal_class.modifier: @Value("${entity.index.topic}")
focal_class.original_string: @Value("${entity.index.topic}")
  	String ENTITY_INDEX;
focal_class.type: String
focal_class.var_name: ENTITY_INDEX
focal_class.declarator: maxCreateBatch
focal_class.modifier: @Value("${batchoperations.maxnumber.create:-1}")
focal_class.original_string: @Value("${batchoperations.maxnumber.create:-1}")
  	int maxCreateBatch;
focal_class.type: int
focal_class.var_name: maxCreateBatch
focal_class.declarator: maxUpdateBatch
focal_class.modifier: @Value("${batchoperations.maxnumber.update:-1}")
focal_class.original_string: @Value("${batchoperations.maxnumber.update:-1}")
  	int maxUpdateBatch;
focal_class.type: int
focal_class.var_name: maxUpdateBatch
focal_class.declarator: maxUpsertBatch
focal_class.modifier: @Value("${batchoperations.maxnumber.upsert:-1}")
focal_class.original_string: @Value("${batchoperations.maxnumber.upsert:-1}")
  	int maxUpsertBatch;
focal_class.type: int
focal_class.var_name: maxUpsertBatch
focal_class.declarator: maxDeleteBatch
focal_class.modifier: @Value("${batchoperations.maxnumber.delete:-1}")
focal_class.original_string: @Value("${batchoperations.maxnumber.delete:-1}")
  	int maxDeleteBatch;
focal_class.type: int
focal_class.var_name: maxDeleteBatch
focal_class.declarator: directDB = true
focal_class.original_string: boolean directDB = true;
focal_class.type: boolean
focal_class.var_name: directDB
focal_class.declarator: storageWriterDao
focal_class.modifier: @Autowired
  	@Qualifier("emstorage")
focal_class.original_string: @Autowired
  	@Qualifier("emstorage")
  	StorageWriterDAO storageWriterDao;
focal_class.type: StorageWriterDAO
focal_class.var_name: storageWriterDao
focal_class.declarator: entityInfoDAO
focal_class.modifier: @Autowired
focal_class.original_string: @Autowired
  	EntityInfoDAO entityInfoDAO;
focal_class.type: EntityInfoDAO
focal_class.var_name: entityInfoDAO
focal_class.declarator: operations
focal_class.modifier: @Autowired
  	@Qualifier("emops")
focal_class.original_string: @Autowired
  	@Qualifier("emops")
  	KafkaOps operations;
focal_class.type: KafkaOps
focal_class.var_name: operations
focal_class.declarator: paramsResolver
focal_class.modifier: @Autowired
  	@Qualifier("emparamsres")
focal_class.original_string: @Autowired
  	@Qualifier("emparamsres")
  	ParamsResolver paramsResolver;
focal_class.type: ParamsResolver
focal_class.var_name: paramsResolver
focal_class.declarator: regexNgsildAttributeTypes = new String(NGSIConstants.NGSI_LD_PROPERTY + "|"
  			+ NGSIConstants.NGSI_LD_RELATIONSHIP + "|" + NGSIConstants.NGSI_LD_GEOPROPERTY)
focal_class.modifier: final private
focal_class.original_string: final private String regexNgsildAttributeTypes = new String(NGSIConstants.NGSI_LD_PROPERTY + "|"
  			+ NGSIConstants.NGSI_LD_RELATIONSHIP + "|" + NGSIConstants.NGSI_LD_GEOPROPERTY);
focal_class.type: String
focal_class.var_name: regexNgsildAttributeTypes
focal_class.declarator: objectMapper
focal_class.original_string: ObjectMapper objectMapper;
focal_class.type: ObjectMapper
focal_class.var_name: objectMapper
focal_class.declarator: eurekaClient
focal_class.modifier: @Autowired
  	private
focal_class.original_string: @Autowired
  	private EurekaClient eurekaClient;
focal_class.type: EurekaClient
focal_class.var_name: eurekaClient
focal_class.declarator: contextResolver
focal_class.modifier: @Autowired
  	@Qualifier("emconRes")
focal_class.original_string: @Autowired
  	@Qualifier("emconRes")
  	ContextResolverBasic contextResolver;
focal_class.type: ContextResolverBasic
focal_class.var_name: contextResolver
focal_class.declarator: producerChannels
focal_class.modifier: private final
focal_class.original_string: private final EntityProducerChannel producerChannels;
focal_class.type: EntityProducerChannel
focal_class.var_name: producerChannels
focal_class.declarator: start
focal_class.original_string: LocalDateTime start;
focal_class.type: LocalDateTime
focal_class.var_name: start
focal_class.declarator: end
focal_class.original_string: LocalDateTime end;
focal_class.type: LocalDateTime
focal_class.var_name: end
focal_class.declarator: entityIds = new HashSet<String>()
focal_class.modifier: private
focal_class.original_string: private Set<String> entityIds = new HashSet<String>();
focal_class.type: Set<String>
focal_class.var_name: entityIds
focal_class.declarator: logger = LogManager.getLogger(EntityService.class)
focal_class.modifier: private final static
focal_class.original_string: private final static Logger logger = LogManager.getLogger(EntityService.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.file: Core/EntityManager/src/main/java/eu/neclab/ngsildbroker/entityhandler/services/EntityService.java
focal_class.identifier: EntityService
focal_class.class_method_signature: EntityService.setOperations(KafkaOps operations)
focal_class.full_signature: public void setOperations(KafkaOps operations)
focal_class.identifier: setOperations
focal_class.modifiers: public
focal_class.parameters: (KafkaOps operations)
focal_class.return: void
focal_class.signature: void setOperations(KafkaOps operations)
focal_class.class_method_signature: EntityService.EntityService(EntityProducerChannel producerChannels, ObjectMapper objectMapper)
focal_class.full_signature: public  EntityService(EntityProducerChannel producerChannels, ObjectMapper objectMapper)
focal_class.identifier: EntityService
focal_class.modifiers: public
focal_class.parameters: (EntityProducerChannel producerChannels, ObjectMapper objectMapper)
focal_class.signature:  EntityService(EntityProducerChannel producerChannels, ObjectMapper objectMapper)
focal_class.class_method_signature: EntityService.loadStoredEntitiesDetails()
focal_class.full_signature: @PostConstruct private void loadStoredEntitiesDetails()
focal_class.identifier: loadStoredEntitiesDetails
focal_class.modifiers: @PostConstruct private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void loadStoredEntitiesDetails()
focal_class.class_method_signature: EntityService.createMessage(String payload)
focal_class.full_signature: public String createMessage(String payload)
focal_class.identifier: createMessage
focal_class.modifiers: public
focal_class.parameters: (String payload)
focal_class.return: String
focal_class.signature: String createMessage(String payload)
focal_class.class_method_signature: EntityService.pushToDB(String key, String payload, String withoutSysAttrs, String kv)
focal_class.full_signature: private void pushToDB(String key, String payload, String withoutSysAttrs, String kv)
focal_class.identifier: pushToDB
focal_class.modifiers: private
focal_class.parameters: (String key, String payload, String withoutSysAttrs, String kv)
focal_class.return: void
focal_class.signature: void pushToDB(String key, String payload, String withoutSysAttrs, String kv)
focal_class.class_method_signature: EntityService.getKeyValueEntity(JsonNode json)
focal_class.full_signature: public JsonNode getKeyValueEntity(JsonNode json)
focal_class.identifier: getKeyValueEntity
focal_class.modifiers: public
focal_class.parameters: (JsonNode json)
focal_class.return: JsonNode
focal_class.signature: JsonNode getKeyValueEntity(JsonNode json)
focal_class.class_method_signature: EntityService.setTemporalProperties(JsonNode jsonNode, String createdAt, String modifiedAt, boolean rootOnly)
focal_class.full_signature: private void setTemporalProperties(JsonNode jsonNode, String createdAt, String modifiedAt, boolean rootOnly)
focal_class.identifier: setTemporalProperties
focal_class.modifiers: private
focal_class.parameters: (JsonNode jsonNode, String createdAt, String modifiedAt, boolean rootOnly)
focal_class.return: void
focal_class.signature: void setTemporalProperties(JsonNode jsonNode, String createdAt, String modifiedAt, boolean rootOnly)
focal_class.class_method_signature: EntityService.removeTemporalProperties(JsonNode jsonNode)
focal_class.full_signature: private void removeTemporalProperties(JsonNode jsonNode)
focal_class.identifier: removeTemporalProperties
focal_class.modifiers: private
focal_class.parameters: (JsonNode jsonNode)
focal_class.return: void
focal_class.signature: void removeTemporalProperties(JsonNode jsonNode)
focal_class.class_method_signature: EntityService.updateMessage(String entityId, String payload)
focal_class.full_signature: public UpdateResult updateMessage(String entityId, String payload)
focal_class.identifier: updateMessage
focal_class.modifiers: public
focal_class.parameters: (String entityId, String payload)
focal_class.return: UpdateResult
focal_class.signature: UpdateResult updateMessage(String entityId, String payload)
focal_class.class_method_signature: EntityService.validateIdAndGetBody(String entityId)
focal_class.full_signature: private String validateIdAndGetBody(String entityId)
focal_class.identifier: validateIdAndGetBody
focal_class.modifiers: private
focal_class.parameters: (String entityId)
focal_class.return: String
focal_class.signature: String validateIdAndGetBody(String entityId)
focal_class.class_method_signature: EntityService.appendMessage(String entityId, String payload, String overwriteOption)
focal_class.full_signature: public AppendResult appendMessage(String entityId, String payload, String overwriteOption)
focal_class.identifier: appendMessage
focal_class.modifiers: public
focal_class.parameters: (String entityId, String payload, String overwriteOption)
focal_class.return: AppendResult
focal_class.signature: AppendResult appendMessage(String entityId, String payload, String overwriteOption)
focal_class.class_method_signature: EntityService.deleteEntity(String entityId)
focal_class.full_signature: public boolean deleteEntity(String entityId)
focal_class.identifier: deleteEntity
focal_class.modifiers: public
focal_class.parameters: (String entityId)
focal_class.return: boolean
focal_class.signature: boolean deleteEntity(String entityId)
focal_class.class_method_signature: EntityService.partialUpdateEntity(String entityId, String attrId, String payload)
focal_class.full_signature: public UpdateResult partialUpdateEntity(String entityId, String attrId, String payload)
focal_class.identifier: partialUpdateEntity
focal_class.modifiers: public
focal_class.parameters: (String entityId, String attrId, String payload)
focal_class.return: UpdateResult
focal_class.signature: UpdateResult partialUpdateEntity(String entityId, String attrId, String payload)
focal_class.class_method_signature: EntityService.deleteAttribute(String entityId, String attrId,String datasetId,String deleteAll)
focal_class.full_signature: public boolean deleteAttribute(String entityId, String attrId,String datasetId,String deleteAll)
focal_class.identifier: deleteAttribute
focal_class.modifiers: public
focal_class.parameters: (String entityId, String attrId,String datasetId,String deleteAll)
focal_class.return: boolean
focal_class.signature: boolean deleteAttribute(String entityId, String attrId,String datasetId,String deleteAll)
focal_class.class_method_signature: EntityService.updateFields(String originalJsonObject, JsonNode jsonToUpdate, String attrId)
focal_class.full_signature: public UpdateResult updateFields(String originalJsonObject, JsonNode jsonToUpdate, String attrId)
focal_class.identifier: updateFields
focal_class.modifiers: public
focal_class.parameters: (String originalJsonObject, JsonNode jsonToUpdate, String attrId)
focal_class.return: UpdateResult
focal_class.signature: UpdateResult updateFields(String originalJsonObject, JsonNode jsonToUpdate, String attrId)
focal_class.class_method_signature: EntityService.appendFields(String originalJsonObject, JsonNode jsonToAppend, String overwriteOption)
focal_class.full_signature: public AppendResult appendFields(String originalJsonObject, JsonNode jsonToAppend, String overwriteOption)
focal_class.identifier: appendFields
focal_class.modifiers: public
focal_class.parameters: (String originalJsonObject, JsonNode jsonToAppend, String overwriteOption)
focal_class.return: AppendResult
focal_class.signature: AppendResult appendFields(String originalJsonObject, JsonNode jsonToAppend, String overwriteOption)
focal_class.class_method_signature: EntityService.deleteFields(String originalJsonObject, String attrId, String datasetId, String deleteAll)
focal_class.full_signature: public JsonNode deleteFields(String originalJsonObject, String attrId, String datasetId, String deleteAll)
focal_class.identifier: deleteFields
focal_class.modifiers: public
focal_class.parameters: (String originalJsonObject, String attrId, String datasetId, String deleteAll)
focal_class.return: JsonNode
focal_class.signature: JsonNode deleteFields(String originalJsonObject, String attrId, String datasetId, String deleteAll)
focal_class.class_method_signature: EntityService.registerContext(byte[] id, byte[] payload)
focal_class.full_signature: public boolean registerContext(byte[] id, byte[] payload)
focal_class.identifier: registerContext
focal_class.modifiers: public
focal_class.parameters: (byte[] id, byte[] payload)
focal_class.return: boolean
focal_class.signature: boolean registerContext(byte[] id, byte[] payload)
focal_class.class_method_signature: EntityService.updateContext(byte[] id, byte[] payload)
focal_class.full_signature: private void updateContext(byte[] id, byte[] payload)
focal_class.identifier: updateContext
focal_class.modifiers: private
focal_class.parameters: (byte[] id, byte[] payload)
focal_class.return: void
focal_class.signature: void updateContext(byte[] id, byte[] payload)
focal_class.class_method_signature: EntityService.getCSourceRegistrationFromJson(byte[] payload)
focal_class.full_signature: private CSourceRegistration getCSourceRegistrationFromJson(byte[] payload)
focal_class.identifier: getCSourceRegistrationFromJson
focal_class.modifiers: private
focal_class.parameters: (byte[] payload)
focal_class.return: CSourceRegistration
focal_class.signature: CSourceRegistration getCSourceRegistrationFromJson(byte[] payload)
focal_class.class_method_signature: EntityService.getCoveringGeoValue(GeoProperty geoLocationProperty)
focal_class.full_signature: private Geometry<?> getCoveringGeoValue(GeoProperty geoLocationProperty)
focal_class.identifier: getCoveringGeoValue
focal_class.modifiers: private
focal_class.parameters: (GeoProperty geoLocationProperty)
focal_class.return: Geometry<?>
focal_class.signature: Geometry<?> getCoveringGeoValue(GeoProperty geoLocationProperty)
focal_class.class_method_signature: EntityService.getResourceURL(String resource)
focal_class.full_signature: public URI getResourceURL(String resource)
focal_class.identifier: getResourceURL
focal_class.modifiers: public
focal_class.parameters: (String resource)
focal_class.return: URI
focal_class.signature: URI getResourceURL(String resource)
focal_class.class_method_signature: EntityService.validateEntity(String payload, HttpServletRequest request)
focal_class.full_signature: public void validateEntity(String payload, HttpServletRequest request)
focal_class.identifier: validateEntity
focal_class.modifiers: public
focal_class.parameters: (String payload, HttpServletRequest request)
focal_class.return: void
focal_class.signature: void validateEntity(String payload, HttpServletRequest request)
focal_class.class_method_signature: EntityService.createMultipleMessage(String payload)
focal_class.full_signature: public BatchResult createMultipleMessage(String payload)
focal_class.identifier: createMultipleMessage
focal_class.modifiers: public
focal_class.parameters: (String payload)
focal_class.return: BatchResult
focal_class.signature: BatchResult createMultipleMessage(String payload)
focal_class.class_method_signature: EntityService.deleteMultipleMessage(String payload)
focal_class.full_signature: public BatchResult deleteMultipleMessage(String payload)
focal_class.identifier: deleteMultipleMessage
focal_class.modifiers: public
focal_class.parameters: (String payload)
focal_class.return: BatchResult
focal_class.signature: BatchResult deleteMultipleMessage(String payload)
focal_class.class_method_signature: EntityService.updateMultipleMessage(String resolved)
focal_class.full_signature: public BatchResult updateMultipleMessage(String resolved)
focal_class.identifier: updateMultipleMessage
focal_class.modifiers: public
focal_class.parameters: (String resolved)
focal_class.return: BatchResult
focal_class.signature: BatchResult updateMultipleMessage(String resolved)
focal_class.class_method_signature: EntityService.upsertMultipleMessage(String resolved)
focal_class.full_signature: public BatchResult upsertMultipleMessage(String resolved)
focal_class.identifier: upsertMultipleMessage
focal_class.modifiers: public
focal_class.parameters: (String resolved)
focal_class.return: BatchResult
focal_class.signature: BatchResult upsertMultipleMessage(String resolved)
focal_class.class_method_signature: EntityService.setFieldValue(Iterator<String> it, JsonNode innerNode, JsonNode jsonToUpdate, UpdateResult updateResult,
  			int i)
focal_class.full_signature: private void setFieldValue(Iterator<String> it, JsonNode innerNode, JsonNode jsonToUpdate, UpdateResult updateResult,
  			int i)
focal_class.identifier: setFieldValue
focal_class.modifiers: private
focal_class.parameters: (Iterator<String> it, JsonNode innerNode, JsonNode jsonToUpdate, UpdateResult updateResult,
  			int i)
focal_class.return: void
focal_class.signature: void setFieldValue(Iterator<String> it, JsonNode innerNode, JsonNode jsonToUpdate, UpdateResult updateResult,
  			int i)
focal_method.body: public UpdateResult updateMessage(String entityId, String payload) throws ResponseException, Exception {
  		logger.trace("updateMessage() :: started");
  		// get message channel for ENTITY_UPDATE topic
  		MessageChannel messageChannel = producerChannels.updateWriteChannel();
  		String entityBody = validateIdAndGetBody(entityId);
  		/*
  		 * String payloadResolved=contextResolver.applyContext(payload);
  		 * System.out.println(payloadResolved); String
  		 * original=contextResolver.applyContext(new String(originalJson),
  		 * contextResolver.getContext(entityId));
  		 * System.out.println("origial :: "+original);
  		 */
  		// update fields
  		JsonNode updateNode = objectMapper.readTree(payload);
  		UpdateResult updateResult = this.updateFields(entityBody, updateNode, null);
  		// pubilsh merged message
  		// & check if anything is changed.
  		if (updateResult.getStatus()) {
  			if (directDB) {
  				String entityWithoutSysAttrs = new String(updateResult.getJsonWithoutSysAttrs());
  				String withSysAttrs = new String(updateResult.getJson());
  				try {
  					pushToDB(entityId, withSysAttrs, entityWithoutSysAttrs,
  							objectMapper.writeValueAsString(getKeyValueEntity(objectMapper.readTree(withSysAttrs))));
  				} catch (JsonProcessingException e) {
  					// TODO Auto-generated catch block
  					e.printStackTrace();
  				}
  
  			}
  			new Thread() {
  				public void run() {
  					try {
  						operations.pushToKafka(messageChannel, entityId.getBytes(NGSIConstants.ENCODE_FORMAT),
  								updateResult.getAppendedJsonFields().toString().getBytes());
  						updateContext(entityId.getBytes(NGSIConstants.ENCODE_FORMAT), updateResult.getJson());
  					} catch (UnsupportedEncodingException e) {
  						// TODO Auto-generated catch block
  						e.printStackTrace();
  					} catch (ResponseException e) {
  						// TODO Auto-generated catch block
  						e.printStackTrace();
  					}
  				};
  			}.start();
  		}
  		logger.trace("updateMessage() :: completed");
  		return updateResult;
  	}
focal_method.class_method_signature: EntityService.updateMessage(String entityId, String payload)
focal_method.full_signature: public UpdateResult updateMessage(String entityId, String payload)
focal_method.identifier: updateMessage
focal_method.invocations: trace updateWriteChannel validateIdAndGetBody readTree updateFields getStatus getJsonWithoutSysAttrs getJson pushToDB writeValueAsString getKeyValueEntity readTree printStackTrace start pushToKafka getBytes getBytes toString getAppendedJsonFields updateContext getBytes getJson printStackTrace printStackTrace trace
focal_method.modifiers: public
focal_method.parameters: (String entityId, String payload)
focal_method.return: UpdateResult
focal_method.signature: UpdateResult updateMessage(String entityId, String payload)