1 package user.jobengine.server.messagequeue;
3 import static org.junit.Assert.*;
7 import org.junit.After;
8 import org.junit.Before;
11 import user.commons.IJob;
12 import user.commons.Job;
13 import user.jobengine.server.messagequeue.ValidReplies;
14 import user.jobengine.server.messagequeue.IUserMessage;
15 import user.jobengine.server.messagequeue.IUserMessageQueues;
16 import user.jobengine.server.messagequeue.UserMessageQueues;
18 public class UserMessageQueuesTest {
19 private IUserMessageQueues sut = null;
22 public void setup() throws Exception {
23 sut = new UserMessageQueues();
27 public void tearDown() throws Exception {
31 public void testConstructor_Ok() throws Exception {
33 assertTrue( sut.getUserMessages() != null );
37 public void testAddMessage() throws Exception {
39 final String catalogName = "catalog1";
40 final int messageNumber = 1;
41 final IJob job = new Job();
43 final boolean mustReply = true;
44 final Map<Long, IUserMessage> um = sut.getUserMessages();
45 final Object[] parameters = new Object[2];
46 parameters[0] = "value";
50 sut.addMessage(job, catalogName, messageNumber, mustReply, parameters);
53 final IUserMessage userMessage = um.get(1L);
54 final String fmtString = sut.getCatalogString(catalogName, messageNumber);
55 final String messageString = String.format(fmtString, parameters);
57 assertEquals( 1, userMessage.getJobId() );
58 assertEquals( messageString, userMessage.getText() );
59 assertEquals( mustReply, userMessage.isMustReply() );
60 assertEquals( ValidReplies.YESNO, userMessage.getValidReplies() );