AnyEvent-MQTT

 view release on metacpan or  search on metacpan

Changes  view on Meta::CPAN

    - Don't check locale-specific error message to avoid test failure.

1.142010  2014-07-20 13:35:48+01:00 Europe/London
    - Fix message ids large than 16-bits. (Thanks to wnagele on github.)

1.141992  2014-07-18 14:36:30+01:00 Europe/London
    - Fix bad release tar.gz.

1.141991  2014-07-18 14:17:51+01:00 Europe/London
    - Use on_read to avoid broken pipe on eof.
    - Support username and password in connect message.
    - Add -e option to command line for neat one-liners.

1.112340  2011-08-22 20:22:40 Europe/London
    - Support for retained messages with multiple subscriptions to the
      same topic.
    - Fix multiple subscriptions not unsubscribing properly.

1.112320  2011-08-20 23:12:35 Europe/London
    - Support multiple subscriptions to the same topic with different
      callback functions.

README  view on Meta::CPAN

      The timeout for responses from the server.

    keep_alive_timer

      The keep alive timer.

    user_name

      The user name for the MQTT broker.

    password

      The password for the MQTT broker.

    tls

      Set flag to enable TLS encryption, Default is no encryption.

    will_topic

      Set topic for will message. Default is undef which means no will
      message will be configured.

lib/AnyEvent/MQTT.pm  view on Meta::CPAN

    bless {
           socket => undef,
           host => '127.0.0.1',
           port => '1883',
           timeout => 30,
           wait => 'nothing',
           keep_alive_timer => 120,
           qos => MQTT_QOS_AT_MOST_ONCE,
           message_id => 1,
           user_name => undef,
           password => undef,
           tls => undef,
           will_topic => undef,
           will_qos => MQTT_QOS_AT_MOST_ONCE,
           will_retain => 0,
           will_message => '',
           client_id => undef,
           clean_session => 1,
           handle_args => [],
           write_queue => [],
           inflight => {},

lib/AnyEvent/MQTT.pm  view on Meta::CPAN

                              Net::MQTT::Message->new(
                                message_type => MQTT_CONNECT,
                                keep_alive_timer => $weak_self->{keep_alive_timer},
                                client_id => $weak_self->{client_id},
                                clean_session => $weak_self->{clean_session},
                                will_topic => $weak_self->{will_topic},
                                will_qos => $weak_self->{will_qos},
                                will_retain => $weak_self->{will_retain},
                                will_message => $weak_self->{will_message},
                                user_name => $weak_self->{user_name},
                                password => $weak_self->{password},
                              );
                            $weak_self->_write_now($msg);
                            $handle->timeout($weak_self->{timeout});
                            $weak_self->{wait} = 'connack';
                            $handle->on_read(subname 'on_read_cb' => sub {
                              my ($hdl) = @_;
                              $hdl->push_read(ref $weak_self =>
                                              subname 'reader_cb' => sub {
                                                $weak_self->_handle_message(@_);
                                                1;

lib/AnyEvent/MQTT.pm  view on Meta::CPAN

The timeout for responses from the server.

=item C<keep_alive_timer>

The keep alive timer.

=item C<user_name>

The user name for the MQTT broker.

=item C<password>

The password for the MQTT broker.

=item C<tls>

Set flag to enable TLS encryption, Default is no encryption.

=item C<will_topic>

Set topic for will message.  Default is undef which means no will
message will be configured.