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 2014/07/31 15:46:25 UTC
svn commit: r1614889 - in /qpid/trunk/qpid/cpp/bindings/qpid:
examples/perl/client.pl perl/lib/qpid/messaging/Receiver.pm
perl/lib/qpid/messaging/Sender.pm
Author: mcpierce
Date: Thu Jul 31 13:46:25 2014
New Revision: 1614889
URL: http://svn.apache.org/r1614889
Log:
QPID-5939: Add get_address to Perl Sender/Receiver classes.
Updated the Perl client/server examples.
Modified:
qpid/trunk/qpid/cpp/bindings/qpid/examples/perl/client.pl
qpid/trunk/qpid/cpp/bindings/qpid/perl/lib/qpid/messaging/Receiver.pm
qpid/trunk/qpid/cpp/bindings/qpid/perl/lib/qpid/messaging/Sender.pm
Modified: qpid/trunk/qpid/cpp/bindings/qpid/examples/perl/client.pl
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/examples/perl/client.pl?rev=1614889&r1=1614888&r2=1614889&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/bindings/qpid/examples/perl/client.pl (original)
+++ qpid/trunk/qpid/cpp/bindings/qpid/examples/perl/client.pl Thu Jul 31 13:46:25 2014
@@ -38,10 +38,8 @@ eval {
# create an address and receiver for incoming messages
# the queue will be created always, and will be deleted
# when the receive disconnects
- my $responseQueue = new qpid::messaging::Address(
- "#response-queue; {create:always, delete:always}");
- my $receiver = $session->create_receiver($responseQueue);
-
+ my $receiver = $session->create_receiver("#");
+ my $responseQueue = $receiver->get_address();
# Now send some messages...
my @s = (
Modified: qpid/trunk/qpid/cpp/bindings/qpid/perl/lib/qpid/messaging/Receiver.pm
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/perl/lib/qpid/messaging/Receiver.pm?rev=1614889&r1=1614888&r2=1614889&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/bindings/qpid/perl/lib/qpid/messaging/Receiver.pm (original)
+++ qpid/trunk/qpid/cpp/bindings/qpid/perl/lib/qpid/messaging/Receiver.pm Thu Jul 31 13:46:25 2014
@@ -298,6 +298,26 @@ sub get_session {
=pod
+Returns the address for this receiver.
+
+=over
+
+=item $address = $receiver->get_address
+
+=back
+
+=cut
+
+sub get_address {
+ my ($self) = @_;
+ my $impl = $self->{_impl};
+ my $address = $impl->getAddress;
+
+ return new qpid::messaging::Address($address);
+}
+
+=pod
+
=over
=item $receiver->is_closed
Modified: qpid/trunk/qpid/cpp/bindings/qpid/perl/lib/qpid/messaging/Sender.pm
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/perl/lib/qpid/messaging/Sender.pm?rev=1614889&r1=1614888&r2=1614889&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/bindings/qpid/perl/lib/qpid/messaging/Sender.pm (original)
+++ qpid/trunk/qpid/cpp/bindings/qpid/perl/lib/qpid/messaging/Sender.pm Thu Jul 31 13:46:25 2014
@@ -255,4 +255,26 @@ sub get_session {
return $self->{_session};
}
+=pod
+
+=head2 ADDRESS
+
+Returns the address for this sender.
+
+=over
+
+=item $address = $sender->get_address
+
+=back
+
+=cut
+
+sub get_address {
+ my ($self) = @_;
+ my $impl = $self->{_impl};
+ my $address = $impl->getAddress;
+
+ return new qpid::messaging::Address($address);
+}
+
1;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org