|
12 | 12 |
|
13 | 13 | import org.apache.camel.CamelContext; |
14 | 14 | import org.apache.camel.ConsumerTemplate; |
| 15 | +import org.apache.camel.FluentProducerTemplate; |
15 | 16 | import org.apache.camel.ProducerTemplate; |
16 | 17 | import org.apache.camel.ShutdownRoute; |
17 | 18 | import org.apache.camel.ShutdownRunningTask; |
@@ -178,6 +179,13 @@ public void defaults() throws Exception { |
178 | 179 | expect(binder.bind(CamelFinalizer.class)).andReturn(cfABB); |
179 | 180 | expect(binder.bind(RouteBuilder.class)).andReturn(rbABB); |
180 | 181 |
|
| 182 | + FluentProducerTemplate fproducer = unit.mock(FluentProducerTemplate.class); |
| 183 | + expect(ctx.createFluentProducerTemplate()).andReturn(fproducer); |
| 184 | + AnnotatedBindingBuilder<FluentProducerTemplate> fptABB = unit |
| 185 | + .mock(AnnotatedBindingBuilder.class); |
| 186 | + fptABB.toInstance(fproducer); |
| 187 | + expect(binder.bind(FluentProducerTemplate.class)).andReturn(fptABB); |
| 188 | + |
181 | 189 | Multibinder<Object> rbMB = unit.mock(Multibinder.class); |
182 | 190 |
|
183 | 191 | unit.mockStatic(Multibinder.class); |
@@ -297,6 +305,13 @@ public void withStreamCaching() throws Exception { |
297 | 305 | expect(binder.bind(CamelFinalizer.class)).andReturn(cfABB); |
298 | 306 | expect(binder.bind(RouteBuilder.class)).andReturn(rbABB); |
299 | 307 |
|
| 308 | + FluentProducerTemplate fproducer = unit.mock(FluentProducerTemplate.class); |
| 309 | + expect(ctx.createFluentProducerTemplate()).andReturn(fproducer); |
| 310 | + AnnotatedBindingBuilder<FluentProducerTemplate> fptABB = unit |
| 311 | + .mock(AnnotatedBindingBuilder.class); |
| 312 | + fptABB.toInstance(fproducer); |
| 313 | + expect(binder.bind(FluentProducerTemplate.class)).andReturn(fptABB); |
| 314 | + |
300 | 315 | Multibinder<Object> rbMB = unit.mock(Multibinder.class); |
301 | 316 |
|
302 | 317 | unit.mockStatic(Multibinder.class); |
@@ -404,6 +419,13 @@ public void withJmx() throws Exception { |
404 | 419 | expect(binder.bind(CamelFinalizer.class)).andReturn(cfABB); |
405 | 420 | expect(binder.bind(RouteBuilder.class)).andReturn(rbABB); |
406 | 421 |
|
| 422 | + FluentProducerTemplate fproducer = unit.mock(FluentProducerTemplate.class); |
| 423 | + expect(ctx.createFluentProducerTemplate()).andReturn(fproducer); |
| 424 | + AnnotatedBindingBuilder<FluentProducerTemplate> fptABB = unit |
| 425 | + .mock(AnnotatedBindingBuilder.class); |
| 426 | + fptABB.toInstance(fproducer); |
| 427 | + expect(binder.bind(FluentProducerTemplate.class)).andReturn(fptABB); |
| 428 | + |
407 | 429 | Multibinder<Object> rbMB = unit.mock(Multibinder.class); |
408 | 430 |
|
409 | 431 | unit.mockStatic(Multibinder.class); |
@@ -512,6 +534,13 @@ public void withConfigurer() throws Exception { |
512 | 534 | expect(binder.bind(CamelFinalizer.class)).andReturn(cfABB); |
513 | 535 | expect(binder.bind(RouteBuilder.class)).andReturn(rbABB); |
514 | 536 |
|
| 537 | + FluentProducerTemplate fproducer = unit.mock(FluentProducerTemplate.class); |
| 538 | + expect(ctx.createFluentProducerTemplate()).andReturn(fproducer); |
| 539 | + AnnotatedBindingBuilder<FluentProducerTemplate> fptABB = unit |
| 540 | + .mock(AnnotatedBindingBuilder.class); |
| 541 | + fptABB.toInstance(fproducer); |
| 542 | + expect(binder.bind(FluentProducerTemplate.class)).andReturn(fptABB); |
| 543 | + |
515 | 544 | Multibinder<Object> rbMB = unit.mock(Multibinder.class); |
516 | 545 |
|
517 | 546 | unit.mockStatic(Multibinder.class); |
@@ -845,6 +874,13 @@ public void withRoutes() throws Exception { |
845 | 874 | expect(binder.bind(CamelFinalizer.class)).andReturn(cfABB); |
846 | 875 | expect(binder.bind(RouteBuilder.class)).andReturn(rbABB); |
847 | 876 |
|
| 877 | + FluentProducerTemplate fproducer = unit.mock(FluentProducerTemplate.class); |
| 878 | + expect(ctx.createFluentProducerTemplate()).andReturn(fproducer); |
| 879 | + AnnotatedBindingBuilder<FluentProducerTemplate> fptABB = unit |
| 880 | + .mock(AnnotatedBindingBuilder.class); |
| 881 | + fptABB.toInstance(fproducer); |
| 882 | + expect(binder.bind(FluentProducerTemplate.class)).andReturn(fptABB); |
| 883 | + |
848 | 884 | Multibinder<Object> rbMB = unit.mock(Multibinder.class); |
849 | 885 |
|
850 | 886 | unit.mockStatic(Multibinder.class); |
@@ -1067,6 +1103,13 @@ public void propertyResolver() throws Exception { |
1067 | 1103 | expect(binder.bind(CamelFinalizer.class)).andReturn(cfABB); |
1068 | 1104 | expect(binder.bind(RouteBuilder.class)).andReturn(rbABB); |
1069 | 1105 |
|
| 1106 | + FluentProducerTemplate fproducer = unit.mock(FluentProducerTemplate.class); |
| 1107 | + expect(ctx.createFluentProducerTemplate()).andReturn(fproducer); |
| 1108 | + AnnotatedBindingBuilder<FluentProducerTemplate> fptABB = unit |
| 1109 | + .mock(AnnotatedBindingBuilder.class); |
| 1110 | + fptABB.toInstance(fproducer); |
| 1111 | + expect(binder.bind(FluentProducerTemplate.class)).andReturn(fptABB); |
| 1112 | + |
1070 | 1113 | Multibinder<Object> rbMB = unit.mock(Multibinder.class); |
1071 | 1114 |
|
1072 | 1115 | unit.mockStatic(Multibinder.class); |
@@ -1180,6 +1223,13 @@ public void routes() throws Exception { |
1180 | 1223 | expect(binder.bind(CamelFinalizer.class)).andReturn(cfABB); |
1181 | 1224 | expect(binder.bind(RouteBuilder.class)).andReturn(rbABB); |
1182 | 1225 |
|
| 1226 | + FluentProducerTemplate fproducer = unit.mock(FluentProducerTemplate.class); |
| 1227 | + expect(ctx.createFluentProducerTemplate()).andReturn(fproducer); |
| 1228 | + AnnotatedBindingBuilder<FluentProducerTemplate> fptABB = unit |
| 1229 | + .mock(AnnotatedBindingBuilder.class); |
| 1230 | + fptABB.toInstance(fproducer); |
| 1231 | + expect(binder.bind(FluentProducerTemplate.class)).andReturn(fptABB); |
| 1232 | + |
1183 | 1233 | LinkedBindingBuilder<Object> rbMBLBB = unit.mock(LinkedBindingBuilder.class); |
1184 | 1234 | expect(rbMBLBB.to(CamelTest.class)).andReturn(null); |
1185 | 1235 |
|
|
0 commit comments