pub-sub-long-http-google
v1.0.0
Published
Simple PoC of pubsub http long polling instead of GRPC stream
Maintainers
Readme
Simple PoC of pubsub http long polling instead of GRPC stream
Example of usage
import {PubSubAPI} from './pub-sub.api';
import {PubSubListener} from './listener';
import {PubSubMessage} from './pub-sub-message.model';
const bootstrap = async () => {
const api = new PubSubAPI()
await api.init(process.env.PROJECT_ID, process.env.CLIENT_EMAIL, process.env.PRIVATE_KEY)
await api.push('test-topic', [{
'key': 'value'
}])
const pubSubListener = new PubSubListener(api)
pubSubListener.on('test-topic-sub', async (message: PubSubMessage): Promise<void> => {
message.acknowledge()
})
await pubSubListener.listen(1000)
}
bootstrap()
