### Question:
HistoryService { public URI createTemporalEntityFromEntity(String payload) throws ResponseException, Exception { return createTemporalEntity(payload, true); } HistoryService(ProducerChannel producerChannels); URI createTemporalEntityFromEntity(String payload); URI createTemporalEntityFromBinding(String payload); void delete(String entityId, String attributeId, String instanceId, List<Object> linkHeaders); void addAttrib2TemporalEntity(String entityId, String payload); void modifyAttribInstanceTemporalEntity(String entityId, String payload, String attribId, String instanceId,
			List<Object> linkHeaders); @KafkaListener(topics = "${entity.create.topic}", groupId = "historyManagerCreate") void handleEntityCreate(@Payload byte[] message, @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) String key); @KafkaListener(topics = "${entity.append.topic}", groupId = "historyManagerAppend") void handleEntityAppend(@Payload byte[] message, @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) String key); @KafkaListener(topics = "${entity.update.topic}", groupId = "historyManagerUpdate") void handleEntityUpdate(@Payload byte[] message, @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) String key); @KafkaListener(topics = "${entity.delete.topic}", groupId = "historyManagerDelete") void handleEntityDelete(@Payload byte[] message, @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) String key);  }### Answer:
@Test public void createTemporalEntityFromEntityTest() { try { URI uri1=historyService.createTemporalEntityFromEntity(temporalPayload); verify(kafkaOperations, times(3)).pushToKafka(any(),any(),any()); } catch (Exception e) { Assert.fail(); e.printStackTrace(); } }