from:"Kasim Sert \(Ibtech\-Software Infrastructure\)"

camel cxf more than one path param error

2017-07-24 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

I am using camel cxfrs component to expose rest webservices. the interface 
below work fine with one @PathParam parameter.

public interface Service2 {
@GET
@Path("/world2/{id}")
@Produces(MediaType.APPLICATION_XML)
public Response hello2(@PathParam("id") String id) ;


However if I add one more @Pathparam annotated parameter than it throws the 
exception below. Any idea about what is the problem here or how to solve it?


public interface Service2 {

@GET

@Path("/world2/{id}/{id2}")

@Produces(MediaType.APPLICATION_XML)

public Response hello2(@PathParam("id") String id,@PathParam("id2") String 
id2 ) ;

The exception:

2017-07-24 14:24:33.725  WARN 7840 --- [nio-8080-exec-1] 
o.a.c.j.i.WebApplicationExceptionMapper  : 
javax.ws.rs.InternalServerErrorException: HTTP 500 Internal Server Error
   at 
org.apache.cxf.jaxrs.utils.SpecExceptions.toInternalServerErrorException(SpecExceptions.java:79)
at 
org.apache.cxf.jaxrs.utils.ExceptionUtils.toInternalServerErrorException(ExceptionUtils.java:113)
at 
org.apache.cxf.jaxrs.interceptor.JAXRSInInterceptor.convertExceptionToResponseIfPossible(JAXRSInInterceptor.java:227)
at 
org.apache.cxf.jaxrs.interceptor.JAXRSInInterceptor.processRequest(JAXRSInInterceptor.java:215)
at 
org.apache.cxf.jaxrs.interceptor.JAXRSInInterceptor.handleMessage(JAXRSInInterceptor.java:77)
at 
org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:308)
at 
org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:121)
at 
org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:263)
at 
org.apache.cxf.transport.servlet.ServletController.invokeDestination(ServletController.java:234)
at 
org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:208)
at 
org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:160)
at 
org.apache.cxf.transport.servlet.CXFNonSpringServlet.invoke(CXFNonSpringServlet.java:189)
at 
org.apache.cxf.transport.servlet.AbstractHTTPServlet.handleRequest(AbstractHTTPServlet.java:299)
at 
org.apache.cxf.transport.servlet.AbstractHTTPServlet.doGet(AbstractHTTPServlet.java:223)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:687)
at 
org.apache.cxf.transport.servlet.AbstractHTTPServlet.service(AbstractHTTPServlet.java:274)
at 
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:230)
at 
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165)
at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52)
at 
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192)
at 
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165)
at 
org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99)
at 
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
at 
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192)
at 
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165)
at 
org.springframework.web.filter.HttpPutFormContentFilter.doFilterInternal(HttpPutFormContentFilter.java:105)
at 
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
at 
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192)
at 
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165)
at 
org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:81)
at 
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
at 
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192)
at 
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165)
at 
org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:197)
at 
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
at 
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192)
at 
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165)
at 
org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:198)
at 
org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)
at 
org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:474)
at 
org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:140)
at

Camel cxf with Spring boot manual starting route

2017-07-18 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

I am using spring boot with camel cxf to expose rest/soap web services. However 
since I have many services and some of them are not well defined, I want to 
register each of them one by one, catch if any exception occurs and continue 
with remaining valid services. But when I set 
camel.springboot.auto-startup=false I can not manage to open cxf service again. 
(Please note that timer route can be started by this way). Any solution or 
suggestion ?

Thank you

Here is the code :

@Component
public class TestRoutes {

 @Autowired CamelContext camelContext;
 @Autowired Swagger2Feature swagger2Feature;

 @PostConstruct
 public void init(){
  try {
camelContext.start();
  } catch (Exception e1) {
e1.printStackTrace();
  }
  HelloResponse response = new HelloResponse();
  response.setCevap("response");
  List providers = new ArrayList<>();
  CxfRsComponent cxfComponent = new CxfRsComponent(camelContext);

CxfRsEndpoint serviceEndpoint = new CxfRsEndpoint("/rest2", cxfComponent);
serviceEndpoint.addResourceClass(Service1.class);
serviceEndpoint.setProviders(providers);
serviceEndpoint.setSynchronous(true);
serviceEndpoint.setAddress("/rest2");
serviceEndpoint.getFeatures().add(swagger2Feature);

RouteBuilder builder = new RouteBuilder(camelContext) {
@Override
public void configure() throws Exception {
 from(serviceEndpoint)
 .id(Service1.class.getCanonicalName()+"rest")
 .log("${header.operationName} message here")
 .setBody(constant(response));

 from("timer:mytimer?period=5000")
  .id("timer")
  .log("hi");

}
  };
  try {
   
camelContext.startRoute(Service1.class.getCanonicalName()+"rest");
camelContext.startRoute("timer");
  } catch (Exception e) {
e.printStackTrace();
  }
 }
}

Startup log:
017-07-18 10:50:49.076  INFO 12052 --- [   main] 
ationConfigEmbeddedWebApplicationContext : Refreshing 
org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@5149d738:
 startup date [Tue Jul 18 10:50:49 EEST 2017]; root of context hierarchy
2017-07-18 10:50:52.413  INFO 12052 --- [   main] 
trationDelegate$BeanPostProcessorChecker : Bean 
'org.apache.camel.spring.boot.CamelAutoConfiguration' of type 
[org.apache.camel.spring.boot.CamelAutoConfiguration$$EnhancerBySpringCGLIB$$5d14135]
 is not eligible for getting processed by all BeanPostProcessors (for example: 
not eligible for auto-proxying)
2017-07-18 10:50:53.063  INFO 12052 --- [   main] 
s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat initialized with port(s): 
8080 (http)
2017-07-18 10:50:53.085  INFO 12052 --- [   main] 
o.apache.catalina.core.StandardService   : Starting service Tomcat
2017-07-18 10:50:53.086  INFO 12052 --- [   main] 
org.apache.catalina.core.StandardEngine  : Starting Servlet Engine: Apache 
Tomcat/8.5.11
2017-07-18 10:50:53.341  INFO 12052 --- [ost-startStop-1] 
o.a.c.c.C.[Tomcat].[localhost].[/]   : Initializing Spring embedded 
WebApplicationContext
2017-07-18 10:50:53.342  INFO 12052 --- [ost-startStop-1] 
o.s.web.context.ContextLoader: Root WebApplicationContext: 
initialization completed in 4269 ms
2017-07-18 10:50:53.974  INFO 12052 --- [ost-startStop-1] 
o.s.b.w.servlet.ServletRegistrationBean  : Mapping servlet: 'dispatcherServlet' 
to [/]
2017-07-18 10:50:53.976  INFO 12052 --- [ost-startStop-1] 
o.s.b.w.servlet.ServletRegistrationBean  : Mapping servlet: 'CXFServlet' to 
[/services/*]
2017-07-18 10:50:53.981  INFO 12052 --- [ost-startStop-1] 
o.s.b.w.servlet.FilterRegistrationBean   : Mapping filter: 
'characterEncodingFilter' to: [/*]
2017-07-18 10:50:53.982  INFO 12052 --- [ost-startStop-1] 
o.s.b.w.servlet.FilterRegistrationBean   : Mapping filter: 
'hiddenHttpMethodFilter' to: [/*]
2017-07-18 10:50:53.982  INFO 12052 --- [ost-startStop-1] 
o.s.b.w.servlet.FilterRegistrationBean   : Mapping filter: 
'httpPutFormContentFilter' to: [/*]
2017-07-18 10:50:53.982  INFO 12052 --- [ost-startStop-1] 
o.s.b.w.servlet.FilterRegistrationBean   : Mapping filter: 
'requestContextFilter' to: [/*]
2017-07-18 10:50:54.682  INFO 12052 --- [   main] 
o.a.camel.spring.SpringCamelContext  : Apache Camel 2.19.1 (CamelContext: 
camel-1) is starting
2017-07-18 10:50:54.685  INFO 12052 --- [   main] 
o.a.c.m.ManagedManagementStrategy: JMX is enabled
2017-07-18 10:50:54.999  INFO 12052 --- [   main] 
o.a.c.i.converter.DefaultTypeConverter   : Loaded 214 type converters
2017-07-18 10:50:55.064  INFO 12052 --- [   main] 
o.a.c.i.DefaultRuntimeEndpointRegistry   : Runtime endpoint registry is in 
extended mode

Polling consumer poll period

2016-11-01 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

Although timer period is 10 seconds , when i check the logs I can see this 
polling occurs every 1 minute. I changed the polling consumer timeout but same 
result.
Why is this behaviour ?

Note : Using camel 2.18.0 with Spring Boot.


from("timer://mytimer?period=1")
  .bean(MyBean.class)
  .pollEnrich("imaps://"+host+":993 ",1000)
  .log("finish");

Log:

2016-11-02 07:23:05.375  INFO 22784 --- [timer://mytimer] route1
2016-11-02 07:24:05.376  INFO 22784 --- [timer://mytimer] route1
2016-11-02 07:25:05.376  INFO 22784 --- [timer://mytimer] route1




Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. Onay?m?z 
olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek istendi?i ki?i 
de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech A.?. bu mesaj?n 
i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun i?eri?inden, 
iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. Bu mesaj?n 
i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini i?ermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.

creating spring beans in routes

2016-10-19 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

Can I define new spring beans in xml route. If yes, how can I do that ?

Thank you.

http://camel.apache.org/schema/spring;>












[Facebook]  [Twitter] 


[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=19.10.201613:2200]


Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. Onay?m?z 
olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek istendi?i ki?i 
de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech A.?. bu mesaj?n 
i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun i?eri?inden, 
iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. Bu mesaj?n 
i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini i?ermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.

Designing many service routes

2016-09-23 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

I have more than 2 thousands web services(SOAP/REST) and want to move them to 
camel cxf. My question is about designing routes. Should I be designing at 
least one route for each service or I should try to find a way one generic 
route for all services. If both possible what are the pros and cons  of each 
methods?
As far as I know in generic route for all services case I will not be able to 
manage routes like start, stop, easily since all services will be affected. 
What else ?



[Facebook]  [Twitter] 


[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=24.09.201600:3000]


Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. Onay?m?z 
olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek istendi?i ki?i 
de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech A.?. bu mesaj?n 
i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun i?eri?inden, 
iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. Bu mesaj?n 
i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini i?ermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.

CXFRS swagger integration

2016-08-31 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

I have defined cxfrs route and its working fine. However when I integrate 
swagger2feature of cxf I can not see api docs. When i hit swagger.json path to 
get swagger response the request again hits my route which produces wrong 
response.
I think requests for swagger api should not hit my routes, what I am missing 
here?

url for get :
http://localhost:8080/api/servlet/rest/bookstore/1

returns :

{
  "name": "name",
  "isbn": "isbn",
  "price": 10
}



url for getting swagger response :

http://localhost:8080/api/servlet/rest/swagger.json

returns:

{
  "name": "name",
  "isbn": "isbn",
  "price": 10
}


Here is my interface:

@WebService
@Path("/bookstore")
@Consumes("application/json")
@Produces({"application/json","application/xml"})
@Api(value = "/bookstore ", description = "Operations about books")
public interface BookStore {

@WebMethod
@GET
@Path("/{id}")
@Consumes("*/*")
List getBook(@PathParam("id") @WebParam(name = "id") Long id) throws 
Exception;

@POST
@Path("/books")
@Consumes({"application/json","application/xml"})
Book addBook(Book book);

}

Here is the route:

from(endpoint)
.log("${headers}")
.process(new Processor() {

  @Override
  public void process(Exchange exchange) throws Exception {
Book b = new Book();
b.setIsbn("isbn");
b.setName("name");
b.setPrice(10.0);

exchange.getIn().setBody(b);
  }
});


[Facebook]  [Twitter] 


[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=31.08.201614:2300]


Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. Onay?m?z 
olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek istendi?i ki?i 
de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech A.?. bu mesaj?n 
i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun i?eri?inden, 
iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. Bu mesaj?n 
i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini i?ermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.

CXFRS vs New Rest DSL

2016-08-31 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

As company we have many soap and rest services and we want to rewrite our 
framework and move these services to camel-cxf.
I like the idea of having one interface definition and being able to expose it 
as soap and rest at the same time, I think we can do this with cxfrs.
However as far as I see camel community promotes new rest dsl which do not 
support cxf-rs currently.also swagger support also seem to be a question mark 
in cxfrs case.
Can somebody list pros and cons of these two frameworks, which one to choose in 
which condition especially if it will be used heavily.



[Facebook]  [Twitter] 


[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=31.08.201610:]


Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. Onay?m?z 
olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek istendi?i ki?i 
de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech A.?. bu mesaj?n 
i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun i?eri?inden, 
iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. Bu mesaj?n 
i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini i?ermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.

RE: Printing message history during root debug

2016-06-09 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi Claus,

Is there a way to do this without changing the route, for instance in eclipse 
display window invoking some methods ?

I tried to print with expression below but not working.

org.apache.camel.builder.SimpleBuilder.simple("${messageHistory}").evaluate(org.apache.camel.builder.ExchangeBuilder.anExchange(getContext()).build(),String.class)

-Original Message-
From: Claus Ibsen [mailto:claus.ib...@gmail.com] 
Sent: Thursday, June 09, 2016 12:01 PM
To: users@camel.apache.org
Subject: Re: Printing message history during root debug

If you are using Camel 2.17 you can use simple language to get it, and then log 
it easily

.log("${messageHistory}")



On Thu, Jun 9, 2016 at 10:55 AM, Kasim Sert (Ibtech-Software
Infrastructure) <kasim.s...@ibtech.com.tr> wrote:
> Hi,
>
> Is it  possible to print Message history (which is printed in case of errors 
> like below) during a route debug without error conditions. I just want to 
> learn how did I reach at that bean currently I am debugging. Is that possible 
> ?
>
>
> Message History
> ---
> RouteId  ProcessorId  Processor   
>  Elapsed (ms)
> [route25   ] [route25   ] [direct://FT_EXPORT_FILE
>] [ 0]
> [route25   ] [to109 ] [direct:pollOnDemand
>] [ 0]
> [route19   ] [bean179   ] 
> [bean[com.abc.mft.MftTransferGroup@c21c663c]] [   
>   0]
> [route19   ] [choice1   ] 
> [when[{header{header(pendingTranferExists)} == true}]choice[] 
>  ] [ 0]
> [route19   ] [bean180   ] 
> [bean[com.abc.mft.helper.CommonHelper]  ] [   
>   0]
>
>
> [Facebook]<http://secure-web.cisco.com/1meywFzt3s5XpduNtje3NllkoDbv0r_
> iP5bNGy5psx9M8o6d3uyfM6YnH3zfkzrrKKdsUggHYqvD7u3RC3DO6XVS6apoFVVjPrOxI
> nsCkx0YjITDzxqnJ-rIlOVViPhPTi-Y_ohVnTj4-mWmcminusaxPat_Ta0Wd5h-KrT0TA1
> WIQwQ7xWBRxjrGmYV1f6tgwWd11X7H0y6x003tIqUqyAk_inV3-3Kz_zAE4EclamEcozl7
> Np1hk-qtt7Nog1hTqvNhIZAZ4VC06pAfXVhpog/http%3A%2F%2Fwww.facebook.com%2
> FFinansbank>  [Twitter] <http://twitter.com/finansbank>
>
> [https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=09.06
> .201611:5500]<https://www.finansbank.com.tr/Disclaimer/Bannerlink.aspx
> ?date=09.06.201611:5500>
>
>
> Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. 
> Onay?m?z olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek 
> istendi?i ki?i de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech 
> A.?. bu mesaj?n i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda 
> bir garanti vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun 
> i?eri?inden, iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. 
> Bu mesaj?n i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini 
> i?ermeyebilir.
>
> The information contained in this e-mail (including any attachments)is 
> confidential. It must not be disclosed to any person without our authority. 
> If you are not the intended recipient, please delete it from your system 
> immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
> of any information contained in this message and hereby excludes any 
> liability of any kind for the information contained therein or for the 
> information transmission, reception, storage or use of such in any way 
> whatsoever. Any opinions expressed in this message are those of the author 
> and may not necessarily reflect the opinions of IBTech A.S.



--
Claus Ibsen
-
http://secure-web.cisco.com/1K-Aq_af5GUW8mxofqmD2R9SzXt9eHVU8W1ob1ZVYjKZIJWD79i3Xs2DEKNqSb3XjMGTx3VE_o2n1J9ra25BU0t8TUheOrHdoOjc4nA_N4MMkIY-R9ZmNw6tyamvs6jVK8Dj8UYGRkWg6IbXdqKjwppjisBNrHf7oAsMIOKcRtmyQRvhmXEndktZR3Tgp4M7NC-1JH6p42UZGujHtZfy9SF1hGm3vFQmBdA_zOacaGKVoshgdo-slmPmLuRYQMKIw/http%3A%2F%2Fdavsclaus.com
 @davsclaus Camel in Action 2: 
https://secure-web.cisco.com/1f-Lgx_lqKiWISJJvIFIaSSO8YA63_gYpYQmzeELhe1ImFSw5_AqIFwDkiPXtWsNro9pxYiARwsjn0Ld-HDu4cj3b0OCnKXGd-yS4644Y_2gYQA7dJ7cRWQXg_h6Vice8_QexTv5cv_G8kOOLMNEhldHzBl8QdbDsDriWYXY7bKxZccTKjAbbFWOp8L_d6qYAw81lsDbimBEUegB4KB5sJo9v38sk8nsWBXKIYHa2n6wmO3r9K67W7h6c8pQW7fmK/https%3A%2F%2Fwww.manning.com%2Fibsen2



Bu e-posta'nin içerdigi bilgiler (ekleri dahil olmak 
üzere) gizlidir. Onayimiz olmaksizin üçüncü kisilere açiklanamaz. Bu mesajin 
gönderilmek istendigi kisi degilseniz, lütfen mesaji sisteminizden de

Printing message history during root debug

2016-06-09 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

Is it  possible to print Message history (which is printed in case of errors 
like below) during a route debug without error conditions. I just want to learn 
how did I reach at that bean currently I am debugging. Is that possible ?


Message History
---
RouteId  ProcessorId  Processor 
   Elapsed (ms)
[route25   ] [route25   ] [direct://FT_EXPORT_FILE  
 ] [ 0]
[route25   ] [to109 ] [direct:pollOnDemand  
 ] [ 0]
[route19   ] [bean179   ] 
[bean[com.abc.mft.MftTransferGroup@c21c663c]] [ 
0]
[route19   ] [choice1   ] 
[when[{header{header(pendingTranferExists)} == true}]choice[]  
] [ 0]
[route19   ] [bean180   ] 
[bean[com.abc.mft.helper.CommonHelper]  ] [ 
0]


[Facebook]  [Twitter] 


[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=09.06.201611:5500]


Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. Onay?m?z 
olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek istendi?i ki?i 
de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech A.?. bu mesaj?n 
i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun i?eri?inden, 
iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. Bu mesaj?n 
i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini i?ermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.

ConcurrentModificationException during route listing

2016-05-13 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

I am using camel version 2.15.1. Sometimes I see 
ConcurrentModificationException in logs with following trace. With test case of 
adding and listing routes  concurrently I could not regenerate exception. Any 
idea about reason ?

Trace :

java.util.ConcurrentModificationException
at 
java.util.LinkedHashMap$LinkedHashIterator.nextEntry(LinkedHashMap.java:406)
at java.util.LinkedHashMap$KeyIterator.next(LinkedHashMap.java:417)
at java.util.AbstractCollection.toArray(AbstractCollection.java:153)
at java.util.ArrayList.(ArrayList.java:176)
at 
org.apache.camel.impl.DefaultCamelContext.getRoutes(DefaultCamelContext.java:695)
at 
org.apache.camel.impl.DefaultCamelContext.getRoute(DefaultCamelContext.java:701)
at 
com.mft.MftTransferDynamicPipelineRouteBuilder.calculateTransfersOfSingleSourceRefCompleteRoute(MftTransferDynamicPipelineRouteBuilder.java:218)
at sun.reflect.GeneratedMethodAccessor178.invoke(Unknown Source)
at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:56)
at java.lang.reflect.Method.invoke(Method.java:620)
at 
org.apache.camel.component.bean.MethodInfo.invoke(MethodInfo.java:408)
at 
org.apache.camel.component.bean.MethodInfo$1.doProceed(MethodInfo.java:279)
at 
org.apache.camel.component.bean.MethodInfo$1.proceed(MethodInfo.java:252)
at 
org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:171)
at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:109)
at 
org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java





Message History

---
RouteId  ProcessorId  Processor 
   Elapsed (ms)
[route24   ] [route24   ] [direct://FT_EXPORT_FILE  
 ] [ 34933]
[route32   ] [to112 ] 
[direct:transferSourceSet_split_paralel_sub
] [   823]
[route33   ] [bean207   ] 
[bean[com.mft.helper.CommonHelper]  ] [ 
0]
[route33   ] [doTry5] [doTry
 ] [   823]
[route33   ] [setHeader54   ] [setHeader[xfr]   
 ] [ 0]
[route33   ] [bean208   ] 
[bean[com.mft.helper.CommonHelper]  ] [ 
1]
[route33   ] [to113 ] 
[direct:transferSourceReference
] [   823]
[route35   ] [doTry7] [doTry
 ] [   620]
[route35   ] [to117 ] [direct:receiveFile   
 ] [   620]
[route37   ] [dynamicRouter2] 
[dynamicRouter[bean{com.mft.MftTransferDynamicPipelineRouteBuilder, ] [   
620]
[direct:dstrouter_r] [bean2295  ] 
[bean[com.mft.helper.CommonHelper]  ] [ 
0]
[direct:dstrouter_r] [bean2296  ] [bean[bean{com.mft.MftLog, 
method=setLogStatus(${body},0, s)}]  ] [25]
[direct:dstrouter_r] [to1527] [direct:checkActivity 
 ] [ 0]
[route47   ] [bean218   ] 
[bean[bean{com.mft.helper.CommonHelper, method=checkActivity(${body}] [ 
0]
[direct:dstrouter_r] [bean2297  ] [bean[bean{com.mft.MftLog, 
method=setLogStatus(${body},1, s)}]  ] [16]
[direct:dstrouter_r] [to1528] [direct:preReceiveCheck   
 ] [ 1]
[route43   ] [bean214   ] 
[bean[bean{com.mft.helper.CommonHelper, method=preReceiveCheck(${bod] [ 
1]
[direct:dstrouter_r] [to1529] [direct:cr_download   
 ] [   508]
[route77   ] [bean248   ] 
[bean[com.mft.ep.cr.CREndpointController@500a7290]  ] [   
508]
[direct:dstrouter_r] [to1530] [direct:postReceiveCheck  
 ] [ 0]
[route44   ] [bean215   ] 
[bean[bean{com.mft.helper.CommonHelper, method=postReceiveCheck(${bo] [ 
0]
[direct:dstrouter_r] [bean2298  ]

RE: Changing header value

2016-04-13 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

You mean since its a constant expression it is evaluated at the beginning and 
not changed after as far as I understand. So can I do it with simple expression 
instead of constant or should I introduce new processor to make it read current 
value of variable a.

Thank you.

-Original Message-
From: Siano, Stephan [mailto:stephan.si...@sap.com] 
Sent: Wednesday, April 13, 2016 12:11 PM
To: users@camel.apache.org
Subject: RE: Changing header value

Hi,

At the beginning of the route you are setting the header to the value a has 
when the route is started (it's a constant expression). In the processor you 
are incrementing the value and are then setting the header to the current value 
of the variable a, so the route behaves as one would expect.

Best regards
Stephan

-Original Message-
From: Kasim Sert (Ibtech-Software Infrastructure) 
[mailto:kasim.s...@ibtech.com.tr] 
Sent: Mittwoch, 13. April 2016 10:52
To: users@camel.apache.org
Subject: Changing header value

Hi,

Can somebody please explain, why header value for starting always remains same 
although its changed in processor ?

Route:
İnt a=1
from("timer://myTimer2?period=1000")
 .setHeader("myheader", constant(a))
 .log("starting...${header[myheader]}")
 .process(new Processor() {
   @Override
   public void process(Exchange exchange) 
throws Exception {
 a = a+1 ;
 exchange.getIn().setHeader("myheader", 
constant(a));
 Thread.sleep(1);
   }
 })
 .log("ending...${header[myheader]}");


Log produced:

2016-04-13 11:45:47,894 [imer://myTimer2] INFO  route1 
- starting...1
2016-04-13 11:45:57,899 [imer://myTimer2] INFO  route1 
- ending...2
2016-04-13 11:45:57,900 [imer://myTimer2] INFO  route1 
- starting...1
2016-04-13 11:46:07,900 [imer://myTimer2] INFO  route1 
- ending...3
2016-04-13 11:46:07,900 [imer://myTimer2] INFO  route1 
- starting...1
2016-04-13 11:46:17,901 [imer://myTimer2] INFO  route1 
- ending...4



[Facebook]<http://www.facebook.com/Finansbank>  [Twitter] 
<http://twitter.com/finansbank>

[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=13.04.201611:5100]<https://www.finansbank.com.tr/Disclaimer/Bannerlink.aspx?date=13.04.201611:5100>


Bu e-posta'nın içerdiği bilgiler (ekleri dahil olmak üzere) gizlidir. Onayımız 
olmaksızın üçüncü kişilere açiklanamaz. Bu mesajın gönderilmek istendiği kişi 
değilseniz, lütfen mesajı sisteminizden derhal siliniz. IBTech A.Ş. bu mesajın 
içerdiği bilgilerin doğruluğu veya eksiksiz olduğu konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne şekilde olursa olsun içeriğinden, 
iletilmesinden, alınmasından, saklanmasından sorumlu değildir. Bu mesajın 
içeriği yazarına ait olup, IBTech A.Ş.'nin görüşlerini içermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.


Bu e-posta'nin içerdigi bilgiler (ekleri dahil olmak 
üzere) gizlidir. Onayimiz olmaksizin üçüncü kisilere açiklanamaz. Bu mesajin 
gönderilmek istendigi kisi degilseniz, lütfen mesaji sisteminizden derhal 
siliniz. IBTech A.S. bu mesajin içerdigi bilgilerin dogrulugu veya eksiksiz 
oldugu konusunda bir garanti vermemektedir. Bu nedenle bilgilerin ne sekilde 
olursa olsun içeriginden, iletilmesinden, alinmasindan, saklanmasindan sorumlu 
degildir. Bu mesajin içerigi yazarina ait olup, IBTech A.S.'nin görüslerini 
içermeyebilir.

The information contained in this e-mail (including any 
attachments)is confidential. It must not be disclosed to any person without our 
authority. If you are not the intended recipient, please delete it from your 
system immediately. IBTech A.S. makes no warranty as to the accuracy or 
completeness of any information contained in this message and hereby excludes 
any liability of any kind for the information contained therein or for the 
information transmission, reception, storage or use of such in a

Changing header value

2016-04-13 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

Can somebody please explain, why header value for starting always remains same 
although its changed in processor ?

Route:
İnt a=1
from("timer://myTimer2?period=1000")
 .setHeader("myheader", constant(a))
 .log("starting...${header[myheader]}")
 .process(new Processor() {
   @Override
   public void process(Exchange exchange) 
throws Exception {
 a = a+1 ;
 exchange.getIn().setHeader("myheader", 
constant(a));
 Thread.sleep(1);
   }
 })
 .log("ending...${header[myheader]}");


Log produced:

2016-04-13 11:45:47,894 [imer://myTimer2] INFO  route1 
- starting...1
2016-04-13 11:45:57,899 [imer://myTimer2] INFO  route1 
- ending...2
2016-04-13 11:45:57,900 [imer://myTimer2] INFO  route1 
- starting...1
2016-04-13 11:46:07,900 [imer://myTimer2] INFO  route1 
- ending...3
2016-04-13 11:46:07,900 [imer://myTimer2] INFO  route1 
- starting...1
2016-04-13 11:46:17,901 [imer://myTimer2] INFO  route1 
- ending...4



[Facebook]  [Twitter] 


[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=13.04.201611:5100]


Bu e-posta'nın içerdiği bilgiler (ekleri dahil olmak üzere) gizlidir. Onayımız 
olmaksızın üçüncü kişilere açiklanamaz. Bu mesajın gönderilmek istendiği kişi 
değilseniz, lütfen mesajı sisteminizden derhal siliniz. IBTech A.Ş. bu mesajın 
içerdiği bilgilerin doğruluğu veya eksiksiz olduğu konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne şekilde olursa olsun içeriğinden, 
iletilmesinden, alınmasından, saklanmasından sorumlu değildir. Bu mesajın 
içeriği yazarına ait olup, IBTech A.Ş.'nin görüşlerini içermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.

RE: Camel reading file periodically

2016-03-25 Thread Kasim Sert (Ibtech-Software Infrastructure)

Thank you, now working.

-Original Message-
From: benny.gi...@gmail.com [mailto:benny.gi...@gmail.com] 
Sent: Friday, March 25, 2016 3:20 PM
To: users@camel.apache.org
Subject: Re: Camel reading file periodically

Hi, 

With Noop=true, Camel will set idempotent=true as well, to avoid consuming the 
same files over and over again.
So just set idempotent to false.

http://camel.apache.org/file2.html

Regards,

Benjamin Girstl

> Am 25.03.2016 um 13:53 schrieb Kasim Sert (Ibtech-Software Infrastructure) 
> <kasim.s...@ibtech.com.tr>:
> 
> Hi,
> 
> Why this route reads file for only one time, and what should I do to make it 
> work like excpected ?
> 
>from("timer://myTimer?period=1000")
> .log("starting...")
>
> .pollEnrich("file:d:/Workspaces/camel/demo-camel/src/main/resources?fileName=sample.xml=true=none",1000)
>.log("read message xml ${body}" );
> 
> 
> Prints:
> 
> 2016-03-25 14:45:21,274 [timer://myTimer] INFO  route1
>  - starting...
> 2016-03-25 14:45:22,287 [timer://myTimer] INFO  route1
>  - read message xml
> 2016-03-25 14:45:22,287 [timer://myTimer] INFO  route1
>  - starting...
> 2016-03-25 14:45:22,299 [timer://myTimer] INFO  route1
>  - read message xml 
> 2016-03-25 14:45:23,288 [timer://myTimer] INFO  route1
>  - starting...
> 2016-03-25 14:45:24,289 [timer://myTimer] INFO  route1
>  - read message xml
> 2016-03-25 14:45:24,289 [timer://myTimer] INFO  route1
>  - starting...
> 2016-03-25 14:45:25,290 [timer://myTimer] INFO  route1
>  - read message xml
> 2016-03-25 14:45:25,290 [timer://myTimer] INFO  route1
>  - starting...
> 2016-03-25 14:45:26,291 [timer://myTimer] INFO  route1
>  - read message xml
> 
> 
> [Facebook]<http://www.facebook.com/Finansbank>  [Twitter] 
> <http://twitter.com/finansbank>
> 
> [https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=25.03.201614:5300]<https://www.finansbank.com.tr/Disclaimer/Bannerlink.aspx?date=25.03.201614:5300>
> 
> 
> Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. 
> Onay?m?z olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek 
> istendi?i ki?i de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech 
> A.?. bu mesaj?n i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda 
> bir garanti vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun 
> i?eri?inden, iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. 
> Bu mesaj?n i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini 
> i?ermeyebilir.
> 
> The information contained in this e-mail (including any attachments)is 
> confidential. It must not be disclosed to any person without our authority. 
> If you are not the intended recipient, please delete it from your system 
> immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
> of any information contained in this message and hereby excludes any 
> liability of any kind for the information contained therein or for the 
> information transmission, reception, storage or use of such in any way 
> whatsoever. Any opinions expressed in this message are those of the author 
> and may not necessarily reflect the opinions of IBTech A.S.

Bu e-posta'nin i?erdigi bilgiler (ekleri dahil olmak 
?zere) gizlidir. Onayimiz olmaksizin ???nc? kisilere a?iklanamaz. Bu mesajin 
g?nderilmek istendigi kisi degilseniz, l?tfen mesaji sisteminizden derhal 
siliniz. IBTech A.S. bu mesajin i?erdigi bilgilerin dogrulugu veya eksiksiz 
oldugu konusunda bir garanti vermemektedir. Bu nedenle bilgilerin ne sekilde 
olursa olsun i?eriginden, iletilmesinden, alinmasindan, saklanmasindan sorumlu 
degildir. Bu mesajin i?erigi yazarina ait olup, IBTech A.S.'nin g?r?slerini 
i?ermeyebilir.

The information contained in this e-mail (including any 
attachments)is confidential. It must not be disclosed to any person without our 
authority. If you are not the intended recipient, please delete it from your 
system immediately. IBTech A.S. makes no warranty as to the accuracy or 
completeness of any information contained in this message and hereby excludes 
any liability of any kind for the information contained therein or for the 
information transmission, reception, storage or use of such in any way 
whatsoever. Any opinions expressed in this message are those of the author and 
may not necessarily reflect the opinions of IBTech 
A.S.

Camel reading file periodically

2016-03-25 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

Why this route reads file for only one time, and what should I do to make it 
work like excpected ?

from("timer://myTimer?period=1000")
 .log("starting...")

.pollEnrich("file:d:/Workspaces/camel/demo-camel/src/main/resources?fileName=sample.xml=true=none",1000)
.log("read message xml ${body}" );


Prints:

2016-03-25 14:45:21,274 [timer://myTimer] INFO  route1 
- starting...
2016-03-25 14:45:22,287 [timer://myTimer] INFO  route1 
- read message xml
2016-03-25 14:45:22,287 [timer://myTimer] INFO  route1 
- starting...
2016-03-25 14:45:22,299 [timer://myTimer] INFO  route1 
- read message xml 
2016-03-25 14:45:23,288 [timer://myTimer] INFO  route1 
- starting...
2016-03-25 14:45:24,289 [timer://myTimer] INFO  route1 
- read message xml
2016-03-25 14:45:24,289 [timer://myTimer] INFO  route1 
- starting...
2016-03-25 14:45:25,290 [timer://myTimer] INFO  route1 
- read message xml
2016-03-25 14:45:25,290 [timer://myTimer] INFO  route1 
- starting...
2016-03-25 14:45:26,291 [timer://myTimer] INFO  route1 
- read message xml


[Facebook]  [Twitter] 


[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=25.03.201614:5300]


Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. Onay?m?z 
olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek istendi?i ki?i 
de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech A.?. bu mesaj?n 
i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun i?eri?inden, 
iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. Bu mesaj?n 
i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini i?ermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.

FTP and SFTP connect method difference

2016-01-11 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

I have a camel application which polls thousands of folders in both ftp and 
sftp modes. Because of too many connection overhead, I am trying to pool 
connections. I have tried to pool RemoteFileOperations objects using 
DefaultServicePool utility and it seem to be working good for sftp case. 
However it does not work for ftp case since it does not control if its already 
connected to ftp at the beggining of connect method.

SftpOperations case :
public boolean connect(RemoteFileConfiguration configuration) throws 
GenericFileOperationFailedException {
if (isConnected()) {
// already connected
return true;
}


Since FtpOperations does not have this control it always reconnects. Is this a 
development bug or done for purpose.
What do you suggest me as a workaround for this?

Thanks in advance.


[Facebook]  [Twitter] 


[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=11.01.201611:0500]


Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. Onay?m?z 
olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek istendi?i ki?i 
de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech A.?. bu mesaj?n 
i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun i?eri?inden, 
iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. Bu mesaj?n 
i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini i?ermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.

FTP Connection Pooling in camel

2015-12-14 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

I want to limit the total number of connections to a ftp server. For this I 
want to implement a connection pool for the ftp component which will be used in 
both consumer and producer mode by camel. My question is should I write it on 
my own, or is it possible with configurations ? I checked documentation but can 
not find something related pooling.


[Facebook]  [Twitter] 


[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=14.12.201514:1700]


Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. Onay?m?z 
olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek istendi?i ki?i 
de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech A.?. bu mesaj?n 
i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun i?eri?inden, 
iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. Bu mesaj?n 
i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini i?ermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.

RE: Using BeanInvocation in camel cxf

2015-11-18 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

I have following route, generating the BeanInvocation manually. I am still not 
sure if that was necessary for ws call.

1)
from("direct:listCustomers")
.bean(Handler.class,"handleForward")
.bean(SOAPToBagTransformer.class)
.bean(QoSHandler.class)
.bean(CxfUtils.class,"cxfToPojo")
//here we have beanInvocation as message
.to(cxfEndpoint)
.bean(Handler.class,"handleBackward");

And I get following error.

Caused by: java.lang.ClassCastException: 
org.apache.camel.component.bean.BeanInvocation incompatible with 
java.lang.String

2)
When I do that it works,

from("direct:listCustomers")
.bean(Handler.class,"handleForward")
.bean(SOAPToBagTransformer.class)
.bean(QoSHandler.class)
.bean(CxfUtils.class,"cxfToPojo")
//here we have beanInvocation as message
.process(new Processor() {
@Override
public void process(Exchange e) throws Exception {
final BeanInvocation bi = e.getIn().getBody( 
BeanInvocation.class );
e.getIn().setBody( bi.getArgs() );
}
})
.to(cxfEndpoint)
.bean(Handler.class,"handleBackward");

However in that case generating InvocationBean is not necessary I think, just 
setting the message with appropriate ws parameters will also work..

3)
And finally when I invoke BeanInvocation it gets following exception.

from("direct:listCustomers")
.bean(Handler.class,"handleForward")
.bean(SOAPToBagTransformer.class)
.bean(QoSHandler.class)
.bean(CxfUtils.class,"cxfToPojo")
//here we have beanInvocation as message
.bean(BeanInvocation.class)
.to(cxfEndpoint)
.bean(Handler.class,"handleBackward");

org.apache.camel.RuntimeCamelException: java.lang.NullPointerException
at 
org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1619)
at 
org.apache.camel.component.bean.BeanInvocation.invoke(BeanInvocation.java:89)


-Original Message-
From: Henryk Konsek [mailto:hekon...@gmail.com] 
Sent: Tuesday, November 17, 2015 6:10 PM
To: users@camel.apache.org
Subject: Re: Using BeanInvocation in camel cxf

Hi Kasim,

Your route should work - it looks fine (just replace BeanInvocation with 
BeanInvocation.class).
Can you send us the stacktrace you see?

Cheers!

wt., 17.11.2015 o 16:08 użytkownik Steve Huston <shus...@riverace.com>
napisał:

> I have this excerpt from a Camel route in blueprint XML:
>
>   
>  
>  
> 
>   
>...
> 
>
> > -Original Message-
> > From: Kasim Sert (Ibtech-Software Infrastructure) 
> > [mailto:kasim.s...@ibtech.com.tr]
> > Sent: Tuesday, November 17, 2015 4:23 AM
> > To: users@camel.apache.org
> > Subject: Using BeanInvocation in camel cxf
> >
> > Hi,
> >
> > I am trying to develop a framework to invoke different web services 
> > based on their db definitions of SEI names and web method names and 
> > parameters etc.
> >
> > To make this I found how to generate and BeanInvocation object from 
> > current web service definition. However I could not find any example 
> > on
> how
> > to invoke this beaninvocation object.
> >
> > Should it be something like :
> >
> > From(direct:start)
> > .bean(BeanInvocation,"invoke")
> >
> > When I try this I get null pointer and even I dont know if this is 
> > right
> way to
> > go.
> >
> > Can anybody send an example usage on camel routes please ?
> >
> >
> > [Facebook]<http://www.facebook.com/Finansbank>  [Twitter] 
> > <http://twitter.com/finansbank>
> >
> > [https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=17.
> > 11 
> > .201511:2300]<https://www.finansbank.com.tr/Disclaimer/Bannerlink.aspx?
> > date=17.11.201511:2300>
> >
> >
> > Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir.
> Onay?m?z
> > olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek 
> > istendi?i ki?i de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. 
> > IBTech A.?.
> bu
> > mesaj?n i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda 
> > bir garanti vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa 
> > olsun i?eri?inden, iletilmesinden, al?nmas?ndan, saklanmas?ndan 
> > sorumlu
> de?ildir.
> > Bu mesaj?n i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini
> i?ermeyebilir.
> >
> > The informati

Using BeanInvocation in camel cxf

2015-11-17 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

I am trying to develop a framework to invoke different web services based on 
their db definitions of SEI names and web method names and parameters etc.

To make this I found how to generate and BeanInvocation object from current web 
service definition. However I could not find any example on how to invoke this 
beaninvocation object.

Should it be something like :

From(direct:start)
.bean(BeanInvocation,"invoke")

When I try this I get null pointer and even I dont know if this is right way to 
go.

Can anybody send an example usage on camel routes please ?


[Facebook]  [Twitter] 


[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=17.11.201511:2300]


Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. Onay?m?z 
olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek istendi?i ki?i 
de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech A.?. bu mesaj?n 
i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda bir garanti 
vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun i?eri?inden, 
iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. Bu mesaj?n 
i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini i?ermeyebilir.

The information contained in this e-mail (including any attachments)is 
confidential. It must not be disclosed to any person without our authority. If 
you are not the intended recipient, please delete it from your system 
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness 
of any information contained in this message and hereby excludes any liability 
of any kind for the information contained therein or for the information 
transmission, reception, storage or use of such in any way whatsoever. Any 
opinions expressed in this message are those of the author and may not 
necessarily reflect the opinions of IBTech A.S.

Dynamic reloading of spring xml

2015-11-16 Thread Kasim Sert (Ibtech-Software Infrastructure)

Hi,

When I was searching dynamic reloading of spring xml in camel, I came accros
with the following question in camel forum.

http://camel.465427.n5.nabble.com/Dynamic-reloading-of-routes-with-SpringXML-td3396990.html

I have basically the same question, I want to be able to reload spring xml with
bean definitions without camel restart.

Is the answer still no for this case ?

Question:
"
Hi,

For productive use of Camel we would need to add, remove reload routes at
runtime without interuption to other routes.
Most routes are defined using SpringXML. I have seen the smples of starting,
stop and packageScan, but it seems they are
all for Java DSL. I have not seen a way to dynamically load Spring DSL routes.

What I have come up with so far is to have each route in a different camel
context and load these multiple camel context
at runtime. I thought may be its a good idea to group a route and dependent
beans into one camel context (and one Spring
XML), because shutdown / restarting a route with its dependencies in productive
enviroment may not be trivial.

Is this the way of doing it? Is there a better way?

thanks for your advice,
Arno

Answer:

Spring doesnt support hot reloading of beans etc.
So usually if you run your application in a container (server) which
supports hot-deployment, then you just leverage that.
For example Apache ServiceMix supports that.

[Facebook] [Twitter]

[https://www.finansbank.com.tr/Disclaimer/BannerImages.aspx?date=16.11.201515:3200]

Bu e-posta'n?n i?erdi?i bilgiler (ekleri dahil olmak ?zere) gizlidir. Onay?m?z
olmaks?z?n ???nc? ki?ilere a?iklanamaz. Bu mesaj?n g?nderilmek istendi?i ki?i
de?ilseniz, l?tfen mesaj? sisteminizden derhal siliniz. IBTech A.?. bu mesaj?n
i?erdi?i bilgilerin do?rulu?u veya eksiksiz oldu?u konusunda bir garanti
vermemektedir. Bu nedenle bilgilerin ne ?ekilde olursa olsun i?eri?inden,
iletilmesinden, al?nmas?ndan, saklanmas?ndan sorumlu de?ildir. Bu mesaj?n
i?eri?i yazar?na ait olup, IBTech A.?.'nin g?r??lerini i?ermeyebilir.

The information contained in this e-mail (including any attachments)is
confidential. It must not be disclosed to any person without our authority. If
you are not the intended recipient, please delete it from your system
immediately. IBTech A.S. makes no warranty as to the accuracy or completeness
of any information contained in this message and hereby excludes any liability
of any kind for the information contained therein or for the information
transmission, reception, storage or use of such in any way whatsoever. Any
opinions expressed in this message are those of the author and may not
necessarily reflect the opinions of IBTech A.S.

Binding ws parameters to method in cxf