Package org.mule.tck.functional

Examples of org.mule.tck.functional.EventCallback

46
47
48
49
50
51
52
53
54
55
56
    public void testClientWithMuleClient() throws Exception
    {
        FunctionalTestComponent testComponent = getFunctionalTestComponent("testService");
        assertNotNull(testComponent);

        EventCallback callback = new EventCallback()
        {
            @Override
            public void eventReceived(final MuleEventContext context, final Object component) throws Exception
            {
                MuleMessage msg = context.getMessage();
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
                                  final String expectedActionInContentType) throws Exception
    {
        Flow flow = (Flow) getFlowConstruct(flowName);
        MuleEvent event = getTestEvent("<test/>");

        getFunctionalTestComponent("server").setEventCallback(new EventCallback()
        {
            @Override
            public void eventReceived(MuleEventContext context, Object component) throws Exception
            {
                String soapAction = context.getMessage().getInboundProperty("SOAPAction");
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
    @Override
    protected void doSetUp() throws Exception
    {
        FunctionalTestComponent comp = (FunctionalTestComponent)getComponent("feedTransformer");
        comp.setEventCallback(new EventCallback()
        {
            @Override
            public void eventReceived(MuleEventContext context, Object component) throws Exception
            {
                message = context.getMessage();
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
        event.getMessage().setProperty(SOAP_HEADER_INOUT, REQUEST_HEADER_INOUT, PropertyScope.OUTBOUND);
        event.getMessage().setProperty(HTTP_HEADER, TEST_MESSAGE, PropertyScope.OUTBOUND);

        // A test component is used on the server side to check HTTP headers that are received (inbound properties).

        getFunctionalTestComponent("server").setEventCallback(new EventCallback()
        {
            @Override
            public void eventReceived(MuleEventContext context, Object component) throws Exception
            {
                errorCollector.checkThat(context.getMessage().getInboundProperty(HTTP_HEADER), notNullValue());
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
    @Test
    public void testAsyncPost() throws Exception
    {
        FunctionalTestComponent component = getFunctionalTestComponent("AsyncService");
        component.setEventCallback(new EventCallback()
        {
            @Override
            public void eventReceived(MuleEventContext context, Object comp) throws Exception
            {
                Thread.sleep(200);
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
    @Test
    public void testAsyncPostWithPersistentSedaQueue() throws Exception
    {
        FunctionalTestComponent component = getFunctionalTestComponent("AsyncPersistentQueueService");
        component.setEventCallback(new EventCallback()
        {
            @Override
            public void eventReceived(MuleEventContext context, Object comp) throws Exception
            {
                Thread.sleep(200);
View Full Code Here
154
155
156
157
158
159
160
161
162
163
164
    @Test
    public void testServerClientProxyWithWsdl() throws Exception
    {
        final Latch latch = new Latch();
        ((FunctionalTestComponent)getComponent("serverClientProxyWithWsdl")).setEventCallback(new EventCallback()
        {
            @Override
            public void eventReceived(MuleEventContext context, Object component) throws Exception
            {
                latch.countDown();
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
    @Test
    public void testServerClientProxyWithWsdl2() throws Exception
    {
        final Latch latch = new Latch();
        ((FunctionalTestComponent)getComponent("serverClientProxyWithWsdl2")).setEventCallback(new EventCallback()
        {

            @Override
            public void eventReceived(MuleEventContext context, Object component) throws Exception
            {
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
        TestApplicationEventBean bean = (TestApplicationEventBean) muleContext.getRegistry().lookupObject(
            "testEventSpringBean");
        assertNotNull(bean);

        final Latch whenFinished = new Latch();
        EventCallback callback = new EventCallback()
        {
            @Override
            public void eventReceived(MuleEventContext context, Object o) throws Exception
            {
                assertNull(context);
View Full Code Here
195
196
197
198
199
200
201
202
203
204
205
        TestSubscriptionEventBean bean1 = (TestSubscriptionEventBean) muleContext.getRegistry().lookupObject(
            "testSubscribingEventBean1");
        assertNotNull(bean1);

        final Latch whenFinished1 = new Latch();
        EventCallback callback = new EventCallback()
        {
            @Override
            public void eventReceived(MuleEventContext context, Object o) throws Exception
            {
                MuleApplicationEvent returnEvent = new MuleApplicationEvent("MuleEvent from a spring bean",
View Full Code Here
TOP

Related Classes of org.mule.tck.functional.EventCallback

  • com.muleinaction.AcmeApiBridgeImprovedTestCase
  • com.muleinaction.FileFunctionalTestCase
  • com.muleinaction.listener.NotificationsTestCase
  • com.muleinaction.VMFunctionalTestCase
  • org.mule.issues.MulticastRouterMule2112TestCase
  • org.mule.module.atom.AtomFeedConsumeAndTransformTestCase
  • org.mule.module.cxf.jaxws.HeaderPropertiesTestCase
  • org.mule.module.cxf.ProxyTestCase
  • org.mule.module.rss.RssFeedConsumeAndTransformTestCase
  • org.mule.module.spring.events.SpringEventsTestCase
    • Copyright © 2018 www.massapicom. 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.