diff --git a/.ci/install.ps1 b/.ci/install.ps1
new file mode 100644
index 0000000..44296e8
--- /dev/null
+++ b/.ci/install.ps1
@@ -0,0 +1,157 @@
+$ProgressPreference = 'Continue'
+$ErrorActionPreference = 'Stop'
+Set-StrictMode -Version 2.0
+
+[Net.ServicePointManager]::SecurityProtocol = [Net.ServicePointManager]::SecurityProtocol -bor 'Tls12'
+
+$versions_path = Join-Path -Path $env:GITHUB_WORKSPACE -ChildPath '.ci' | Join-Path -ChildPath 'versions.json'
+$versions = Get-Content $versions_path | ConvertFrom-Json
+Write-Host "[INFO] versions: $versions"
+$erlang_ver = $versions.erlang
+$rabbitmq_ver = $versions.rabbitmq
+
+$base_installers_dir = Join-Path -Path $HOME -ChildPath 'installers'
+if (-Not (Test-Path $base_installers_dir))
+{
+    New-Item -Verbose -ItemType Directory $base_installers_dir
+}
+
+$erlang_download_url = "https://github.com/erlang/otp/releases/download/OTP-$erlang_ver/otp_win64_$erlang_ver.exe"
+$erlang_installer_path = Join-Path -Path $base_installers_dir -ChildPath "otp_win64_$erlang_ver.exe"
+$erlang_install_dir = Join-Path -Path $HOME -ChildPath 'erlang'
+
+Write-Host '[INFO] Downloading Erlang...'
+
+if (-Not (Test-Path $erlang_installer_path))
+{
+    Invoke-WebRequest -UseBasicParsing -Uri $erlang_download_url -OutFile $erlang_installer_path
+}
+else
+{
+    Write-Host "[INFO] Found '$erlang_installer_path' in cache!"
+}
+
+Write-Host "[INFO] Installing Erlang to $erlang_install_dir..."
+& $erlang_installer_path '/S' "/D=$erlang_install_dir" | Out-Null
+
+$rabbitmq_installer_download_url = "https://github.com/rabbitmq/rabbitmq-server/releases/download/v$rabbitmq_ver/rabbitmq-server-$rabbitmq_ver.exe"
+$rabbitmq_installer_path = Join-Path -Path $base_installers_dir -ChildPath "rabbitmq-server-$rabbitmq_ver.exe"
+
+$erlang_reg_path = 'HKLM:\SOFTWARE\Ericsson\Erlang'
+if (Test-Path 'HKLM:\SOFTWARE\WOW6432Node\')
+{
+    $erlang_reg_path = 'HKLM:\SOFTWARE\WOW6432Node\Ericsson\Erlang'
+}
+$erlang_erts_version = Get-ChildItem -Path $erlang_reg_path -Name
+$erlang_home = (Get-ItemProperty -LiteralPath $erlang_reg_path\$erlang_erts_version).'(default)'
+
+Write-Host "[INFO] Setting ERLANG_HOME to '$erlang_home'..."
+$env:ERLANG_HOME = $erlang_home
+[Environment]::SetEnvironmentVariable('ERLANG_HOME', $erlang_home, 'Machine')
+
+Write-Host "[INFO] Setting RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS..."
+$env:RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS = '-rabbitmq_stream advertised_host localhost'
+[Environment]::SetEnvironmentVariable('RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS', '-rabbitmq_stream advertised_host localhost', 'Machine')
+
+Write-Host '[INFO] Downloading RabbitMQ...'
+
+if (-Not (Test-Path $rabbitmq_installer_path))
+{
+    Invoke-WebRequest -UseBasicParsing -Uri $rabbitmq_installer_download_url -OutFile $rabbitmq_installer_path
+}
+else
+{
+    Write-Host "[INFO] Found '$rabbitmq_installer_path' in cache!"
+}
+
+Write-Host "[INFO] Installer dir '$base_installers_dir' contents:"
+Get-ChildItem -Verbose -Path $base_installers_dir
+
+Write-Host '[INFO] Creating Erlang cookie files...'
+
+function Set-ErlangCookie {
+    Param($Path, $Value = 'RABBITMQ-COOKIE')
+    Remove-Item -Force $Path -ErrorAction SilentlyContinue
+    [System.IO.File]::WriteAllText($Path, $Value, [System.Text.Encoding]::ASCII)
+}
+
+$erlang_cookie_user = Join-Path -Path $HOME -ChildPath '.erlang.cookie'
+$erlang_cookie_system = Join-Path -Path $env:SystemRoot -ChildPath 'System32\config\systemprofile\.erlang.cookie'
+
+Set-ErlangCookie -Path $erlang_cookie_user
+Set-ErlangCookie -Path $erlang_cookie_system
+
+Write-Host '[INFO] Installing and starting RabbitMQ with default config...'
+
+& $rabbitmq_installer_path '/S' | Out-Null
+(Get-Service -Name RabbitMQ).Status
+
+$regPath = 'HKLM:\SOFTWARE\Microsoft\Windows\CurrentVersion\Uninstall\RabbitMQ'
+if (Test-Path 'HKLM:\SOFTWARE\WOW6432Node\')
+{
+    $regPath = 'HKLM:\SOFTWARE\WOW6432Node\Microsoft\Windows\CurrentVersion\Uninstall\RabbitMQ'
+}
+$rabbitmq_base_path = Split-Path -Parent (Get-ItemProperty $regPath 'UninstallString').UninstallString
+$rabbitmq_version = (Get-ItemProperty $regPath "DisplayVersion").DisplayVersion
+
+$rabbitmq_home = Join-Path -Path $rabbitmq_base_path -ChildPath "rabbitmq_server-$rabbitmq_version"
+Write-Host "[INFO] Setting RABBITMQ_HOME to '$rabbitmq_home'..."
+[Environment]::SetEnvironmentVariable('RABBITMQ_HOME', $rabbitmq_home, 'Machine')
+$env:RABBITMQ_HOME = $rabbitmq_home
+
+$rabbitmqctl_path = Join-Path -Path $rabbitmq_base_path -ChildPath "rabbitmq_server-$rabbitmq_version" | Join-Path -ChildPath 'sbin' | Join-Path -ChildPath 'rabbitmqctl.bat'
+$rabbitmq_plugins_path = Join-Path -Path $rabbitmq_base_path -ChildPath "rabbitmq_server-$rabbitmq_version" | Join-Path -ChildPath 'sbin' | Join-Path -ChildPath 'rabbitmq-plugins.bat'
+
+Write-Host "[INFO] Setting RABBITMQ_RABBITMQCTL_PATH to '$rabbitmqctl_path'..."
+$env:RABBITMQ_RABBITMQCTL_PATH = $rabbitmqctl_path
+[Environment]::SetEnvironmentVariable('RABBITMQ_RABBITMQCTL_PATH', $rabbitmqctl_path, 'Machine')
+
+$epmd_running = $false
+[int]$count = 1
+
+$epmd_exe = Join-Path -Path $erlang_home -ChildPath "erts-$erlang_erts_version" | Join-Path -ChildPath 'bin' | Join-Path -ChildPath 'epmd.exe'
+
+Write-Host "[INFO] Waiting for epmd ($epmd_exe) to report that RabbitMQ has started..."
+
+Do {
+    $epmd_running = & $epmd_exe -names | Select-String -CaseSensitive -SimpleMatch -Quiet -Pattern 'name rabbit at port'
+    if ($epmd_running -eq $true) {
+        Write-Host '[INFO] epmd reports that RabbitMQ is running!'
+        break
+    }
+
+    if ($count -gt 60) {
+        throw '[ERROR] too many tries waiting for epmd to report RabbitMQ running!'
+    }
+
+    Write-Host "[INFO] epmd NOT reporting yet that RabbitMQ is running, count: '$count'..."
+    $count = $count + 1
+    Start-Sleep -Seconds 5
+
+} While ($true)
+
+[int]$count = 1
+
+Do {
+    $proc_id = (Get-Process -Name erl).Id
+    if (-Not ($proc_id -is [array])) {
+        & $rabbitmqctl_path wait -t 300000 -P $proc_id
+        if ($LASTEXITCODE -ne 0) {
+            throw "[ERROR] rabbitmqctl wait returned error: $LASTEXITCODE"
+        }
+        break
+    }
+
+    if ($count -gt 120) {
+        throw '[ERROR] too many tries waiting for just one erl process to be running!'
+    }
+
+    Write-Host '[INFO] multiple erl instances running still...'
+    $count = $count + 1
+    Start-Sleep -Seconds 5
+
+} While ($true)
+
+$ErrorActionPreference = 'Continue'
+Write-Host '[INFO] Getting RabbitMQ status...'
+& $rabbitmqctl_path status
diff --git a/.ci/versions.json b/.ci/versions.json
new file mode 100644
index 0000000..634a30c
--- /dev/null
+++ b/.ci/versions.json
@@ -0,0 +1,4 @@
+{
+  "erlang": "24.3.3",
+  "rabbitmq": "3.9.15"
+}
diff --git a/.github/workflows/tests.yml b/.github/workflows/tests.yml
index 92817c6..b3d78f4 100644
--- a/.github/workflows/tests.yml
+++ b/.github/workflows/tests.yml
@@ -1,4 +1,4 @@
-name: PR
+name: amqp091-go
 
 on:
   push:
@@ -7,8 +7,30 @@ on:
     branches: [main]
 
 jobs:
-  tests:
-    name: tests
+  build-win32:
+    name: build/test on windows-latest
+    runs-on: windows-latest
+    strategy:
+      matrix:
+        go-version: [1.16.x, 1.17.x, 1.18.x]
+    steps:
+      - uses: actions/checkout@v3
+      - uses: actions/setup-go@v3
+        with:
+          go-version: ${{ matrix.go-version }}
+      - name: Cache installers
+        uses: actions/cache@v3
+        with:
+          # Note: the cache path is relative to the workspace directory
+          # https://docs.github.com/en/actions/using-workflows/caching-dependencies-to-speed-up-workflows#using-the-cache-action
+          path: ~/installers
+          key: ${{ runner.os }}-v0-${{ hashFiles('.ci/versions.json') }}
+      - name: Install and start RabbitMQ
+        run: ./.ci/install.ps1
+      - name: Tests
+        run: go test -cpu 1,2 -race -v -tags integration
+  build-linux:
+    name: build/test on ubuntu-latest
     runs-on: ubuntu-latest
     strategy:
       matrix:
@@ -19,10 +41,8 @@ jobs:
         ports:
           - 5672:5672
     steps:
-      - name: Check out code into the Go module directory
-        uses: actions/checkout@v3
-      - name: Set up Go environment
-        uses: actions/setup-go@v3
+      - uses: actions/checkout@v3
+      - uses: actions/setup-go@v3
         with:
           go-version: ${{ matrix.go-version }}
       - name: Tests