1919pubsub = gcloud . pubsub
2020# [END create_pubsub_client]
2121
22- # [START create_topic]
2322def create_topic
23+ # [START create_topic]
2424 gcloud = Gcloud . new "my-gcp-project-id"
2525 pubsub = gcloud . pubsub
2626
2727 topic = pubsub . create_topic "my-topic"
2828
2929 puts "Topic created #{ topic . name } "
30+ # [END create_topic]
3031end
31- # [END create_topic]
3232
33- # [START create_subscription]
3433def create_subscription
34+ # [START create_subscription]
3535 gcloud = Gcloud . new "my-gcp-project-id"
3636 pubsub = gcloud . pubsub
3737 topic = pubsub . topic "my-topic"
3838
3939 subscription = topic . subscribe "my-subscription"
4040
4141 puts "Subscription created #{ subscription . name } "
42+ # [END create_subscription]
4243end
43- # [END create_subscription]
4444
45- # [START create_push_subscription]
4645def create_push_subscription
46+ # [START create_push_subscription]
4747 gcloud = Gcloud . new "my-gcp-project-id"
4848 pubsub = gcloud . pubsub
4949 topic = pubsub . topic "my-topic"
@@ -54,21 +54,21 @@ def create_push_subscription
5454 )
5555
5656 puts "Push subscription created #{ subscription . name } "
57+ # [END create_push_subscription]
5758end
58- # [END create_push_subscription]
5959
60- # [START publish_message]
6160def publish_message
61+ # [START publish_message]
6262 gcloud = Gcloud . new "my-gcp-project-id"
6363 pubsub = gcloud . pubsub
6464 topic = pubsub . topic "my-topic"
6565
6666 topic . publish "A Message"
67+ # [END publish_message]
6768end
68- # [END publish_message]
6969
70- # [START pull_messages]
7170def pull_messages
71+ # [START pull_messages]
7272 gcloud = Gcloud . new "my-gcp-project-id"
7373 pubsub = gcloud . pubsub
7474 subscription = pubsub . subscription "my-subscription"
@@ -78,11 +78,11 @@ def pull_messages
7878 puts message . data
7979 message . acknowledge!
8080 end
81+ # [END pull_messages]
8182end
82- # [END pull_messages]
8383
84- # [START list_topics]
8584def list_topics
85+ # [START list_topics]
8686 gcloud = Gcloud . new "my-gcp-project-id"
8787 pubsub = gcloud . pubsub
8888 topics = pubsub . topics
@@ -91,11 +91,11 @@ def list_topics
9191 topics . each do |topic |
9292 puts topic . name
9393 end
94+ # [END list_topics]
9495end
95- # [END list_topics]
9696
97- # [START list_subscriptions]
9897def list_subscriptions
98+ # [START list_subscriptions]
9999 gcloud = Gcloud . new "my-gcp-project-id"
100100 pubsub = gcloud . pubsub
101101 subscriptions = pubsub . subscriptions
@@ -104,11 +104,11 @@ def list_subscriptions
104104 subscriptions . each do |subscription |
105105 puts subscription . name
106106 end
107+ # [END list_subscriptions]
107108end
108- # [END list_subscriptions]
109109
110- # [START print_topic_policy]
111- def print_topic_policy
110+ def get_topic_policy
111+ # [START get_topic_policy]
112112 gcloud = Gcloud . new "my-gcp-project-id"
113113 pubsub = gcloud . pubsub
114114 topic = pubsub . topic "my-topic"
@@ -117,11 +117,11 @@ def print_topic_policy
117117
118118 puts "Topic policy:"
119119 puts policy . roles
120+ # [END get_topic_policy]
120121end
121- # [END print_topic_policy]
122122
123- # [START print_subscription_policy]
124- def print_subscription_policy
123+ def get_subscription_policy
124+ # [START get_subscription_policy]
125125 gcloud = Gcloud . new "my-gcp-project-id"
126126 pubsub = gcloud . pubsub
127127 subscription = pubsub . subscription "my-subscription"
@@ -130,11 +130,11 @@ def print_subscription_policy
130130
131131 puts "Subscription policy:"
132132 puts policy . roles
133+ # [END get_subscription_policy]
133134end
134- # [END print_subscription_policy]
135135
136- # [START set_subscription_policy]
137136def set_subscription_policy
137+ # [START set_subscription_policy]
138138 gcloud = Gcloud . new "my-gcp-project-id"
139139 pubsub = gcloud . pubsub
140140 subscription = pubsub . subscription "my-subscription"
@@ -145,11 +145,11 @@ def set_subscription_policy
145145 end
146146
147147 puts subscription . policy . roles
148+ # [END set_subscription_policy]
148149end
149- # [END set_subscription_policy]
150150
151- # [START set_topic_policy]
152151def set_topic_policy
152+ # [START set_topic_policy]
153153 gcloud = Gcloud . new "my-gcp-project-id"
154154 pubsub = gcloud . pubsub
155155 topic = pubsub . topic "my-topic"
@@ -160,11 +160,11 @@ def set_topic_policy
160160 end
161161
162162 puts topic . policy . roles
163+ # [END set_topic_policy]
163164end
164- # [END set_topic_policy]
165165
166- # [START test_subscription_permissions]
167166def test_subscription_permissions
167+ # [START test_subscription_permissions]
168168 gcloud = Gcloud . new "my-gcp-project-id"
169169 pubsub = gcloud . pubsub
170170 subscription = pubsub . subscription "my-subscription"
@@ -174,11 +174,11 @@ def test_subscription_permissions
174174
175175 puts permissions . include? "pubsub.subscriptions.consume"
176176 puts permissions . include? "pubsub.subscriptions.update"
177+ # [END test_subscription_permissions]
177178end
178- # [END test_subscription_permissions]
179179
180- # [START test_topic_permissions]
181180def test_topic_permissions
181+ # [START test_topic_permissions]
182182 gcloud = Gcloud . new "my-gcp-project-id"
183183 pubsub = gcloud . pubsub
184184 topic = pubsub . topic "my-topic"
@@ -190,5 +190,5 @@ def test_topic_permissions
190190 puts permissions . include? "pubsub.topics.attachSubscription"
191191 puts permissions . include? "pubsub.topics.publish"
192192 puts permissions . include? "pubsub.topics.update"
193+ # [END test_topic_permissions]
193194end
194- # [END test_topic_permissions]
0 commit comments