You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by mc...@apache.org on 2013/12/02 16:42:49 UTC
svn commit: r1547066 - in /qpid/proton/trunk/proton-c/bindings/perl/lib:
qpid/proton/Errors.pm qpid/proton/Messenger.pm qpid/proton/Tracker.pm
qpid_proton.pm
Author: mcpierce
Date: Mon Dec 2 15:42:49 2013
New Revision: 1547066
URL: http://svn.apache.org/r1547066
Log:
PROTON-463: Add Tracker class to Perl bindings
Added:
qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Errors.pm
- copied, changed from r1547038, qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm
qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Tracker.pm
- copied, changed from r1547038, qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm
Modified:
qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Messenger.pm
qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm
Copied: qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Errors.pm (from r1547038, qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm)
URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Errors.pm?p2=qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Errors.pm&p1=qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm&r1=1547038&r2=1547066&rev=1547066&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm (original)
+++ qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Errors.pm Mon Dec 2 15:42:49 2013
@@ -21,13 +21,6 @@ use strict;
use warnings;
use cproton_perl;
-use qpid::proton::Data;
-use qpid::proton::Mapping;
-use qpid::proton::Constants;
-use qpid::proton::Messenger;
-use qpid::proton::Message;
+package qpid::proton::Errors;
-use qpid::proton;
-
-1;
Modified: qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Messenger.pm
URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Messenger.pm?rev=1547066&r1=1547065&r2=1547066&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Messenger.pm (original)
+++ qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Messenger.pm Mon Dec 2 15:42:49 2013
@@ -165,7 +165,20 @@ sub put {
my $msgimpl = $message->get_impl();
cproton_perl::pn_messenger_put($impl, $msgimpl);
- return cproton_perl::pn_messenger_outgoing_tracker($impl);
+ my $tracker = $self->get_outgoing_tracker();
+ return $tracker;
+}
+
+sub get_outgoing_tracker {
+ my ($self) = @_;
+ my $impl = $self->{_impl};
+
+ my $tracker = cproton_perl::pn_messenger_outgoing_tracker($impl);
+ if ($tracker != -1) {
+ return qpid::proton::Tracker->new($tracker);
+ } else {
+ return undef;
+ }
}
sub send {
@@ -186,6 +199,16 @@ sub get {
return cproton_perl::pn_messenger_incoming_tracker($impl);
}
+sub incoming_tracker {
+ my ($self) = @_;
+ my $impl = $self->{_impl};
+
+ my $tracker = cproton_perl::pn_messenger_incoming_tracker($impl);
+ return undef if $tracker == -1;
+
+ return qpid::proton::Tracker->new($tracker);
+}
+
sub receive {
my ($self) = @_;
my $n = $_[1];
Copied: qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Tracker.pm (from r1547038, qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm)
URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Tracker.pm?p2=qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Tracker.pm&p1=qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm&r1=1547038&r2=1547066&rev=1547066&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm (original)
+++ qpid/proton/trunk/proton-c/bindings/perl/lib/qpid/proton/Tracker.pm Mon Dec 2 15:42:49 2013
@@ -21,13 +21,23 @@ use strict;
use warnings;
use cproton_perl;
-use qpid::proton::Data;
-use qpid::proton::Mapping;
-use qpid::proton::Constants;
-use qpid::proton::Messenger;
-use qpid::proton::Message;
+package qpid::proton::Tracker;
-use qpid::proton;
+sub new {
+ my ($class) = @_;
+ my ($self) = {};
-1;
+ $self->{_impl} = $_[1];
+
+ bless $self, $class;
+ return $self;
+}
+
+sub get_impl {
+ my ($self) = @_;
+
+ return $self->{_impl};
+}
+
+1;
Modified: qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm
URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm?rev=1547066&r1=1547065&r2=1547066&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm (original)
+++ qpid/proton/trunk/proton-c/bindings/perl/lib/qpid_proton.pm Mon Dec 2 15:42:49 2013
@@ -24,6 +24,7 @@ use cproton_perl;
use qpid::proton::Data;
use qpid::proton::Mapping;
use qpid::proton::Constants;
+use qpid::proton::Tracker;
use qpid::proton::Messenger;
use qpid::proton::Message;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org