@Test public void testSetReplyToAddressFromDestinationWithTopic() { String testAddress = "testAddress"; JmsDestination destination = new JmsTopic("testAddress"); AmqpJmsMessageFacade message = Mockito.mock(AmqpJmsMessageFacade.class); AmqpConnection conn = Mockito.mock(AmqpConnection.class); Mockito.when(message.getConnection()).thenReturn(conn); AmqpDestinationHelper.setReplyToAddressFromDestination(message, destination); Mockito.verify(message).setReplyToAddress(testAddress); Mockito.verify(message).removeMessageAnnotation(JMS_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL); assertNull(message.getMessageAnnotations()); }
public static void setReplyToAddressFromDestination(AmqpJmsMessageFacade message, JmsDestination destination) { message.setReplyToAddress(getDestinationAddress(destination, message.getConnection())); message.removeMessageAnnotation(JMS_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL); message.removeMessageAnnotation(AmqpMessageSupport.LEGACY_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL); }
AmqpDestinationHelper { public static void setReplyToAddressFromDestination(AmqpJmsMessageFacade message, JmsDestination destination) { message.setReplyToAddress(getDestinationAddress(destination, message.getConnection())); message.removeMessageAnnotation(JMS_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL); message.removeMessageAnnotation(AmqpMessageSupport.LEGACY_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL); } }
AmqpDestinationHelper { public static void setReplyToAddressFromDestination(AmqpJmsMessageFacade message, JmsDestination destination) { message.setReplyToAddress(getDestinationAddress(destination, message.getConnection())); message.removeMessageAnnotation(JMS_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL); message.removeMessageAnnotation(AmqpMessageSupport.LEGACY_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL); }  }
AmqpDestinationHelper { public static void setReplyToAddressFromDestination(AmqpJmsMessageFacade message, JmsDestination destination) { message.setReplyToAddress(getDestinationAddress(destination, message.getConnection())); message.removeMessageAnnotation(JMS_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL); message.removeMessageAnnotation(AmqpMessageSupport.LEGACY_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL); }  static JmsDestination getJmsDestination(AmqpJmsMessageFacade message, JmsDestination consumerDestination); static JmsDestination getJmsReplyTo(AmqpJmsMessageFacade message, JmsDestination consumerDestination); static void setToAddressFromDestination(AmqpJmsMessageFacade message, JmsDestination destination); static void setReplyToAddressFromDestination(AmqpJmsMessageFacade message, JmsDestination destination); static void setToAnnotationFromDestination(JmsDestination destination, MessageAnnotations annotations); static void setReplyToAnnotationFromDestination(JmsDestination destination, MessageAnnotations annotations); static String getDestinationAddress(JmsDestination destination, AmqpConnection connection); static Symbol toTypeCapability(JmsDestination destination); }
AmqpDestinationHelper { public static void setReplyToAddressFromDestination(AmqpJmsMessageFacade message, JmsDestination destination) { message.setReplyToAddress(getDestinationAddress(destination, message.getConnection())); message.removeMessageAnnotation(JMS_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL); message.removeMessageAnnotation(AmqpMessageSupport.LEGACY_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL); }  static JmsDestination getJmsDestination(AmqpJmsMessageFacade message, JmsDestination consumerDestination); static JmsDestination getJmsReplyTo(AmqpJmsMessageFacade message, JmsDestination consumerDestination); static void setToAddressFromDestination(AmqpJmsMessageFacade message, JmsDestination destination); static void setReplyToAddressFromDestination(AmqpJmsMessageFacade message, JmsDestination destination); static void setToAnnotationFromDestination(JmsDestination destination, MessageAnnotations annotations); static void setReplyToAnnotationFromDestination(JmsDestination destination, MessageAnnotations annotations); static String getDestinationAddress(JmsDestination destination, AmqpConnection connection); static Symbol toTypeCapability(JmsDestination destination); static final Symbol JMS_DEST_TYPE_MSG_ANNOTATION_SYMBOL; static final Symbol JMS_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL; static final byte QUEUE_TYPE; static final byte TOPIC_TYPE; static final byte TEMP_QUEUE_TYPE; static final byte TEMP_TOPIC_TYPE; static final Symbol QUEUE_CAPABILITY; static final Symbol TOPIC_CAPABILITY; static final Symbol TEMP_QUEUE_CAPABILITY; static final Symbol TEMP_TOPIC_CAPABILITY; static final byte UNKNOWN_TYPE; }