Skip to content
This repository


Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP

Simple message queue based on AnyEvent

branch: master

Checking in changes prior to tagging of version 0.35.

Changelog diff is:

diff --git a/Changes b/Changes
index 61b60b6..545c647 100644
--- a/Changes
+++ b/Changes
@@ -1,5 +1,8 @@
 Revision history for Perl extension AnyMQ

+0.35 Sat Feb 16 18:34:24 CST 2013
+        - Support unpoll. [alexmv]
 0.34 Thu Feb  2 23:29:27 CST 2012
         - Improvements for traits to override publish method.
latest commit c363306307
Chia-liang Kao authored February 16, 2013
Octocat-spinner-32 lib
Octocat-spinner-32 t
Octocat-spinner-32 xt
Octocat-spinner-32 .gitignore
Octocat-spinner-32 .shipit
Octocat-spinner-32 .travis.yml
Octocat-spinner-32 Changes
Octocat-spinner-32 MANIFEST.SKIP
Octocat-spinner-32 Makefile.PL
Octocat-spinner-32 README
    AnyMQ - Non-blocking message queue system based on AnyEvent

      use AnyMQ;
      my $mq = AnyMQ->topic('Foo'); # gets an AnyMQ::Topic object
      $mq->publish({ message => 'Hello world'});

      #  bind to external message queue servers using traits.
      #  my $bus = AnyMQ->new_with_traits(traits => ['AMQP'],
      #                                   host   => 'localhost',
      #                                   port   => 5672,
      #                                   user   => 'guest',
      #                                   pass   => 'guest',
      #                                   vhost  => '/',
      #                                   exchange => '');
      #  my $mq = $bus->topic('foo')

      $mq->publish({ message => 'Hello world'});

      # $bus->new_listener('client_id', $mq);

    AnyMQ is message queue system based on AnyEvent. It can store all
    messages in memory or use external message queue servers.

    Messages are published to AnyMQ::Topic, and consumed with AnyMQ::Queue.

    Returns a new AnyMQ object, which is a message bus that can associate
    with arbitrary AnyMQ::Topic and consumed by AnyMQ::Queue

  topic($name or %opt)
    Returns a AnyMQ::Topic with given name or constructor options %opt. If
    called as class method, the default bus will be used. Topics not known
    to the current AnyMQ bus will be created.

  new_topic($name or %opt)
    Creates and returns a new AnyMQ::Topic object with given name or
    constructor options %opt. This should not be called directly.

    Returns a new AnyMQ::Queue object, and subscribes to the optional given
    topic. If called as class method, the default bus will be used.

    Tatsuhiko Miyagawa Chia-liang Kao

    This library is free software; you can redistribute it and/or modify it
    under the same terms as Perl itself.

    AnyMQ::Topic, AnyMQ::Queue

Something went wrong with that request. Please try again.