server

type Application interface {
	// Get the next message from the queue.
	GetNextMessage(ctx context.Context, topic string) ([]byte, error)
	// GetNextBatch gets the next count messages from the queue.
	GetNextBatch(ctx context.Context, topic string, count int) ([][]byte, error)
	// IsHealthy checks the health of the Application.
	IsHealthy() error
}

type Server struct {
	// contains filtered or unexported fields
}