### Question:
AmqpJmsMessageFacade implements JmsMessageFacade { @Override public byte[] getCorrelationIdBytes() throws JMSException { Object correlationId = null; if (properties != null) { correlationId = properties.getCorrelationId(); } if (correlationId == null) { return null; } else if (correlationId instanceof Binary) { ByteBuffer dup = ((Binary) correlationId).asByteBuffer(); byte[] bytes = new byte[dup.remaining()]; dup.get(bytes); return bytes; } else { throw new JMSException("The underlying correlation-id is not binary and so can't be returned"); } }  void initialize(AmqpConnection connection); void initialize(AmqpConsumer consumer); byte getJmsMsgType(); Symbol getContentType(); void setContentType(Symbol value); @Override boolean propertyExists(String key); boolean applicationPropertyExists(String key); @Override Set<String> getPropertyNames(); Set<String> getApplicationPropertyNames(Set<String> propertyNames); @Override Object getProperty(String key); Object getApplicationProperty(String key); @Override void setProperty(String key, Object value); void setApplicationProperty(String key, Object value); @Override void onSend(long producerTtl); @Override void onDispatch(); @Override void clearBody(); @Override void clearProperties(); @Override AmqpJmsMessageFacade copy(); @Override String getMessageId(); @Override Object getProviderMessageIdObject(); @Override void setProviderMessageIdObject(Object messageId); @Override void setMessageId(String messageId); @Override long getTimestamp(); @Override void setTimestamp(long timestamp); @Override String getCorrelationId(); @Override void setCorrelationId(String correlationId); @Override byte[] getCorrelationIdBytes(); @Override void setCorrelationIdBytes(byte[] correlationId); @Override boolean isPersistent(); @Override void setPersistent(boolean value); @Override int getDeliveryCount(); @Override void setDeliveryCount(int deliveryCount); @Override int getRedeliveryCount(); @Override void setRedeliveryCount(int redeliveryCount); @Override boolean isRedelivered(); @Override void setRedelivered(boolean redelivered); @Override String getType(); @Override void setType(String type); @Override int getPriority(); @Override void setPriority(int priority); @Override long getExpiration(); @Override void setExpiration(long expiration); @Override long getDeliveryTime(); @Override void setDeliveryTime(long deliveryTime, boolean transmit); @Override boolean isDeliveryTimeTransmitted(); void setAmqpTimeToLiveOverride(Long ttl); boolean hasAmqpTimeToLiveOverride(); long getAmqpTimeToLiveOverride(); @Override JmsDestination getDestination(); @Override void setDestination(JmsDestination destination); @Override JmsDestination getReplyTo(); @Override void setReplyTo(JmsDestination replyTo); void setReplyToGroupId(String replyToGroupId); String getReplyToGroupId(); @Override String getUserId(); @Override void setUserId(String userId); @Override byte[] getUserIdBytes(); @Override void setUserIdBytes(byte[] userId); @Override String getGroupId(); @Override void setGroupId(String groupId); @Override int getGroupSequence(); @Override void setGroupSequence(int groupSequence); @Override boolean hasBody(); JmsMessage asJmsMessage(); @Override ByteBuf encodeMessage(); @Override Object getTracingContext(String key); @Override Object setTracingContext(String key, Object value); @Override Object removeTracingContext(String key); @Override Object getTracingAnnotation(String key); @Override Object setTracingAnnotation(String key, Object value); @Override Object removeTracingAnnotation(String key); @Override void filterTracingAnnotations(BiConsumer<String, Object> filter);  }### Answer:
@Test public void testGetCorrelationIdBytesOnNewMessage() throws Exception { AmqpJmsMessageFacade amqpMessageFacade = createNewMessageFacade(); assertNull("Expected correlationId bytes to be null", amqpMessageFacade.getCorrelationIdBytes()); }