changed access modifier

This commit is contained in:
IrynaMatveieva 2024-08-06 17:49:34 +03:00
parent 7eafd4a9d2
commit 333e7927df

View File

@ -129,7 +129,7 @@ public class TbPubSubNode extends TbAbstractExternalNode {
return TbMsg.transformMsgMetadata(origMsg, metaData); return TbMsg.transformMsgMetadata(origMsg, metaData);
} }
protected Publisher initPubSubClient(TbContext ctx) throws IOException { Publisher initPubSubClient(TbContext ctx) throws IOException {
ProjectTopicName topicName = ProjectTopicName.of(config.getProjectId(), config.getTopicName()); ProjectTopicName topicName = ProjectTopicName.of(config.getProjectId(), config.getTopicName());
ServiceAccountCredentials credentials = ServiceAccountCredentials credentials =
ServiceAccountCredentials.fromStream( ServiceAccountCredentials.fromStream(