review.fuel-infra Code Review - packages/trusty/rabbitmq-server.git/blob

   1 package com.rabbitmq.amqp1_0.tests.proton;
   2
   3 import junit.framework.TestCase;
   4 import org.apache.qpid.proton.amqp.Binary;
   5 import org.apache.qpid.proton.amqp.messaging.Data;
   6 import org.apache.qpid.proton.message.Message;
   7 import org.apache.qpid.proton.message.impl.MessageImpl;
   8 import org.apache.qpid.proton.messenger.Messenger;
   9 import org.apache.qpid.proton.messenger.impl.MessengerImpl;
  10
  11 public class ProtonTests extends TestCase {
  12     public static final String ADDRESS = "amqp://localhost/amqp-1.0-test";
  13     // This uses deprecated classes, yes. I took them from the examples provided...
  14
  15     public void testRoundTrip() throws Exception {
  16         Messenger mng = new MessengerImpl();
  17         mng.start();
  18         Message msg = new MessageImpl();
  19         msg.setAddress(ADDRESS);
  20         msg.setSubject("hello");
  21         msg.setContentType("application/octet-stream");
  22         msg.setBody(new Data(new Binary("hello world".getBytes())));
  23         mng.put(msg);
  24         mng.send();
  25
  26         mng.subscribe(ADDRESS);
  27         mng.recv();
  28         Message msg2 = mng.get();
  29         assertEquals(msg.getSubject(), msg2.getSubject());
  30         assertEquals(msg.getContentType(), msg2.getContentType());
  31         assertEquals(msg.getBody().toString(), msg2.getBody().toString());
  32         mng.stop();
  33     }
  34 }