func main() {
    db, err := gorm.Open(mysql.Open(""), &gorm.Config{})
    if err != nil {
        panic(err)
    }

    w, err := axq.NewWriter().
        WithName("writer_name").
        WithDB(db).
        // MaxBlobSize specify max messages in blob (default 10000)
        WithMaxBlobSize(10000).
        // ChunkSize specify how much messages in chunk (default 1000)
        WithChunkSize(1000). 
        // WithoutCompression specify if you not want to compress your
        WithoutCompression().
        Build()
    if err != nil {
        panic(err)
    }
	
    err = w.Push([]byte("some msg"))
    if err != nil {
        panic(err)
    }	
}

	db, err := gorm.Open(mysql.Open(""), &gorm.Config{})
	if err != nil {
		panic(err)
	}

    r, err := axq.NewReader().
        WithName("reader_name").
        WithDB(db).
        // LoaderCount start N loader workers
        WithLoaderCount(2).
        // WaiterCount start N outers processing sorter message
        WithWaiterCount(2).
        // BufferSize specify size of buffer chan for message queue
        WithBufferSize(100_000).
        // Provide only if you need read b2 before start reading db
        WithB2Credentials(creds).
        Build()
    if err != nil {
        panic(err)
    }

	for {
		m := r.Pop()
		// Handle message
		m.Done()
	}

func main() {
	db, err := gorm.Open(mysql.Open(""), &gorm.Config{})
	if err != nil {
		panic(err)
	}

	// B2 Application Key and Key ID should be exported to env
	creds := backblaze.Credentials{
		ApplicationKey: os.Getenv("B2_APP_KEY"),
		KeyID:          os.Getenv("B2_KEY_ID"),
	}
	a, err := axq.NewArchiver().
		WithName("archiver_name").
		WithDB(db).
		WithB2Credentials(creds).
		// MaxCount specify max messages in blob
		WithMaxCount(5_000_000). // Default 5_000_000
		// MaxCount specify max size of blob
		WithMaxSize(1_000_000). // Default 1_000_000
		// ChunkSize specify how often blob size recalculation will be made
		WithChunkSize(2_000). // Default 2_000
		Build()
	defer a.Close()
}

    db, err := gorm.Open(mysql.Open(""), &gorm.Config{})
    if err != nil {
        panic(err)
    }
    
    // B2 Application Key and Key ID should be exported to env
    creds := backblaze.Credentials{
        ApplicationKey: os.Getenv("B2_APP_KEY"),
        KeyID:          os.Getenv("B2_KEY_ID"),
    }
    r, err := axq.NewB2Reader().
        WithName("reader_name").
        // LoaderCount start N loader workers
        WithLoaderCount(2).
        // WaiterCount start N outers processing sorter message
        WithOuterCount(2).
        // BufferSize specify size of buffer chan for message queue
        WithBufferSize(100_000).
        // Provide only if you need read b2 before start reading db
        WithB2Credentials(creds).
        Build()
    if err != nil {
        panic(err)
    }
    
    for {
        m := r.Pop()
        // Handle message
        m.Done()
    }