Тестовые случаи Junit для Pubsub Publish Message ⇐ JAVA

[Anonymous]

Степень проблемы при написании тестовых примеров JUNIT для кода ниже. < /p>
public String publishJSON(String json) throws InterruptedException, IOException, ExecutionException {
log.info(" Publishing payload to: "+config.getTopicId());
TopicName topicName=TopicName.of(config.getPubsubProjectId(),config.getTopicId());
Publisher publisher=null;
try {
publisher =
Publisher.newBuilder(topicName)
.build();
ByteString data = ByteString.copyFromUtf8(json);
PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data).build();
ApiFuture messageIdFuture = publisher.publish(pubsubMessage);
String messageId = messageIdFuture.get();
log.info("Published message ID: " + messageId);
return messageId;
} catch (ExecutionException e) {
log.error("Error while publishing messsage" + e.getMessage());
throw e;
} catch (IOException e) {
log.error( "PubSub exception "+ e.getMessage());
throw e;
} catch (InterruptedException e) {
log.error("Connection making exception for PubSub" + e.getMessage());
throw e;
} catch (Exception e) {
log.error( "publishJSON Error : "+ e.getMessage());
throw e;
}
finally {
if (publisher != null) {
// When finished with the publisher, shutdown to free up resources.
publisher.shutdown();
publisher.awaitTermination(1, TimeUnit.MINUTES);
}
}
}


Подробнее здесь: https://stackoverflow.com/questions/747 ... sh-message