rabbitmq-tests/src/test/java/com/datastax/oss/starlight/rabbitmqtests/javaclient/functional/FrameMax.java
@Test
  public void rejectExceedingFrameMax() throws IOException, TimeoutException {
    closeChannel();
    closeConnection();
    ConnectionFactory cf = new GenerousConnectionFactory();
    cf.setPort(pulsarListenerPort);
    cf.setRequestedFrameMax(8192);
    connection = cf.newConnection();
    openChannel();
    basicPublishVolatile(new byte[connection.getFrameMax() * 2], "void");
    expectError(AMQP.FRAME_ERROR);
  }
/* server should reject frames larger than the negotiated frame
   * size */
server should reject frames larger than the negotiated frame
size
server should reject frames larger than the negotiated frame size
@Test
  public void rejectExceedingFrameMax() throws IOException, TimeoutException {
    closeChannel();
    closeConnection();
    ConnectionFactory cf = new GenerousConnectionFactory();
    cf.setPort(pulsarListenerPort);
    cf.setRequestedFrameMax(8192);
    connection = cf.newConnection();
    openChannel();
    basicPublishVolatile(new byte[connection.getFrameMax() * 2], "void");
    expectError(AMQP.FRAME_ERROR);
  }
@ Test public void rejectExceedingFrameMax ( ) throws IOException , TimeoutException { closeChannel ( ) ; closeConnection ( ) ; ConnectionFactory cf = new GenerousConnectionFactory ( ) ; cf . setPort ( pulsarListenerPort ) ; cf . setRequestedFrameMax ( 8192 ) ; connection = cf . newConnection ( ) ; openChannel ( ) ; basicPublishVolatile ( new byte [ connection . getFrameMax ( ) * 2 ] , "void" ) ; expectError ( AMQP . FRAME_ERROR ) ; }
server should reject frames larger than the negotiated frame
 size
server should reject frames larger than the negotiated frame size