pubsub_middleware

README

Pub/Sub middleware

This repo contains go middleware for Google Pub/Sub. See the following links for more information on Google Pub/Sub.

https://cloud.google.com/pubsub/docs/overview

https://github.com/googleapis/google-cloud-go/tree/master/pubsub

The following snippet shows how to use recovery middleware when receiving pubsub messages.

package main

import (
	"context"
	"fmt"
	"log"

	"github.com/bvwells/pubsub-middleware/recovery"

	"cloud.google.com/go/pubsub"
)

func main() {
	ctx := context.Background()
	client, err := pubsub.NewClient(ctx, "project-id")
	if err != nil {
		log.Fatal(err)
	}

	// Log message ID if panic occurs when processing received message.
	recoveryFunc := recovery.WithRecoveryFunc(func(_ context.Context, msg *pubsub.Message, _ interface{}) {
		log.Printf("recovered from panic while handling message '%s'", msg.ID)
	})

	// Use a callback to receive messages via subscription.
	sub := client.Subscription("subscription")
	err = sub.Receive(ctx, recovery.NewRecoveryHandler(func(ctx context.Context, m *pubsub.Message) {
		fmt.Println(m.Data)
		m.Ack() // Acknowledge that we've consumed the message.
	}, recoveryFunc))
	if err != nil {
		log.Println(err)
	}
}

Documentation

Overview

Package pubsub_middleware is a collection of Google Pub/Sub middleware.

Index

• type HandlerFunc

Types

type HandlerFunc

type HandlerFunc func(ctx context.Context, m *pubsub.Message)

HandlerFunc is a pubsub handler function which can be used in pubsub subscription receive.