Skip to content

Commit b339942

Browse files
docs: update pubsub example (GoogleCloudPlatform#107)
1 parent 05755f9 commit b339942

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

README.md

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -112,26 +112,26 @@ contents:
112112
```java
113113
package com.example;
114114

115-
import com.example.PubSubBackground.PubSubMessage;
116115
import com.google.cloud.functions.BackgroundFunction;
117116
import com.google.cloud.functions.Context;
118117
import java.util.Map;
119118
import java.util.logging.Logger;
120119

120+
// This is the Pub/Sub message format from the Pub/Sub emulator.
121+
class PubSubMessage {
122+
String data;
123+
Map<String, String> attributes;
124+
String messageId;
125+
String publishTime;
126+
}
127+
121128
public class PubSubBackground implements BackgroundFunction<PubSubMessage> {
122129
private static final Logger logger =
123130
Logger.getLogger(PubSubBackground.class.getName());
124131

125132
@Override
126133
public void accept(PubSubMessage pubSubMessage, Context context) {
127-
logger.info("Received message with id " + pubSubMessage.messageId);
128-
}
129-
130-
public static class PubSubMessage {
131-
public String data;
132-
public Map<String, String> attributes;
133-
public String messageId;
134-
public String publishTime;
134+
logger.info("Received message with id " + context.eventId());
135135
}
136136
}
137137
```

0 commit comments

Comments
 (0)