Package org.jboss.internal.soa.esb.command

Examples of org.jboss.internal.soa.esb.command.InMemoryCommandQueue.addCommand()

85
86
87
88
89
90
91
92
93
94
95
    consumerThread.start();
   
    // Make sure the thread is running.
    assertTrue(consumerThread.isRunning);
   
    commandQueue.addCommand("command1");
    assertCommandReceived(consumerThread, "command1", 0);
    commandQueue.addCommand("command2");
    assertCommandReceived(consumerThread, "command2", 1);
    commandQueue.addCommand("command3");
    assertCommandReceived(consumerThread, "command3", 2);
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
    // Make sure the thread is running.
    assertTrue(consumerThread.isRunning);
   
    commandQueue.addCommand("command1");
    assertCommandReceived(consumerThread, "command1", 0);
    commandQueue.addCommand("command2");
    assertCommandReceived(consumerThread, "command2", 1);
    commandQueue.addCommand("command3");
    assertCommandReceived(consumerThread, "command3", 2);
   
    // Stop the queue thread...
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
   
    commandQueue.addCommand("command1");
    assertCommandReceived(consumerThread, "command1", 0);
    commandQueue.addCommand("command2");
    assertCommandReceived(consumerThread, "command2", 1);
    commandQueue.addCommand("command3");
    assertCommandReceived(consumerThread, "command3", 2);
   
    // Stop the queue thread...
    commandQueue.addCommand("stop");
    Thread.sleep(50);
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
    assertCommandReceived(consumerThread, "command2", 1);
    commandQueue.addCommand("command3");
    assertCommandReceived(consumerThread, "command3", 2);
   
    // Stop the queue thread...
    commandQueue.addCommand("stop");
    Thread.sleep(50);
    assertTrue(!consumerThread.isRunning);  // this flag being reset proves the stop command was consumed and so the queue is really working
    assertEquals(4, consumerThread.unblockCount); // Should have unblocked 4 times - once for each command.
   
    // receive should fail if the queue has been closed...
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.