1 18 package org.apache.activemq.test; 19 20 import org.apache.activemq.ActiveMQConnectionFactory; 21 import org.apache.activemq.broker.BrokerService; 22 23 import javax.jms.JMSException ; 24 import javax.jms.Message ; 25 26 import java.util.Iterator ; 27 import java.util.List ; 28 29 33 public class JmsTopicSendReceiveWithEmbeddedBrokerAndUserIDTest extends 34 JmsTopicSendReceiveWithTwoConnectionsAndEmbeddedBrokerTest { 35 36 protected String userName = "James"; 37 38 protected ActiveMQConnectionFactory createConnectionFactory() throws Exception { 39 ActiveMQConnectionFactory answer = super.createConnectionFactory(); 40 answer.setUserName(userName); 41 return answer; 42 } 43 44 protected void configureBroker(BrokerService answer) throws Exception { 45 answer.setPopulateJMSXUserID(true); 46 super.configureBroker(answer); 47 } 48 49 protected void assertMessagesReceivedAreValid(List receivedMessages) throws JMSException { 50 super.assertMessagesReceivedAreValid(receivedMessages); 51 52 for (Iterator iter = receivedMessages.iterator(); iter.hasNext();) { 54 Message message = (Message ) iter.next(); 55 String userID = message.getStringProperty("JMSXUserID"); 56 57 log.info("Received message with userID: " + userID); 58 59 assertEquals("JMSXUserID header", userName, userID); 60 } 61 } 62 } 63 | Popular Tags |