view release on metacpan or  search on metacpan

examples/publisher.pl  view on Meta::CPAN

18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
  },
 
  on_disconnect => sub {
    print "Disconnected from server\n";
  },
);
 
my $cv  = AE::cv;
my $num = 1;
 
my $timer;
$timer = AE::timer( 0, 1,
  sub {
    my $body = 'foo' . $num++;
 
    $stomper->send(
      destination => '/queue/foo',
      persistent  => 'true',
      body        => $body,
 
      sub {
        my $receipt = shift;

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

502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
  }
}
elsif ( $self->{lazy} ) {
  undef $self->{lazy};
  $self->_connect;
}
else {
  if ( defined $self->{reconnect_interval}
    && $self->{reconnect_interval} > 0 )
  {
    unless ( defined $self->{_reconnect_timer} ) {
      weaken($self);
 
      $self->{_reconnect_timer} = AE::timer(
        $self->{reconnect_interval}, 0,
        sub {
          undef $self->{_reconnect_timer};
          $self->_connect;
        }
      );
    }
  }
  else {
    $self->_connect;
  }
}

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

886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
 
sub _reset_internals {
  my $self = shift;
 
  $self->{_handle}          = undef;
  $self->{_connected}       = 0;
  $self->{_login_state}     = S_NEED_DO;
  $self->{_ready}           = 0;
  $self->{_version}         = undef;
  $self->{_session_id}      = undef;
  $self->{_reconnect_timer} = undef;
 
  return;
}
 
sub _abort {
  my $self = shift;
  my $err  = shift;
 
  my @queued_commands = $self->_queued_commands;
  my %subs            = %{ $self->{_subs} };