Skip to content
Read-only release history for POE-Component-Server-Bayeux
JavaScript Perl CSS
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Failed to load latest commit information.


    POE::Component::Server::Bayeux - Bayeux/cometd server implementation in

      use POE qw(Component::Server::Bayeux);

      # Create the server, listening on port 8080
      my $server = POE::Component::Server::Bayeux->spawn(
          Port  => 8080,
          Alias => 'bayeux_server',

      # Create a local client, a reply-bot
          inline_states => {
              _start => sub {
                  my ($kernel, $heap) = @_[KERNEL, HEAP];

                  # Subscribe to /chat/demo, assigning a state for events
                  $kernel->post('bayeux_server', 'subscribe', {
                      channel => '/chat/demo',
                      client_id => $heap->{client_id},
                      args => {
                          state => 'subscribe_response',
              subscribe_response => sub {
                  my ($kernel, $heap, $message) = @_[KERNEL, HEAP, ARG0];

                  # Don't auto-reply to my own messages
                  return if $message->{clientId} eq $heap->{client_id};

                  # Auto-reply to every message posted
                  $kernel->post('bayeux_server', 'publish', {
                      channel => $message->{channel},
                      client_id => $heap->{client_id},
                      data => {
                          user => 'Autobot',
                          chat => "I got your message, ".($message->{data}{user} || 'anon'),
          heap => {
              client_id => 'test_local_client',


    This module implements the Bayeux Protocol (1.0draft1) from the Dojo
    Foundation. Also called cometd, Bayeux is a low-latency routing protocol
    for JSON encoded events between clients and servers in a
    publish-subscribe model.

    This is the server implementation. There is also a client found at
    POE::Component::Client::Bayeux. With this server, you can roll out a
    cometd server and basic HTTP server with POE communication capabilities.
    It comes bundled with test code that you can run in your browser to test
    the functionality for a basic chat program.

    Please note: This is the first release of this code. Not much testing
    has been done, so please keep that in mind if you plan on using this for
    production. It was developed for a production environment that is still
    being built, so future versions of this code will be released over the
    next month that will be more feature complete and less prone to errors.

  spawn (...)
        Create a new Bayeux server. Arguments to this method:

        *Port* (default: 80)
            Bind an HTTP server to this port.

        *Alias* (default: 'bayeux')
            The POE session alias for local clients to post to.

        *AnonPublish* (default: 0)
            Allow HTTP-connected clients to publish without handshake.

        *ConnectTimeout* (default: 120)
            Seconds before an HTTP-connected client is timed out and forced
            to rehandshake. Clients must not go this long between having a
            connect open.

        *ClientMaxConnections* (default: 10)
            Maximum number of concurrent connections allowed from a single
            IP address. Not effective for anything but the bayeux/cometd
            connections, as the simple HTTP server doesn't support counting
            concurrent connections.

        *Debug* (default: 0)
            Either 0 or 1, indicates level of logging.

        *LogFile* (default: undef)
            If present, opens the file path indicated for logging output.

        *DocumentRoot* (default: '/var/www')
            Document root of generic HTTP server for file serving.

        *DirectoryIndex* (default: [ 'index.html' ])
            Index file (think Apache config).

        *TypeExpires* (default: {})
            Provide a hashref of MIME types and their associated expiry
            time. Similar to mod_expires 'ExpiresByType $key "access plus
            $value seconds"'.

        *PostHandle* (default: undef)
            Provide a subref which will be called with the HTTP::Request and
            HTTP::Response of any simple HTTP requests before the request is
            completed. This could allow the code to modify the headers of
            the response as needed (i.e., path-based expiry time).

        *Services* (default: {})
            Each key of this hash represents a service channel that will be
            available. The name of the channel will be '/service/$key', and
            the handling is dependent on the $value. Provide '_handler' as a
            fallback handler.

            If $value is a coderef, the code will be called with a single
            arg of the message being acted upon. The return value(s) of the
            coderef will be considered response(s) to be sent back to the
            client, so return an empty array if you don't want this to
            happen (if you've added responses by

        *MessageACL* (defaults: sub {})
            Coderef to perform authorization checks on messages. Code block
            is passed two args, the Client, and the Message. If the message
            should be rejected, the code should set is_error() on the

            One could use this to perform authentication on the 'handshake'

              sub {
                  my ($client, $message) = @_;

                  return unless $message->isa('POE::Component::Server::Bayeux::Message::Meta');
                  return unless $message->type eq 'handshake';

                  my $error;

                  while (1) {
                      if (! $message->ext ||
                          ! (defined $message->ext->{username} && defined $message->ext->{password})) {
                          $error = "Must pass username and password in ext to handshake";

                      my $authenticated = $message->ext->{username} eq 'admin'
                          && $message->ext->{password} eq 'password' ? 1 : 0;

                      if (! $authenticated) {
                          $error = "Invalid username or password";

                      $client->flags->{is_authenticated} = 1;

                  if ($error) {

        *Callback* (defaults: sub {})
            Coderef to receive general event notifications from the server.
            Sends a hashref like so:

                  event => 'new_connection',
                  client_id => ...,
                  client => ...,
                  message => ...,

            See "Server Callbacks" for more details about every type of
            event that this will receive.

        *ContentHandler* (defaults: {})
            Additional ContentHandler for POE::Component::Server::HTTP
            creation. Use this to extend the HTTP server content handling.

        Returns a class object with methods of interest:

            Returns the Log::Log4perl object used by the server. Use this
            for unified logging output.

            The POE::Session object returned from an internal create() call.

    Most of the server code is regarding interaction with HTTP-connected
    clients. For this, see POE::Component::Server::Bayeux::Client. It
    supports locally connected POE sessions, and for this, makes the
    following states available.

    These same states are called internally to handle the basic PubSub
    behavior of the server for all clients, local and HTTP.

  subscribe ({...})
        Required keys 'channel', 'client_id'. Optional key 'args' (hashref).

        Subscribes client_id to the channel indicated. If subscribe() is
        called by another session, it's treated as a non-HTTP request and
        will not perform authentication on the subscription. Local clients
        need not handshake or connect.

        Events published to the subscribed channel are sent to the calling
        session's method named 'deliver', which can be overrided by the args
        hashref key 'state'. For example:

          $kernel->post('bayeux_server', 'subscribe', {
              channel => '/chat/demo',
              client_id => 'local_client',
              args => {
                  state => 'subscribe_events',

  unsubscribe ({...})
        Required keys 'channel', 'client_id'.

        Unsubscribes client_id from the channel indicated.

  publish ({...})
        Required keys 'channel' and 'data'. Optional keys 'client_id', 'id',
        and 'ext'.

        Publishes a message to the channel specified. The keys 'client_id',
        'id' and 'ext' are passed thru, appended to the message sent. For
        local clients who subscribed from another session, the message is
        immediately posted to their callback state. For HTTP clients,
        messages are put into queue and flushed if they have an open

  client_push ({...})
  Server Callbacks
    Using the Callback feature of the server spawning, you can be notified
    about every significant event on the server. Below describes all the
    current callback events:

        Keys 'client_id' and 'channel'

        Keys 'client_id' and 'channel'

        Keys 'channel' and 'data', optional: 'client_id', 'id', 'ext'

        Keys 'channel' and 'client_id', optional: (any extra). Indicates
        data was pushed to the client not as a normal request/response or a
        publish/subscribe (out-of-sequence reply to a /service, for
        example). Likely only triggered by local sessions.

        Keys 'client_id' and either 'ip' or 'session' depending on the type
        of client.

        Key 'client_id'.

    Lots of stuff.

    The code currently implements only the long-polling transport and
    doesn't yet strictly follow all the directives in the protocol document

    No known bugs, but I'm sure you can find some.

    POE, POE::Component::Server::HTTP

    Copyright (c) 2008 Eric Waters and XMission LLC
    ( All rights reserved. This program is free
    software; you can redistribute it and/or modify it under the same terms
    as Perl itself.

    The full text of the license can be found in the LICENSE file included
    with this module.

    Eric Waters <>

Something went wrong with that request. Please try again.