Package javax.jbi.messaging

Examples of javax.jbi.messaging.RobustInOnly

148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
   
    public void testRobustInOnlyWithTransformerFaultAndError() throws Exception {
        activateComponent(new ReturnFaultComponent(), "transformer");
        ReceiverComponent target = activateReceiver("target");

        RobustInOnly me = client.createRobustInOnlyExchange();
        me.setService(new QName("pipeline"));
        me.getInMessage().setContent(createSource("<hello/>"));
        client.sendSync(me);
        assertEquals(ExchangeStatus.ACTIVE, me.getStatus());
        assertNotNull(me.getFault());
        client.fail(me, new Exception("I do not like faults"));
       
        target.getMessageList().assertMessagesReceived(0);
       
        listener.assertExchangeCompleted();
View Full Code Here
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
   
    public void testRobustInOnlyWithTransformerError() throws Exception {
        activateComponent(new ReturnErrorComponent(), "transformer");
        ReceiverComponent target = activateReceiver("target");

        RobustInOnly me = client.createRobustInOnlyExchange();
        me.setService(new QName("pipeline"));
        me.getInMessage().setContent(createSource("<hello/>"));
        client.sendSync(me);
        assertEquals(ExchangeStatus.ERROR, me.getStatus());
       
        target.getMessageList().assertMessagesReceived(0);
       
        listener.assertExchangeCompleted();
    }
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
   
    public void testRobustInOnlyWithTargetFault() throws Exception {
        activateComponent(new ReturnOutComponent(), "transformer");
        activateComponent(new ReturnFaultComponent(), "target");

        RobustInOnly me = client.createRobustInOnlyExchange();
        me.setService(new QName("pipeline"));
        me.getInMessage().setContent(createSource("<hello/>"));
        client.sendSync(me);
        assertEquals(ExchangeStatus.ACTIVE, me.getStatus());
        assertNotNull(me.getFault());
        client.done(me);
       
        listener.assertExchangeCompleted();
    }
View Full Code Here
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
   
    public void testRobustInOnlyWithTargetFaultAndError() throws Exception {
        activateComponent(new ReturnOutComponent(), "transformer");
        activateComponent(new ReturnFaultComponent(), "target");

        RobustInOnly me = client.createRobustInOnlyExchange();
        me.setService(new QName("pipeline"));
        me.getInMessage().setContent(createSource("<hello/>"));
        client.sendSync(me);
        assertEquals(ExchangeStatus.ACTIVE, me.getStatus());
        assertNotNull(me.getFault());
        client.fail(me, new Exception("I do not like faults"));
       
        listener.assertExchangeCompleted();
    }
View Full Code Here
210
211
212
213
214
215
216
217
218
219
220
221
222
   
    public void testRobustInOnlyWithTargetError() throws Exception {
        activateComponent(new ReturnOutComponent(), "transformer");
        activateComponent(new ReturnErrorComponent(), "target");

        RobustInOnly me = client.createRobustInOnlyExchange();
        me.setService(new QName("pipeline"));
        me.getInMessage().setContent(createSource("<hello/>"));
        client.sendSync(me);
        assertEquals(ExchangeStatus.ERROR, me.getStatus());
       
        listener.assertExchangeCompleted();
    }
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
    }
   
    public void testRobustInOnly() throws Exception {
        ReceiverComponent target = activateReceiver("target");

        RobustInOnly me = client.createRobustInOnlyExchange();
        me.setService(new QName("wireTap"));
        me.getInMessage().setContent(createSource("<hello/>"));
        client.sendSync(me);
        assertEquals(ExchangeStatus.DONE, me.getStatus());
       
        target.getMessageList().assertMessagesReceived(1);
        inReceiver.getMessageList().assertMessagesReceived(1);
        outReceiver.getMessageList().assertMessagesReceived(0);
        faultReceiver.getMessageList().assertMessagesReceived(0);
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
    }
   
    public void testRobustInOnlyWithError() throws Exception {
        activateComponent(new ReturnErrorComponent(), "target");
       
        RobustInOnly me = client.createRobustInOnlyExchange();
        me.setService(new QName("wireTap"));
        me.getInMessage().setContent(createSource("<hello/>"));
        client.sendSync(me);
        assertEquals(ExchangeStatus.ERROR, me.getStatus());
       
        inReceiver.getMessageList().assertMessagesReceived(1);
        outReceiver.getMessageList().assertMessagesReceived(0);
        faultReceiver.getMessageList().assertMessagesReceived(0);
       
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
    }
   
    public void testRobustInOnlyWithFault() throws Exception {
        activateComponent(new ReturnFaultComponent(), "target");
       
        RobustInOnly me = client.createRobustInOnlyExchange();
        me.setService(new QName("wireTap"));
        me.getInMessage().setContent(createSource("<hello/>"));
        client.sendSync(me);
        assertEquals(ExchangeStatus.ACTIVE, me.getStatus());
        assertNotNull(me.getFault());
        client.done(me);
       
        inReceiver.getMessageList().assertMessagesReceived(1);
        outReceiver.getMessageList().assertMessagesReceived(0);
        faultReceiver.getMessageList().assertMessagesReceived(1);
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
    }
   
    public void testRobustInOnlyWithFaultAndError() throws Exception {
        activateComponent(new ReturnFaultComponent(), "target");
       
        RobustInOnly me = client.createRobustInOnlyExchange();
        me.setService(new QName("wireTap"));
        me.getInMessage().setContent(createSource("<hello/>"));
        client.sendSync(me);
        assertEquals(ExchangeStatus.ACTIVE, me.getStatus());
        assertNotNull(me.getFault());
        client.fail(me, new Exception("I do not like faults"));
       
        inReceiver.getMessageList().assertMessagesReceived(1);
        outReceiver.getMessageList().assertMessagesReceived(0);
        faultReceiver.getMessageList().assertMessagesReceived(1);
View Full Code Here
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
    }

    public void testRobustInOnly() throws Exception {
        // Send message exchange
        MessageExchangeFactory mef = consumer.getChannel().createExchangeFactoryForService(new QName("provider"));
        RobustInOnly mec = mef.createRobustInOnlyExchange();
        NormalizedMessage m = mec.createMessage();
        m.setContent(new StringSource(PAYLOAD));
        mec.setInMessage(m);
        consumer.getChannel().send(mec);
        // Provider side
        RobustInOnly mep = (RobustInOnly) provider.getChannel().accept(100L);
        assertNotNull(mep);
        assertEquals(ExchangeStatus.ACTIVE, mep.getStatus());
        mep.setStatus(ExchangeStatus.DONE);
        provider.getChannel().send(mep);
        // Consumer side
        mec = (RobustInOnly) consumer.getChannel().accept(100L);
        assertEquals(ExchangeStatus.DONE, mec.getStatus());
        // Nothing left
View Full Code Here
TOP

Related Classes of javax.jbi.messaging.RobustInOnly

  • org.apache.servicemix.client.DefaultDestination
  • org.apache.servicemix.client.DefaultServiceMixClient
  • org.apache.servicemix.client.ServiceMixClientFacade
  • org.apache.servicemix.components.util.ComponentSupport
  • org.apache.servicemix.components.vfs.FilePoller
  • org.apache.servicemix.eip.PipelineTest
  • org.apache.servicemix.eip.StaticRecipientListTest
  • org.apache.servicemix.eip.StaticRoutingSlipTest
  • org.apache.servicemix.eip.WireTapTest
  • org.apache.servicemix.http.HttpConsumerTest
    • 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.