Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (herse.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Message-ID: <10852036.post@talk.nabble.com>
Date: Tue, 29 May 2007 04:14:29 -0700 (PDT)
From: Carfield Yim <carfield@carfield.com.hk>
To: users@activemq.apache.org
Subject: Re: Question about unit test with activemq
In-Reply-To: <7b3355cb0705280619p4765e5f3u318a556e2f38ad7e@mail.gmail.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
References: <b4503c170705260540i4b28de51w257e757ccf8e4276@mail.gmail.com>
 <7b3355cb0705260757t643a45f1u19edbb901c1efc74@mail.gmail.com>
 <b4503c170705260908h6b5724dfw44b6172d6cbe1d9d@mail.gmail.com>
 <10831734.post@talk.nabble.com>
 <7b3355cb0705280619p4765e5f3u318a556e2f38ad7e@mail.gmail.com>


bsnyder wrote:
> 
> Well you wanted to send a message through the broker and assert it.
> This requires that you start up the broker, create a session, create a
> connection, send the message and assert it. That's why I suggested
> that you look at the testReceiveMessageWithConsumer() method as one
> example to follow.  Below is this method:
> 

The reason that I don't want to do that is I don't really need to create a
session and consumer detail myself, spring will handle it. I would like to
make the test using similar functioniltiy of spring to make thing simple.

Here is my simple util class of doing so, it may not really elegant but it
work for me, see if anyone interested to reuse that


public class TestJmsTemplate extends JmsTemplate102
{
	public final JmsQueueSender sender = new JmsQueueSender();

	public TestJmsTemplate() throws JMSException
	{
		super(new ActiveMQConnectionFactory("vm://localhost"), false);
		final ActiveMQQueue activeMQQueue = new ActiveMQQueue("queue");
		sender.setJt(this);
		sender.setQueue(activeMQQueue);
	}

	public void assertMessage(final String text) throws JMSException
	{
		final Message m = receive(sender.getQueue());
		assertNotNull(m);
		assertEquals(text, ((TextMessage) m).getText());
	}
}

public class JmsQueueSender
{

	private JmsTemplate jt;

	private Queue queue;

	public void simpleSend(final String input)
	{
		jt.send(queue, new MessageCreator()
		{
			public Message createMessage(Session session) throws JMSException
			{
				return session.createTextMessage(input);
			}
		});
	}

	public void setQueue(Queue q)
	{
		queue = q;
	}

	public void setJt(JmsTemplate jt)
	{
		this.jt = jt;
	}

	public Queue getQueue()
	{
		return queue;
	}

}

-- 
View this message in context: http://www.nabble.com/Question-about-unit-test-with-activemq-tf3820428s2354.html#a10852036
Sent from the ActiveMQ - User mailing list archive at Nabble.com.