bug20570 merged into default

Author: Marek Majkowski

test/src/com/rabbitmq/client/test/functional/FunctionalTests.java

@@ -71,6 +71,7 @@ public static TestSuite suite() {
         suite.addTestSuite(UnexpectedFrames.class);
         suite.addTestSuite(PerQueueTTL.class);
         suite.addTestSuite(SaslMechanisms.class);
+        suite.addTestSuite(UserIDHeader.class);
         suite.addTestSuite(InternalExchange.class);
         return suite;
     }

test/src/com/rabbitmq/client/test/functional/UserIDHeader.java

@@ -0,0 +1,26 @@
+package com.rabbitmq.client.test.functional;
+
+import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.test.BrokerTestCase;
+
+import java.io.IOException;
+
+public class UserIDHeader extends BrokerTestCase {
+    public void testValidUserId() throws IOException {
+        AMQP.BasicProperties properties = new AMQP.BasicProperties();
+        properties.setUserId("guest");
+        channel.basicPublish("amq.fanout", "", properties, "".getBytes());
+    }
+
+    public void testInvalidUserId() {
+        AMQP.BasicProperties properties = new AMQP.BasicProperties();
+        properties.setUserId("not the guest, honest");
+        try {
+            channel.basicPublish("amq.fanout", "", properties, "".getBytes());
+            channel.queueDeclare(); // To flush the channel
+            fail("Accepted publish with incorrect user ID");
+        } catch (IOException e) {
+            checkShutdownSignal(AMQP.PRECONDITION_FAILED, e);
+        }
+    }
+}