{scrollbar}

Loan Broker example

You can also read this article by Mohan Vamsi which describes this example:
Implement two-way communication among ESB components

{scrollbar}

You can use a PHP Stomp client to test this example...

  1. Patch examples/loan-broker/src/components/loanbroker/LoanBroker.java with the patch below to allow String parameters
  2. Configure activemq.xml to have a <transportConnector uri="stomp://localhost:61626"/>
  3. Run: ant setup as per the README.txt
  4. Run: ../../bin/servicemix servicemix.xml (as per the README.txt)
  5. Download Dejan Bosanac's extended Stomp PHP library from: http://www.nighttale.net/download/stomp.zip
  6. Copy Stomp.php and JSON.php to an appropriate location
  7. Put the following PHP code into LoanBrokerTest.php
  8. Run: php LoanBrokerTest.php (sample response message output shown below)
LoanBroker.java.diff 148,149c148,161 < ag.amount = (Double) getInProperty(exchange, Constants.PROPERTY_AMOUNT); < ag.duration = (Integer) getInProperty(exchange, Constants.PROPERTY_DURATION); --- > > Object amountObj = getInProperty(exchange, Constants.PROPERTY_AMOUNT); > if(amountObj instanceof String) { > ag.amount = new Double((String)amountObj); > } else { > ag.amount = (Double) amountObj; > } > > Object durationObj = getInProperty(exchange, Constants.PROPERTY_DURATION); > if(durationObj instanceof String){ > ag.duration = new Integer((String) durationObj); > } else { > ag.duration = (Integer) durationObj; > } LoanBrokerTest.php <?php /** * @author Robin Bramley, Opsera Ltd */ require_once 'Stomp.php'; $c = new StompConnection("tcp://localhost:61626"); $result = $c->connect("smx", "smx"); print_r($result); $c->subscribe("/queue/demo.org.servicemix.output"); // the JMS client uses a MapMessage so here we set the payload parameters as properties in the header // along with the reply-to queue and a correlation id for good measure $c->send("/queue/demo.org.servicemix.source", "", array("ssn"=>"012-24932-53254", "amount"=>12345.12, "duration"=>36, "reply-to"=>"/queue/demo.org.servicemix.output", "correlation-id"=>"111111456")); // Wait for the message to come in.. $result = $c->readFrame(); print_r($result); // acknowledge the message so it is removed from the queue $c->ack($result); $c->disconnect(); ?> Sample response message output stompframe Object ( [command] => MESSAGE [headers] => Array ( [bank] => bank3 [destination] => /queue/demo.org.servicemix.output [type] => null [reply-to] => null [timestamp] => 1170954845203 [priority] => 4 [expires] => 0 [correlation-id] => 111111456 [rate] => 3.977056214363132 [message-id] => ID:rbramley-3265-1170951585062-6:0:2:1:9 ) [body] => )

Building on steps 1-4 from above and using a Perl client...

  1. Download Net-Stomp Perl module from: http://search.cpan.org/dist/Net-Stomp/
  2. Download Class-Accessor module from: http://search.cpan.org/~kasei/Class-Accessor-0.30/
  3. Make the libraries and copy to an appropriate location
  4. Put the following Perl code into LoanBrokerTest.pl
  5. Run: perl LoanBrokerTest.pl (sample response output below)
LoanBrokerTest.pl # Loan broker test - Robin Bramley, Opsera Ltd use Net::Stomp; # set up connection my $stomp = Net::Stomp->new( { hostname => 'localhost', port => '61626' } ); $stomp->connect( { login => 'smx', passcode => 'smx' } ); # subscribe to output channel $stomp->subscribe( { destination => '/queue/demo.org.servicemix.output', 'ack' => 'client', 'activemq.prefetchSize' => 1 } ); # send to source channel $stomp->send( { destination => '/queue/demo.org.servicemix.source', body => 'test message', 'ssn'=>'012-24932-53254', 'amount'=>12345.12, 'duration'=>36, 'reply-to'=>'/queue/demo.org.servicemix.output', 'correlation-id'=>'111111456' } ); # pick up the response my $frame = $stomp->receive_frame; print $frame->as_string; $stomp->ack( { frame => $frame } ); # disconnect $stomp->disconnect; Sample response message output MESSAGE priority:4 destination:/queue/demo.org.servicemix.output correlation-id:111111456 reply-to:null rate:4.940422499994942 bank:bank4 timestamp:1171540180281 type:null message-id:ID:rbramley-2033-1171539209750-6:0:2:1:4 expires:0