pub-sub-long-http-google
1.0.0 • Public • Published
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()
Package Sidebar
Install
npm i pub-sub-long-http-google
Weekly Downloads