Re: [Camel-Kafka] consumerStreams vs ConsumersCount

2015-06-26 Thread vasilievip
ConsumersCount is amount of kafka.consumer.Consumer instances.
consumerStreams is amount of kafka.consumer.KafkaStream instances.

https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
http://ingest.tips/2014/10/12/kafka-high-level-consumer-frequently-missing-pieces/



--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-Kafka-consumerStreams-vs-ConsumersCount-tp5768581p5768602.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Camel java dsl: try/catch+stop = finally is not evaluated

2015-02-13 Thread vasilievip
I'm thinking to stop execution in case of exception, but I do want to perform
some logging in finally block. The .stop() definition looks like does what I
need but it stops finally definition as well.
https://github.com/vasilievip/camel-spring-boot/blob/master/src/main/java/cameltest/CamelConfiguration.java#L35

Is this expected behavior? Am I missing something?
Thanks




--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-java-dsl-try-catch-stop-finally-is-not-evaluated-tp5762683.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Camel-boot autowiring issue

2014-11-07 Thread vasilievip
Ok, I tested out the change and it works like a charm in unit test, but in
main class itself I think there is still some issue. 

Lets take as an example Boot1.java from my example project, if I do this:

@Configuration
@EnableAutoConfiguration
@Import({*CamelAutoConfiguration.class,* CamelConfiguration.class})
public class Boot1 {

@Value(${name})
String name;

public static void main(String[] args) {
SpringApplication.run(Boot1.class, args);
}

@Bean(name = someProperty)
public String getPropertyValue() {
return name;
}
}

It works well, but if I remove CamelAutoConfiguration.class from imports,
then the issue is still the same (I guess CamelAutoConfiguration is
processed *after* my routes config). 






--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-boot-autowiring-issue-tp5758543p5758667.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Camel-boot autowiring issue

2014-11-07 Thread vasilievip
Oops, my bad,  the issue is that spring-boot-autoconfigure dependency is only
available for test scope 




--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-boot-autowiring-issue-tp5758543p5758668.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Camel-boot autowiring issue

2014-11-07 Thread vasilievip
Yes, everything works fine. Thank you!
Looks like for the main, optional flag makes some classpath magic not
working :)
dependency
groupIdorg.springframework.boot/groupId
artifactIdspring-boot-starter/artifactId
version${spring-boot.version}/version
*optionaltrue/optional*




--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-boot-autowiring-issue-tp5758543p5758675.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Camel-boot autowiring issue

2014-11-07 Thread vasilievip
See attached:
camel-spring-boot-example.zip
http://camel.465427.n5.nabble.com/file/n5758700/camel-spring-boot-example.zip 
 

- Run Boot1 and take a look at output
- Run Boot2 and take a look at output



--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-boot-autowiring-issue-tp5758543p5758700.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Camel-boot autowiring issue

2014-11-06 Thread vasilievip
Thanks! 
Will try latest changes and let you know the results.



--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-boot-autowiring-issue-tp5758543p5758592.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Camel 2.15-SNAPSHOT dependency missing sources in repo

2014-11-05 Thread vasilievip
There is still no sources for latest build only for previous one. I guess
this has something to do with set of profiles enabled for no tests build
and all tests build.




--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-2-15-SNAPSHOT-dependency-missing-sources-in-repo-tp5758495p5758530.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Camel-boot autowiring issue

2014-11-05 Thread vasilievip
I see strange behavior when trying to use camel boot. 
When config class for camel creates beans (RoutesBuilder's) it does not see
autowired fields - they are not initialized, but in @PostConstruct method
they are getting initialized. When I add additional config file (see
Boot2.java in my example) camel config is skipped at all.
At this point I'm not sure where the problem is, this maybe related to
spring itself, but my main suspected is camel-boot at this point.

Here is sample project I prepared to demonstrate the issue:
camel-spring-boot-example.zip
http://camel.465427.n5.nabble.com/file/n5758543/camel-spring-boot-example.zip 
 

Any advices are appreciated :)



--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-boot-autowiring-issue-tp5758543.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Camel 2.15-SNAPSHOT dependency missing sources in repo

2014-11-04 Thread vasilievip
https://repository.apache.org/content/repositories/snapshots/org/apache/camel/camel-core/2.15-SNAPSHOT/

If you take a look at latest snapshot build - it does not contain sources,
sources as published for the previous snapshot, but maven sees that there
newest build and ignores sources.
Something with daily build configuration?

no_sources.PNG
http://camel.465427.n5.nabble.com/file/n5758495/no_sources.PNG  



--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-2-15-SNAPSHOT-dependency-missing-sources-in-repo-tp5758495.html
Sent from the Camel - Users mailing list archive at Nabble.com.