Package org.apache.servicemix.tck

Examples of org.apache.servicemix.tck.Sender.sendMessages()

44
45
46
47
48
49
50
51
52
53
54
    public void testSendingAndReceivingMessagesUsingSpring() throws Exception {
        Sender sender = (Sender) getBean("sender");
        assertNotNull(sender);
        ScriptComponent component = (ScriptComponent) getBean("receiver");
        assertNotNull(component);
        sender.sendMessages(1);

        List result = getResult();
        assertNotNull("Have not received any results from groovy!", result);
        logger.info("Found results: {}", result);
    }
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
public class GroovyTransformTest extends org.apache.servicemix.tck.SpringTestSupport {

    public void testSendingAndReceivingMessagesUsingSpring() throws Exception {
        Sender sender = getSender();

        sender.sendMessages(messageCount);

        MessageList messageList = getReceivedMessageList();
        messageList.assertMessagesReceived(messageCount);

        // lets now look into the received messages
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
    public void testSendingAndReceivingMessagesUsingSpring() throws Exception {
        Sender sender = (Sender) getBean("sender");
        assertNotNull(sender);
        ScriptComponent component = (ScriptComponent) getBean("receiver");
        assertNotNull(component);
        sender.sendMessages(1);

        List result = getResult();
        assertNotNull("Have not received any results from groovy!", result);
        System.out.println("Found results: " + result);
    }
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
            container.activateComponent(createReceiverAS("receiver1", receiver1));

            ReceiverListener receiver2 = new ReceiverListener();
            container.activateComponent(createReceiverAS("receiver2", receiver2));

            sender.sendMessages(1);

            Thread.sleep(100);

            assertFalse(receiver1.isPropertySetOnExchange());
            assertFalse(receiver2.isPropertySetOnExchange());
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
       
        container.activateComponent(asReceiver);
        container.activateComponent(asSender);
        container.getRegistry().registerEndpointConnection(new QName("service"), "linkedEndpoint", new QName("service"), "endpoint", null);
       
        sender.sendMessages(1);
        receiver.getMessageList().assertMessagesReceived(1);
    }
   
    public void testInterfaceConnection() throws Exception {
        Receiver receiver = new ReceiverComponent();
View Full Code Here
77
78
79
80
81
82
83
84
85
86
       
        container.activateComponent(asReceiver);
        container.activateComponent(asSender);
        container.getRegistry().registerInterfaceConnection(new QName("interface"), new QName("service"), "endpoint");
       
        sender.sendMessages(1);
        receiver.getMessageList().assertMessagesReceived(1);
    }
   
}
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
    public void testSendingAndReceivingMessagesUsingSpring() throws Exception {
        Sender sender = getSender();
        assertNotNull(sender);
        assertNotNull(getReceiver());

        sender.sendMessages(messageCount);

        MessageList messageList = getReceivedMessageList();
        messageList.assertMessagesReceived(messageCount);
    }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
    public void testSendingAndReceivingMessagesUsingSpring() throws Exception {
        Sender sender = (Sender) getBean("sender");
        assertNotNull(sender);
        ScriptComponent component = (ScriptComponent) getBean("receiver");
        assertNotNull(component);
        sender.sendMessages(1);

        List result = getResult();
        assertNotNull("Have not received any results from groovy!", result);
        log.info("Found results: " + result);
    }
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
public class GroovyTransformTest extends org.apache.servicemix.tck.SpringTestSupport {

    public void testSendingAndReceivingMessagesUsingSpring() throws Exception {
        Sender sender = getSender();

        sender.sendMessages(messageCount);

        MessageList messageList = getReceivedMessageList();
        messageList.assertMessagesReceived(messageCount);

        // lets now look into the received messages
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
      container.activateComponent(createReceiverAS("receiver1", receiver1));
 
      ReceiverListener receiver2 = new ReceiverListener();
      container.activateComponent(createReceiverAS("receiver2", receiver2));
     
      sender.sendMessages(1);
     
      Thread.sleep(100);
     
            assertFalse(receiver1.isPropertySetOnExchange());
            assertFalse(receiver2.isPropertySetOnExchange());
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.