workers

type CountMessageHandler struct {
	// AutoAck  auto ack messages
	AutoAck bool
	// Count the number of messages consumed
	Count     int
	Preview   bool
	Formatter f.Formatter
}

type PublisheWorker struct {
	Publish pubsub.Publish
}