Fix memory leak!

.github/workflows/actions.yml

@@ -0,0 +1,114 @@
+on: [push, pull_request]
+
+jobs:
+  integration-test:
+    needs: build
+    runs-on: ${{ matrix.os }}
+    strategy:
+      matrix:
+        os: ['ubuntu-latest']
+        perl: [ '5.34', '5.32', '5.10', '5.10.0' ]
+      max-parallel: 2
+    name: Integration test ${{ matrix.perl }} on ${{ matrix.os }}
+
+    services:
+      rabbitmq:
+        image: rabbitmq:latest
+        env:
+          RABBITMQ_DEFAULT_VHOST: "/"
+        ports:
+          - 5672:5672/tcp
+        options: --health-cmd "rabbitmqctl node_health_check" --health-interval 10s --health-timeout 5s --health-retries 5
+
+    steps:
+      - name: Grab release tarball
+        uses: actions/download-artifact@v1
+        with:
+          name: release-tarball
+      - run: tar xzf release-tarball/ar.tar.gz --strip 1
+      - run: rm -rf release-tarball
+      - name: Set up perl
+        uses: shogo82148/actions-setup-perl@v1.15.3
+        with:
+          perl-version: ${{ matrix.perl }}
+      - run: perl -V
+      - run: cpanm --quiet --notest --installdeps --with-recommends --with-develop .
+      - run: perl Makefile.PL
+      - run: make
+      - run: AUTHOR_TESTING=1 make test
+      - run: prove -Iblib/lib -r xt/
+  unit-test:
+    needs: build
+    runs-on: ${{ matrix.os }}
+    strategy:
+      matrix:
+        os: ['ubuntu-latest', 'macos-latest']
+        perl: [ '5.34', '5.32', '5.10' ]
+      max-parallel: 3
+    name: Perl unit tests ${{ matrix.perl }} on ${{ matrix.os }}
+
+    steps:
+      - name: Grab release tarball
+        uses: actions/download-artifact@v1
+        with:
+          name: release-tarball
+      - run: tar xzf release-tarball/ar.tar.gz --strip 1
+      - name: Set up perl
+        uses: shogo82148/actions-setup-perl@v1.15.3
+        with:
+          perl-version: ${{ matrix.perl }}
+      - run: perl -V
+      - run: cpanm --quiet --notest --installdeps .
+      - run: perl Makefile.PL
+      - run: make
+      - run: make test
+
+  strawberry-unit-test:
+    needs: build
+    runs-on: ${{ matrix.os }}
+    strategy:
+      matrix:
+        os: ['windows-latest']
+        perl: [ '5.30.2.1', '5.28.2.1' ]
+        arch: ['64bit']
+      max-parallel: 3
+    name: Strawberry Perl unit tests on ${{ matrix.os }} with ${{ matrix.arch }} perl ${{ matrix.perl }}
+
+    steps:
+      - name: Grab release tarball
+        uses: actions/download-artifact@v1
+        with:
+          name: release-tarball
+      - run: tar xzf release-tarball/ar.tar.gz --strip 1
+      - run: Invoke-WebRequest -Uri http://strawberryperl.com/download/${{ matrix.perl }}/strawberry-perl-${{ matrix.perl }}-${{ matrix.arch }}.msi -OutFile c:\strawberry-perl-${{ matrix.perl }}-${{ matrix.arch }}.msi
+      - run: Start-Process msiexec.exe -Wait -ArgumentList '/I C:\strawberry-perl-${{ matrix.perl }}-${{ matrix.arch }}.msi /quiet'
+      - run: perl -V
+      - run: cpanm --quiet --notest --installdeps .
+      - run: perl Makefile.PL
+      - run: make
+      - run: make test
+
+  build:
+    runs-on: ${{ matrix.os }}
+    strategy:
+      matrix:
+        os: ['ubuntu-latest']
+        perl: [ '5.30' ]
+      max-parallel: 2
+    name: CPAN build ${{ matrix.perl }} on ${{ matrix.os }}
+
+    steps:
+      - uses: actions/checkout@v2
+      - name: Set up perl
+        uses: shogo82148/actions-setup-perl@v1.15.3
+        with:
+          perl-version: ${{ matrix.perl }}
+      - run: perl -V
+      - run: cpanm --quiet --notest Dist::Zilla
+      - run: dzil authordeps | cpanm --quiet --notest
+      - run: dzil build
+      - run: mv AnyEvent-RabbitMQ-*.tar.gz ar.tar.gz
+      - uses: actions/upload-artifact@v2
+        with:
+          path: ar.tar.gz
+          name: release-tarball

.gitignore

@@ -1,3 +1,6 @@
+AnyEvent-RabbitMQ-*
+*.swp
+MYMETA.*
 cover_db
 META.yml
 Makefile

.shipit

@@ -1,2 +1,2 @@
 steps = FindVersion, ChangeVersion, CheckChangeLog, DistTest, Commit, Tag, MakeDist
-svk.tagpattern = release-%v
+git.tagpattern = %v

.travis.yml

@@ -0,0 +1,20 @@
+language: perl
+
+perl:
+  - "5.16"
+
+services:
+  - rabbitmq
+
+before_install:
+  - sudo apt-get update -qq
+  - sudo apt-get install -y aspell
+
+install:
+  - cpanm --quiet --notest AnyEvent
+  - cpanm --quiet --notest Devel::GlobalDestruction
+  - cpanm --quiet --notest Module::Install::AuthorTests
+  - cpanm --quiet --notest Net::AMQP
+  - cpanm --quiet --notest Readonly
+  - cpanm --quiet --notest Test::Perl::Critic
+  - cpanm --quiet --notest Test::Spelling

Changes

@@ -1,5 +1,137 @@
 Revision history for Perl extension AnyEvent::RabbitMQ
 
+1.22  Fri 12 Jun 19:55:03 BST 2020
+        - Minor correction to author tests.
+        - Correct version constraint on version.pm.
+
+1.21_01  Wed 10 Jun 12:23:48 BST 2020
+        - Validate peer when using TLS. (Scott O'Neil)
+        - Add "nodelay" option to disable Nagle's algorithm.
+          https://rt.cpan.org/Ticket/Display.html?id=119793
+          Also José Micó's e888205306fb49167c0dc9aa4e4dc940cc922d25.
+        - Assign a version number to all modules in package.
+
+1.21  Sat 30 May 23:40:54 BST 2020
+        - No changes.
+
+1.20_01  Sat 23 May 23:29:50 BST 2020
+        - Add "no_ack" flag to "get" method. (Julio Polo)
+        - Prevent channelMax from overflowing.
+          https://rt.cpan.org/Ticket/Display.html?id=97716 (Carl Hörberg)
+        - Merge in documentation patch from
+          https://rt.cpan.org/Ticket/Display.html?id=88213 (Rod Taylor)
+
+1.20  Sun 17 May 14:22:17 BST 2020
+        - Downgrade error to a warning.
+
+1.19_01  Sat 16 May 21:18:27 BST 2020
+        - Allow AnyEvent::TLS options to be passed (Nicolas R).
+        - Correct check when in confirm mode (Ruslan Zakirov).
+        - Fix @INC breaking perls >= 5.26 (Nicolas R).
+        - Minor test fixes
+
+1.19  Sat Mar 21 16:49:24 GMT 2015
+        - Add 'no_ack' as an optional argument to the ->consume method
+          (Dave Mueller).
+        - Fill in some missing documentation (Moritz Lenz).
+1.18  Mon Sep 29 19:36:00 PDT 2014
+        - Added the bind_exchange and unbind_exchange methods
+          for exchange-exchange bindings.
+
+1.17  Fri Jul 25 14:02:00 PDT 2014
+        - Add support for chunking large bodies into multiple AMQP frames,
+          allowing the sending of large messages.
+
+1.16  Sat Apr 12 14:42:00 BST 2014
+        - Doc fixes (Mark Ellis)
+        - Fix leak when calling ->close + tests (Peter Haworth)
+
+1.15  Mon Jul 1 12:35:00 BST 2013
+        - Fix paper-bag bug in connection close - calling nonexistent method.
+
+1.14  Fri Jun  7 08:54:00 BST 2013
+        - Fix paper-bag bug in heartbeat - always lost heartbeat even on
+          active connections
+        - on channel close, automatically call on_return callbacks for any
+          publishes that are waiting
+        - maintain more state around opening and closing to avoid hang/race
+          when server sends Close after client does (this is possible!)
+        - cope with AMQP quirk that in confirm mode, returned messages are
+	  *also* acked/nacked
+        - document $channel->publish
+
+1.13  Thu May  2 16:48:58 PDT 2013
+        - Require Net::AMQP 0.06 to:
+           + Get consume cancel notifications (e.g. queue deletion)
+           + Properly encode user-provided header strings that look like numbers
+        - Fix race between server-sent and client-sent cancellation.
+
+        - Expect server to send heartbeats as promised.  If it doesn't, go President
+            Madagasgar on its ass and SHUT DOWN EVERYTHING.
+
+        - Rearrange many things and weaken many references to eliminate bad circular
+            references.  Some circular refs are actually good, though; leave those.
+
+        - Allow customized client_properties on connection.
+
+        - Make test output clearer.
+
+1.12  Thu Apr 11 20:45:00 2013
+        - Allow AMQP client to adjust tuning, e.g. heartbeat
+          (Chip Salzenberg)
+
+        - Fix RT#84222, continue reading AMQP packets after a heartbeat.
+
+        - Spontaneously emit hearts as per amqp 0.9.1 spec.
+
+          The AMQP spec says, "The client should start sending heartbeats after
+          receiving a Connection.Tune method, and start monitoring heartbeats after
+          receiving Connection.Open."  There is no mention of merely responding to
+          heartbeat packets emitted by the server. (Dave Lambley)
+
+1.11  Tue Mar  5 22:22:00 2013
+        - Fix on_success callback for the Channel->close method (davel).
+
+1.10  Mon Feb 25 13:48:00 2013
+        - Clarify relationship to Net::RabbitFoot. RT#71099
+
+        - Add TLS connection support. RT#81729
+
+1.09   Mon Feb 25 12:03:00 2013
+        - Support AMQP heartbeat.
+
+        - Support AMQP 0.9 standard. (Chip Salzenberg)
+
+        - Stop defining a _return_cb value when not using the mandatory
+          or immediate flags when publishing a message. This means that
+          if you're not using these flags, but are using an infinite set
+          of routing keys, then you won't leak infinite RAM.
+          Currently if you do use these flags and infinitely variable
+          routing keys, we still have a problem as we leak callbacks.
+          RT#79511
+
+1.08    Mon Aug 27 08:43:00 2012
+        - Improve Data::Dumper options for protocol dumps (Chip Salzenberg)
+        - More thoroughly eliminate memory leaks on incoming messages
+          (Chip Salzenberg)
+        - Properly handle channel close: Ensure pending requests fail
+          immediately (Chip Salzenberg)
+
+1.07    Tue Aug 21 15:47:00 2012
+        - Fix dist by putting missing version numbers back into
+          all the modules.
+
+1.06    Tue Aug 21 15:10:00 2012
+        - Fix a race condition stopping connections from closing properly.
+          If you ask to open a channel, and then immediately try to close
+          the connection then the not yet open channel would never remove
+          itself from the associated connection, resulting in the connection
+          never being terminated (as there were still channels associated
+          with it).
+
+        - Stop leaking all RabbitMQ messages recieved back inside
+          a closure.
+
         - Allow multiple clients to have independent connections
           to RabbitMQ, as long as they all use the same spec file.
 

MANIFEST.SKIP

@@ -1,3 +1,4 @@
+^MYMETA\.
 \bRCS\b
 \bCVS\b
 ^MANIFEST\.
@@ -19,3 +20,5 @@
 ^[^/]+\.pl$
 ^\.shipit$
 ^\.gitignore$
+^\.travis.yml$
+^\.github\/

dist.ini

@@ -0,0 +1,62 @@
+name = AnyEvent-RabbitMQ
+author = Masahito Ikuta <cooldaemon@gmail.com>
+license = Perl_5
+copyright_holder = AnyEvent-RabbitMQ's developers
+version = 1.22
+
+[@Filter]
+-bundle = @Basic
+-remove = Readme
+
+[Metadata]
+x_contributors = Tom Doran <bobtfish@cpan.org>
+x_contributors = Nicolas R <atoomic@cpan.org>
+x_contributors = Dave Lambley <dlambley@cpan.org>
+x_contributors = Ruslan Zakirov <ruz@bestpractical.com>
+x_contributors = Masahito Ikuta <cooldaemon@gmail.com>
+x_contributors = Rod Taylor <rod.taylor@gmail.com>
+x_contributors = Carl Hörberg <carl@cloudamqp.com>
+x_contributors = Julio Polo <julio@hawaii.edu>
+x_contributors = A.J. Ragusa <aragusa@globalnoc.iu.edu>
+x_contributors = José Micó <jmico@cpan.org>
+x_contributors = Scott O'Neil <scott@cpanel.net>
+x_contributors = Eugen Konkov <kes@cpan.org>
+
+[InstallGuide]
+[CPANFile]
+[MetaJSON]
+
+[OurPkgVersion]
+underscore_eval_version = 1
+no_critic = 1
+
+[MetaResources]
+repository.url  = git://github.com/bobtfish/AnyEvent-RabbitMQ.git
+repository.web  = https://github.com/bobtfish/AnyEvent-RabbitMQ
+repository.type = git
+
+[Test::PodSpelling]
+stopword = TCP
+stopword = ack
+stopword = qos
+stopword = AMQP
+
+[Test::Perl::Critic]
+
+[Prereqs]
+List::MoreUtils = 0
+Net::AMQP = 0.06
+AnyEvent = 0
+Devel::GlobalDestruction = 0
+namespace::clean = 0
+File::ShareDir = 0
+Readonly = 1.03
+perl = 5.010
+
+[Prereqs / TestRequires]
+Test::More = 0
+Test::Exception = 0
+version = 0.77
+
+[Prereqs / TestRecommends]
+Test::Pod = 0