Skip to content

Commit 18c678d

Browse files
committed
Update translate/pubsub
1 parent c0d769a commit 18c678d

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

appengine-java8/pubsub/src/main/java/com/example/appengine/pubsub/PubSubPublish.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
import com.google.protobuf.ByteString;
2222
import com.google.pubsub.v1.ProjectTopicName;
2323
import com.google.pubsub.v1.PubsubMessage;
24-
import com.google.pubsub.v1.TopicName;
2524
import java.io.IOException;
2625
import javax.servlet.ServletException;
2726
import javax.servlet.annotation.WebServlet;

appengine-java8/translate-pubsub/src/main/java/com/example/appengine/translatepubsub/PubSubPublish.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,8 @@
2020
import com.google.cloud.pubsub.v1.Publisher;
2121
import com.google.gson.Gson;
2222
import com.google.protobuf.ByteString;
23+
import com.google.pubsub.v1.ProjectTopicName;
2324
import com.google.pubsub.v1.PubsubMessage;
24-
import com.google.pubsub.v1.TopicName;
2525
import java.io.IOException;
2626
import javax.servlet.annotation.WebServlet;
2727
import javax.servlet.http.HttpServlet;
@@ -56,7 +56,10 @@ public void doPost(HttpServletRequest req, HttpServletResponse resp) throws IOEx
5656
// create a publisher on the topic
5757
if (publisher == null) {
5858
this.publisher = publisher = Publisher.newBuilder(
59-
TopicName.of(ServiceOptions.getDefaultProjectId(), topicId))
59+
ProjectTopicName.newBuilder()
60+
.setProject(ServiceOptions.getDefaultProjectId())
61+
.setTopic(topicId)
62+
.build())
6063
.build();
6164
}
6265

0 commit comments

Comments
 (0)