overflow_subscriber/subscriber_handler.go

package overflow_subscriber

type SubscriberHandler interface {
	GetChannel() string
	OnSubscribe(channel string, payload []byte)
}