receive message from Rest webservice

[takidean]

hi i use to send message from Rest web service but i get this problem
qtp18105374-27] JAXRSUtils WARN  No
operation matching request path "/route/MessageResource/message" is found,
Relative Path: /message, HTTP Method: POST, ContentType:
application/xml;charset=UTF-8, Accept:
text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8,. Please
enable FINE/TRACE log level for more details.
[qtp18105374-27] WebApplicationExceptionMapper  WARN 
javax.ws.rs.WebApplicationException
at
org.apache.cxf.jaxrs.utils.JAXRSUtils.findTargetMethod(JAXRSUtils.java:414)
at
org.apache.cxf.jaxrs.interceptor.JAXRSInInterceptor.processRequest(JAXRSInInterceptor.java:213)
at
org.apache.cxf.jaxrs.interceptor.JAXRSInInterceptor.handleMessage(JAXRSInInterceptor.java:90)
at
org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:271)
at
org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:121)
at
org.apache.cxf.transport.http_jetty.JettyHTTPDestination.serviceRequest(JettyHTTPDestination.java:355)
at
org.apache.cxf.transport.http_jetty.JettyHTTPDestination.doService(JettyHTTPDestination.java:319)
at
org.apache.cxf.transport.http_jetty.JettyHTTPHandler.handle(JettyHTTPHandler.java:72)
at
org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1074)
at
org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1010)
at
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135)
at
org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:255)
at
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116)
at org.eclipse.jetty.server.Server.handle(Server.java:365)
at
org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:485)
at
org.eclipse.jetty.server.AbstractHttpConnection.content(AbstractHttpConnection.java:937)
at
org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.content(AbstractHttpConnection.java:998)
at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:856)
at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:240)
at
org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82)
at
org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:627)
at
org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:51)
at
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608)
at
org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543)
at java.lang.Thread.run(Thread.java:662)


this is my code
/*MessageProcessor**/
package com.pfe.test.rout;

import java.util.ArrayList;
import java.util.List;

import javax.ws.rs.Consumes;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.UriInfo;


@Path("/MessageResource/")
public class MessageResource {
List messages = new ArrayList();

@Context 
private UriInfo uriInfo;
public MessageResource(){
}
@POST 
@Path("message")
@Consumes("application/xml")
public Response receiveMessage(Message message){
return null;
}

}
/Processor***/
package com.pfe.test.rout;

import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
import org.apache.camel.model.RemoveHeaderDefinition;

public class MyProcessor implements Processor{

@Override
public void process(Exchange exchange) throws Exception {
exchange.removeProperty(exchange.HTTP_URI); 
exchange.removeProperty(exchange.HTTP_METHOD);  
Message inMessage = (Message) exchange.getIn().getBody();
inMessage.toString();
exchange.getOut().setBody(inMessage);


}

}
/***Camel context**/
package com.pfe.test.rout;

import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
import org.apache.camel.model.RemoveHeaderDefinition;

public class MyProcessor implements Processor{

@Override
public void process(Exchange exchange) throws Exception {
exchange.removeProperty(exchange.HTTP_URI); 
exchange.removeProperty(exchange.HTTP_METHOD);  
Message inMessage = (Message) exchange.getIn().getBody();
inMessage.toString();
exchange.getOut().setBody(inMessage);


}

}
/*thjis is the message i used to send using firefox poster
plugin**/


aaa


aaa







--
View this message in context: 
http://camel.465427.n5.nabble.com/receive-message-from-Rest-webservice-tp5731048.html
Sent from the

Re: Camel Properties override

[Willem jiang]

Hi,

I just checked the code of Camel Properties component, the last one will 
override the first one value.  

--  
Willem Jiang

Red Hat, Inc.
FuseSource is now part of Red Hat
Web: http://www.fusesource.com | http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) 
(English)
  http://jnn.iteye.com (http://jnn.javaeye.com/) (Chinese)
Twitter: willemjiang  
Weibo: 姜宁willem





On Wednesday, April 17, 2013 at 11:21 PM, valerian.merkling wrote:

> Hi !
>  
> Just a quick question about properties.
>  
> If I define two property files like this :
>  
>  class="org.apache.camel.component.properties.PropertiesComponent">
> 
> 
> classpath:test1.properties
> file:${karaf.home}/etc/test2.properties
> 
> 
> 
>  
> And test1 and test2 both define the /foo/property, am I sure that I will
> always have the value defined in test2 ?  
>  
> I made a few test, and it seems that it is ok, but i need to be sure.
>  
> Best regards,  
>  
> Valerian Merkling
>  
>  
>  
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Camel-Properties-override-tp5731025.html
> Sent from the Camel - Users mailing list archive at Nabble.com 
> (http://Nabble.com).

Re: cxf producer needs a break?

[Willem.Jiang]

camel-cxf is using the asyn invocation by default, if you add the
synchronous=true , it will use the synchronous invocation instead.

Willem




--
View this message in context: 
http://camel.465427.n5.nabble.com/cxf-producer-needs-a-break-tp5730612p5731050.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: consumer.bridgeErrorHandler=true on netty uri

[Willem jiang]

Hi,

I'm not sure how did you find the option, I just check the netty page[1], there 
is no such a option.

[1]http://camel.apache.org/netty.html  

--  
Willem Jiang

Red Hat, Inc.
FuseSource is now part of Red Hat
Web: http://www.fusesource.com | http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) 
(English)
  http://jnn.iteye.com (http://jnn.javaeye.com/) (Chinese)
Twitter: willemjiang  
Weibo: 姜宁willem





On Thursday, April 18, 2013 at 3:09 AM, fbarbat wrote:

> Hi,
>  
> I tried to use consumer.bridgeErrorHandler=true on a netty endpoint but it
> had no effect. From what I see from Camel's source, it looks like this
> parameter is not used although NettyConsumer extends DefaultConsumer. Is
> there any way to bridge the exceptionHandler to the errorHandler in netty
> component?
>  
> In my case, I just want to have custom logic if a
> java.nio.channels.ClosedChannelException is thrown when the consumer is
> writing a response.
>  
> Thanks.
>  
>  
>  
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/consumer-bridgeErrorHandler-true-on-netty-uri-tp5731038.html
> Sent from the Camel - Users mailing list archive at Nabble.com 
> (http://Nabble.com).

Re: CXF Bean, MultiPart -> Couldn't find MIME boundary

[Christian Müller]

Can you enable stream caching and try it again.

http://camel.apache.org/stream-caching.html

Best,
Christian

Sent from a mobile device
Am 17.04.2013 23:53 schrieb "Calvert, Zach (Zach)** CTR **" <
zcalv...@motive.com>:

> I'm having trouble submitting a multi-part form to a CXF endpoint.  My
> route looks like:
> 
> https://0.0.0.0:9005/submit/?matchOnUriPrefix=true"/>
> 
> 
> 
> Where the list is a util list of 1 endpoint consuming a POST method.  The
> HTML form code is retrieved from the same path using a GET, resulting in:
>
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
>
> Submitting a post triggers this in the logs:
> 2013-04-17 15:55:40,900 | WARN  | qtp11314826-356  |
> WebApplicationExceptionMapper|  -  -  | WebApplicationException has
> been caught : Couldn't find MIME boundary:
> -173102388111750
>
> I walked the code to org.apache.cxf.attachment.AttachmentDeserializer
> Where it obtains the "InputStream" content body using:
> ...
> boundary = boundaryString.getBytes("utf-8");
>
> stream = new
> PushbackInputStream(message.getContent(InputStream.class),
>  pbAmount);
> ...
>
> The resulting InputStream from the CXF Message, while non-null, always
> returns -1 at the first read.  In other words, this InputStream is empty
> 100% of the time.  I've verified using different browsers that the content
> is submitted, and the MIME boundary is populated in the content.  What is
> going on with the input stream?  Have I configured my CXF endpoint
> incorrectly in some way, or am I missing a configuration detail in the form?
>
> Any and all help is greatly appreciated!
>
>
> Thank you,
> Zach Calvert
>
>
>

CXF Bean, MultiPart -> Couldn't find MIME boundary

[Calvert, Zach (Zach)** CTR **]

I'm having trouble submitting a multi-part form to a CXF endpoint.  My route 
looks like:

https://0.0.0.0:9005/submit/?matchOnUriPrefix=true"/>



Where the list is a util list of 1 endpoint consuming a POST method.  The HTML 
form code is retrieved from the same path using a GET, resulting in:













Submitting a post triggers this in the logs:
2013-04-17 15:55:40,900 | WARN  | qtp11314826-356  | 
WebApplicationExceptionMapper|  -  -  | WebApplicationException has been 
caught : Couldn't find MIME boundary: 
-173102388111750

I walked the code to org.apache.cxf.attachment.AttachmentDeserializer
Where it obtains the "InputStream" content body using:
...
boundary = boundaryString.getBytes("utf-8");

stream = new 
PushbackInputStream(message.getContent(InputStream.class),
 pbAmount);
...

The resulting InputStream from the CXF Message, while non-null, always returns 
-1 at the first read.  In other words, this InputStream is empty 100% of the 
time.  I've verified using different browsers that the content is submitted, 
and the MIME boundary is populated in the content.  What is going on with the 
input stream?  Have I configured my CXF endpoint incorrectly in some way, or am 
I missing a configuration detail in the form?

Any and all help is greatly appreciated!


Thank you,
Zach Calvert

Re: Why doesn't SFTP "move" option work??

[Chris Wolf]

I took the FromFtpMoveFileTest and modified it for SFTP - that works,
so "move" works
for SFTP.  My problem is that because the current release requires
hard-coding the
URI for (s)ftp(s) consumer - I implemented a custom processor that
instantiates the SFTP component,
SFTP endpoint and SFTP consumer, all programatically.  Obviously, I'm
missing something.
Unfortunately, it's pretty much a show-stopper for us to not be able
to SFTP *from* (consume)
dynamically (runtime-calculated) URIs.

On Wed, Apr 17, 2013 at 4:54 PM, Chris Wolf  wrote:
> I notice there's a unit test, FromFtpMoveFileTest, for plain FTP, but
> not for SFTP - should I file a bug, or am I doing something
> wrong?
>
> On Wed, Apr 17, 2013 at 11:39 AM, Chris Wolf  wrote:
>> Trying to use Sftp component.   I am using localWorkDirectory because
>> I don't want the whole files loaded into memory.
>> Seems like the files *are* being downloaded but they are NOT being
>> moved, on the remote side to the directory indicated by the "move"
>> option.
>>
>>
>> Here, on a poll, it gets a file, while downloading to
>> "localWorkDirectory", the file's name is appended with ".inprogress",
>> then it's
>> renamed to the base file name without ".inprogress" - so far, so good,
>> except on the server-side, it's not moved to the "move" directory.
>>
>> [#4 - sftp://localhost/download] SftpOperations DEBUG Retrieve file to
>> local work file result: true
>> [#4 - sftp://localhost/download] SftpOperations TRACE Renaming local
>> in progress file from:
>> \tmp\local\ftpwork\ADPT5_MKT_20120319_VOIR_DAILY.csv.inprogress to:
>> \tmp\local\ftpwork\ADPT5_MKT_20120319_VOIR_DAILY.csv
>> [#4 - sftp://localhost/download] SftpConsumer  TRACE Retrieved file:
>> download/ADPT5_MKT_20120319_VOIR_DAILY.csv from:
>> Endpoint[sftp://localhost/download]
>>
>> ...then, at poll n+1, I see:
>>
>> [#4 - sftp://localhost/download] SftpConsumer TRACE
>> SftpFile[fileName=ADPT5_MKT_20120319_VOIR_DAILY.csv,
>> longName=-rwxrwxrwx   1 adpt5adpt5  298313 Apr 17 09:42
>> ADPT5_MKT_20120319_VOIR_DAILY.csv, dir=false]
>> [#4 - sftp://localhost/download] SftpConsumer TRACE Skipping as file
>> is already in progress: ADPT5_MKT_20120319_VOIR_DAILY.csv
>>
>> I guess that's the idempotent mechanism, but that file should have
>> been moved out of that directory.
>>
>>
>> SftpConfiguration:
>>
>> chmod = null,
>> ciphers = null,
>> compression = 0,
>> connectTimeout = 1,
>> directory = download,
>> host = localhost,
>> knownHostsFile = null,
>> password = adpt5,
>> port = 22,
>> privateKeyFile = null,
>> privateKeyFilePassphrase = null,
>> protocol = sftp,
>> separator = UNIX,
>> serverAliveCountMax = 1,
>> serverAliveInterval = 0,
>> siteCommand = null,
>> soTimeout = 0,
>> strictHostKeyChecking = no,
>> timeout = 3,
>> username = adpt5,
>> binary = true,
>> passiveMode = false,
>> stepwise = true,
>> throwExceptionOnConnectFailed = false
>>
>> [1) thread #0 - timer://kickoff] INFO  SftpEndpoint:
>> antFilter = null,
>> bufferSize = 131072,
>> camelContext = CamelContext(camel-1),
>> charset = null,
>> component = org.apache.camel.component.file.remote.SftpComponent@1e34f445,
>> configuration = download,
>> consumerProperties = null,
>> doneFileName = null,
>> endpointConfiguration =
>> org.apache.camel.impl.MappedEndpointConfiguration@8292f75a,
>> endpointKey = sftp://localhost/download,
>> endpointUri = sftp://localhost/download,
>> exchangePattern = InOnly,
>> exchanges = [Exchange[ADPT5_MKT_20090211_MICF.csv],
>> Exchange[ADPT5_MKT_20090211_MINOCF.csv],
>> Exchange[ADPT5_MKT_20090305_VOE.csv],
>> Exchange[ADPT5_MKT_20090305_VOIR.csv],
>> Exchange[ADPT5_MKT_20120319_DAILY.csv],
>> Exchange[ADPT5_MKT_20120319_FX.csv],
>> Exchange[ADPT5_MKT_20120319_MTX_DAILY.csv],
>> Exchange[ADPT5_MKT_20120319_VOIR_DAILY.csv],
>> Exchange[ADPT5_MKT_20121121_HISTORY_EUR_IRBank-FZ-D.csv],
>> Exchange[ADPT5_MKT_20121121_HISTORY_EUR_IRBank-FZ-M.csv],
>> Exchange[ADPT5_MKT_20121121_HISTORY_EUR_IRBank-FZ-Y.csv]],
>> exclude = null,
>> exclusiveReadLockStrategy = null,
>> fileExist = Override,
>> fileName = null,
>> fileSeparator = /,
>> filter = ms.algo.adapt.camel.cpmd.CPMDFileFilter@54aa2db,
>> genericFileProcessStrategy =
>> org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@67b14530,
>> id = endpoint13,
>> idempotentRepository = null,
>> include = null,
>> inProgressRepository =
>> org.apache.camel.processor.idempotent.MemoryIdempotentRepository@563b100c,
>> localWorkDirectory = /tmp/local/ftpwork,
>> maxDepth = 2147483647,
>> maximumReconnectAttempts = 3,
>> maxMessagesPerPoll = 0,
>> minDepth = 0,
>> move = ${file:parent}/../archive/${file:onlyname},,
>> moveExisting = null,
>> moveFailed = null,
>> preMove = null,
>> processStrategy =
>> org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@67b14530,
>> readLock = none,
>> readLockCheckInterval = 5000,
>> readLockMinLength = 1,
>> readLockTimeout = 2,
>> reconnectDelay = 1000,
>> scheme = sftp,
>> so

Re: HTTP with Jetty as consumer with Client Cert Authenticator

[Christian Müller]

Did you checked
http://cxf.apache.org/docs/client-http-transport-including-ssl-support.html?

If you want to use Java code, we do the following:

public class PremiumGatewayJAXWSRouteBuilderTest extends
CamelSpringTestSupport {

private static JaxWsProxyFactoryBean factory;
private static XYZService port;

public void doPostSetup() throws Exception {
factory = new JaxWsProxyFactoryBean();
factory.setBus(BusFactory.getDefaultBus());
factory.setAddress("https://localhost:9875/services/jaxws";);
factory.getOutInterceptors().add(new LoggingOutInterceptor());
factory.getInInterceptors().add(new LoggingInInterceptor());
factory.setServiceClass(XYZService.class);
port = (XYZService) factory.create();

HTTPConduit httpConduit = (HTTPConduit)
ClientProxy.getClient(port).getConduit();
TLSClientParameters tlsClientParameters = new TLSClientParameters();

KeyStore keyStore = KeyStore.getInstance(KeyStore.getDefaultType());
keyStore.load(
this.getClass().getResourceAsStream("/client.jks"),
"password".toCharArray());
KeyManagerFactory keyMgrFactory =
KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
keyMgrFactory.init(keyStore, "password".toCharArray());
tlsClientParameters.setKeyManagers(keyMgrFactory.getKeyManagers());

KeyStore trustStore =
KeyStore.getInstance(KeyStore.getDefaultType());
trustStore.load(
this.getClass().getResourceAsStream("/client.jks"),
"password".toCharArray());
TrustManagerFactory trustMgrFactory =
TrustManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
trustMgrFactory.init(trustStore);

tlsClientParameters.setTrustManagers(trustMgrFactory.getTrustManagers());

tlsClientParameters.setDisableCNCheck(true);

httpConduit.setTlsClientParameters(tlsClientParameters);
}

@Test
public void testFindAccounts() {
XXXResponse response = port.findXXX(new XXXRequest());

assertXXX(response);
}
}

Best,
Christian


On Wed, Apr 17, 2013 at 2:03 PM, Laurentiu Trica <
laurentiu.tr...@moredevs.ro> wrote:

> Hi,
>
> I need to use jetty as HTTP consumer with Client Cert Authenticator.
> In other words, the client should be authenticated by a certificate, not
> the Basic method.
>
> How could I do this?
> Any help is very appreciated!
>
> Thank you in advance,
> Laurentiu
>

Re: Why doesn't SFTP "move" option work??

[Chris Wolf]

I notice there's a unit test, FromFtpMoveFileTest, for plain FTP, but
not for SFTP - should I file a bug, or am I doing something
wrong?

On Wed, Apr 17, 2013 at 11:39 AM, Chris Wolf  wrote:
> Trying to use Sftp component.   I am using localWorkDirectory because
> I don't want the whole files loaded into memory.
> Seems like the files *are* being downloaded but they are NOT being
> moved, on the remote side to the directory indicated by the "move"
> option.
>
>
> Here, on a poll, it gets a file, while downloading to
> "localWorkDirectory", the file's name is appended with ".inprogress",
> then it's
> renamed to the base file name without ".inprogress" - so far, so good,
> except on the server-side, it's not moved to the "move" directory.
>
> [#4 - sftp://localhost/download] SftpOperations DEBUG Retrieve file to
> local work file result: true
> [#4 - sftp://localhost/download] SftpOperations TRACE Renaming local
> in progress file from:
> \tmp\local\ftpwork\ADPT5_MKT_20120319_VOIR_DAILY.csv.inprogress to:
> \tmp\local\ftpwork\ADPT5_MKT_20120319_VOIR_DAILY.csv
> [#4 - sftp://localhost/download] SftpConsumer  TRACE Retrieved file:
> download/ADPT5_MKT_20120319_VOIR_DAILY.csv from:
> Endpoint[sftp://localhost/download]
>
> ...then, at poll n+1, I see:
>
> [#4 - sftp://localhost/download] SftpConsumer TRACE
> SftpFile[fileName=ADPT5_MKT_20120319_VOIR_DAILY.csv,
> longName=-rwxrwxrwx   1 adpt5adpt5  298313 Apr 17 09:42
> ADPT5_MKT_20120319_VOIR_DAILY.csv, dir=false]
> [#4 - sftp://localhost/download] SftpConsumer TRACE Skipping as file
> is already in progress: ADPT5_MKT_20120319_VOIR_DAILY.csv
>
> I guess that's the idempotent mechanism, but that file should have
> been moved out of that directory.
>
>
> SftpConfiguration:
>
> chmod = null,
> ciphers = null,
> compression = 0,
> connectTimeout = 1,
> directory = download,
> host = localhost,
> knownHostsFile = null,
> password = adpt5,
> port = 22,
> privateKeyFile = null,
> privateKeyFilePassphrase = null,
> protocol = sftp,
> separator = UNIX,
> serverAliveCountMax = 1,
> serverAliveInterval = 0,
> siteCommand = null,
> soTimeout = 0,
> strictHostKeyChecking = no,
> timeout = 3,
> username = adpt5,
> binary = true,
> passiveMode = false,
> stepwise = true,
> throwExceptionOnConnectFailed = false
>
> [1) thread #0 - timer://kickoff] INFO  SftpEndpoint:
> antFilter = null,
> bufferSize = 131072,
> camelContext = CamelContext(camel-1),
> charset = null,
> component = org.apache.camel.component.file.remote.SftpComponent@1e34f445,
> configuration = download,
> consumerProperties = null,
> doneFileName = null,
> endpointConfiguration =
> org.apache.camel.impl.MappedEndpointConfiguration@8292f75a,
> endpointKey = sftp://localhost/download,
> endpointUri = sftp://localhost/download,
> exchangePattern = InOnly,
> exchanges = [Exchange[ADPT5_MKT_20090211_MICF.csv],
> Exchange[ADPT5_MKT_20090211_MINOCF.csv],
> Exchange[ADPT5_MKT_20090305_VOE.csv],
> Exchange[ADPT5_MKT_20090305_VOIR.csv],
> Exchange[ADPT5_MKT_20120319_DAILY.csv],
> Exchange[ADPT5_MKT_20120319_FX.csv],
> Exchange[ADPT5_MKT_20120319_MTX_DAILY.csv],
> Exchange[ADPT5_MKT_20120319_VOIR_DAILY.csv],
> Exchange[ADPT5_MKT_20121121_HISTORY_EUR_IRBank-FZ-D.csv],
> Exchange[ADPT5_MKT_20121121_HISTORY_EUR_IRBank-FZ-M.csv],
> Exchange[ADPT5_MKT_20121121_HISTORY_EUR_IRBank-FZ-Y.csv]],
> exclude = null,
> exclusiveReadLockStrategy = null,
> fileExist = Override,
> fileName = null,
> fileSeparator = /,
> filter = ms.algo.adapt.camel.cpmd.CPMDFileFilter@54aa2db,
> genericFileProcessStrategy =
> org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@67b14530,
> id = endpoint13,
> idempotentRepository = null,
> include = null,
> inProgressRepository =
> org.apache.camel.processor.idempotent.MemoryIdempotentRepository@563b100c,
> localWorkDirectory = /tmp/local/ftpwork,
> maxDepth = 2147483647,
> maximumReconnectAttempts = 3,
> maxMessagesPerPoll = 0,
> minDepth = 0,
> move = ${file:parent}/../archive/${file:onlyname},,
> moveExisting = null,
> moveFailed = null,
> preMove = null,
> processStrategy =
> org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@67b14530,
> readLock = none,
> readLockCheckInterval = 5000,
> readLockMinLength = 1,
> readLockTimeout = 2,
> reconnectDelay = 1000,
> scheme = sftp,
> sortBy = null,
> sorter = null,
> status = Started,
> tempFileName = null,
> tempPrefix = null,
> version = 2.10.4,
> allowNullBody = false,
> autoCreate = true,
> delete = false,
> directoryMustExist = false,
> disconnect = false,
> eagerDeleteTargetFile = true,
> eagerMaxMessagesPerPoll = true,
> fastExistsCheck = false,
> flatten = false,
> keepLastModified = false,
> lenientProperties = false,
> noop = false,
> recursive = false,
> runAllowed = true,
> singleton = true,
> started = true,
> starting = false,
> startingDirectoryMustExist = false,
> stopped = false,
> stopping = false,
> suspended = false,
> suspending = false,
> synchronous = false

Re: Insane logs about RouteContextProcessor

[lleclerc]

Thank you! 

Adding the link to JIRA :

https://issues.apache.org/jira/browse/CAMEL-6220



--
View this message in context: 
http://camel.465427.n5.nabble.com/Insane-logs-about-RouteContextProcessor-tp5731023p5731041.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Bindy fixed length

[Magnus Palmér]

There are examples of how to do it on the Bindy documentation page:
http://camel.apache.org/bindy.html

Look for the @Link


2013/4/17 fbarbat 

> Sorry, after I wrote the post I felt it wasn't clear enough too...
> I wanted to ask if there was a feature to similar to Hibernate's components
> (or BeanIO segments) to break the bean into a root bean and smaller nested
> beans.
>
> For example, let's suppose I have this line:
> NAME--LAST_NAME-ADDRESS---ZIP_CODE--
>
> We could model this line as a POJO called Person, and it would be something
> like this:
>
> @FixedLengthRecord
> class Person{
> @DataField(pos=1, length=10)
> private String name;
> @DataField(pos=2, length=10)
> private String lastName;
> @DataField(pos=3, length=10)
> private String address;
> @DataField(pos=4, length=10)
> private String zipCode;
>
> //Getters and setters...
> }
>
> Now, if the amount of fields grows too much, I would like to split this
> object into several nested objects. For example, now I want to have two
> objects:
>
> //Nested bean, relative to the position specified in parent bean
> @FixedLengthRecord
> class Address{
> @DataField(pos=1, length=10)
> private String address;
> @DataField(pos=2, length=10)
> private String zipCode;
>
> //Getters and setters...
> }
>
> //Root bean
> @FixedLengthRecord
> class Person {
> @DataField(pos=1, length=10)
> private String name;
> @DataField(pos=2, length=10)
> private String lastName;
> @DataField(pos=3, length=10)
> private Address address;
>
> //Getters and setters
> }
>
> I tried to find a feature like this in Bindy but I couldn't find one. As a
> workaround, I switched to BeanIO for marshalling/unmarshalling this way.
> Anyway, I would have liked to use annotations instead of the BeanIO XML
> file.
>
> Thanks,.
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Bindy-fixed-length-tp5730980p5731037.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

consumer.bridgeErrorHandler=true on netty uri

[fbarbat]

Hi,

I tried to use consumer.bridgeErrorHandler=true on a netty endpoint but it
had no effect. From what I see from Camel's source, it looks like this
parameter is not used although NettyConsumer extends DefaultConsumer. Is
there any way to bridge the exceptionHandler to the errorHandler in netty
component?

In my case, I just want to have custom logic if a
java.nio.channels.ClosedChannelException is thrown when the consumer is
writing a response.

Thanks.



--
View this message in context: 
http://camel.465427.n5.nabble.com/consumer-bridgeErrorHandler-true-on-netty-uri-tp5731038.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Bindy fixed length

[fbarbat]

Sorry, after I wrote the post I felt it wasn't clear enough too...
I wanted to ask if there was a feature to similar to Hibernate's components
(or BeanIO segments) to break the bean into a root bean and smaller nested
beans. 

For example, let's suppose I have this line:
NAME--LAST_NAME-ADDRESS---ZIP_CODE--

We could model this line as a POJO called Person, and it would be something
like this:

@FixedLengthRecord
class Person{
@DataField(pos=1, length=10)
private String name;
@DataField(pos=2, length=10)
private String lastName;
@DataField(pos=3, length=10)
private String address;
@DataField(pos=4, length=10)
private String zipCode;

//Getters and setters...
}

Now, if the amount of fields grows too much, I would like to split this
object into several nested objects. For example, now I want to have two
objects:

//Nested bean, relative to the position specified in parent bean
@FixedLengthRecord
class Address{
@DataField(pos=1, length=10)
private String address;
@DataField(pos=2, length=10)
private String zipCode;

//Getters and setters...
}

//Root bean
@FixedLengthRecord
class Person {
@DataField(pos=1, length=10)
private String name;
@DataField(pos=2, length=10)
private String lastName;
@DataField(pos=3, length=10)
private Address address;

//Getters and setters
}

I tried to find a feature like this in Bindy but I couldn't find one. As a
workaround, I switched to BeanIO for marshalling/unmarshalling this way.
Anyway, I would have liked to use annotations instead of the BeanIO XML
file.

Thanks,.



--
View this message in context: 
http://camel.465427.n5.nabble.com/Bindy-fixed-length-tp5730980p5731037.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: cxf producer needs a break?

[Smith-John]

Hi,

added the issue to the JIRA[1].

Regards.

[1]https://issues.apache.org/jira/browse/CAMEL-6295



--
View this message in context: 
http://camel.465427.n5.nabble.com/cxf-producer-needs-a-break-tp5730612p5731036.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Splitting XML into multiple separate bits and send out to webservices

[RTernier]

I'm still not sure the best route to take.

If I have the XML Message:



I want to take the first node (which can be found through xpath) and send
that to another Web Service. I then need to check to see if the attribute
foo exists in the 2nd element, and if so, manually create another XML file
(probably through a quick XSL transform ) and send it to another.

Then I need to take both responses, and push them together.

What is the best way to do this within Camel?





--
View this message in context: 
http://camel.465427.n5.nabble.com/Splitting-XML-into-multiple-separate-bits-and-send-out-to-webservices-tp5730936p5731034.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Using # notation in java dsl

[swwyatt]

I am trying to configure a file route with the idempotentRepository option
using route builder. Seems you cannot reference spring beans using #
notation as you would in spring dsl. Is there a simple way to achieve this
in java dsl?

v2.8.1

from("file://c:/temp?idempotentRepository=#repo").to("file://c:/out")

where repo is a spring bean implementing IdempotentRepository

I thought of creating an endpoint first using the uri casting that to
GenericFileEndpoint and then setting the idempotentRepository, but not sure
if this is right.

((GenericFileEndpoint)getCamelContext().getComponent("file").createEndpoint("file://c:/temp")).setIdempotentRepository(repo);



--
View this message in context: 
http://camel.465427.n5.nabble.com/Using-notation-in-java-dsl-tp5731032.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Calling WebService with Camel

[PhilBurress]

At this moment, we are getting this error:

Here's the endpoint definition:

And the route (using a test case to send Jaxb object to direct:start):




--
View this message in context: 
http://camel.465427.n5.nabble.com/Calling-WebService-with-Camel-tp5731026p5731031.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Calling WebService with Camel

[valerian.merkling]

What kind of problem ? And where ?

I'm currently using cxf for ws consumer and producer, so i may be able to
help you, but i can't post my whole project here. 





--
View this message in context: 
http://camel.465427.n5.nabble.com/Calling-WebService-with-Camel-tp5731026p5731027.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel 2.11

[Claus Ibsen]

Hi

We found some issues and the release is being re-cut today. Then we
have a period where ppl can give that RC a test spin before its being
GA.

You can keep an eye on the Camel @dev mailing list about the status.
And we suggest always people in the community to help test it. Its
better we find issues before the GA than after.


On Wed, Apr 17, 2013 at 5:34 PM, Josiah Mangiameli
 wrote:
> Hi
>
> I was wondering when the 2.11 release would be available for download.
> Initially I was told early this week.
>
> Regards,
> Josiah Mangiameli
>
> --
> Josiah Mangiameli
>
> Software Developer
> Urjanet Energy Solutions
>



-- 
Claus Ibsen
-
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cib...@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen

Why doesn't SFTP "move" option work??

[Chris Wolf]

Trying to use Sftp component.   I am using localWorkDirectory because
I don't want the whole files loaded into memory.
Seems like the files *are* being downloaded but they are NOT being
moved, on the remote side to the directory indicated by the "move"
option.


Here, on a poll, it gets a file, while downloading to
"localWorkDirectory", the file's name is appended with ".inprogress",
then it's
renamed to the base file name without ".inprogress" - so far, so good,
except on the server-side, it's not moved to the "move" directory.

[#4 - sftp://localhost/download] SftpOperations DEBUG Retrieve file to
local work file result: true
[#4 - sftp://localhost/download] SftpOperations TRACE Renaming local
in progress file from:
\tmp\local\ftpwork\ADPT5_MKT_20120319_VOIR_DAILY.csv.inprogress to:
\tmp\local\ftpwork\ADPT5_MKT_20120319_VOIR_DAILY.csv
[#4 - sftp://localhost/download] SftpConsumer  TRACE Retrieved file:
download/ADPT5_MKT_20120319_VOIR_DAILY.csv from:
Endpoint[sftp://localhost/download]

...then, at poll n+1, I see:

[#4 - sftp://localhost/download] SftpConsumer TRACE
SftpFile[fileName=ADPT5_MKT_20120319_VOIR_DAILY.csv,
longName=-rwxrwxrwx   1 adpt5adpt5  298313 Apr 17 09:42
ADPT5_MKT_20120319_VOIR_DAILY.csv, dir=false]
[#4 - sftp://localhost/download] SftpConsumer TRACE Skipping as file
is already in progress: ADPT5_MKT_20120319_VOIR_DAILY.csv

I guess that's the idempotent mechanism, but that file should have
been moved out of that directory.


SftpConfiguration:

chmod = null,
ciphers = null,
compression = 0,
connectTimeout = 1,
directory = download,
host = localhost,
knownHostsFile = null,
password = adpt5,
port = 22,
privateKeyFile = null,
privateKeyFilePassphrase = null,
protocol = sftp,
separator = UNIX,
serverAliveCountMax = 1,
serverAliveInterval = 0,
siteCommand = null,
soTimeout = 0,
strictHostKeyChecking = no,
timeout = 3,
username = adpt5,
binary = true,
passiveMode = false,
stepwise = true,
throwExceptionOnConnectFailed = false

[1) thread #0 - timer://kickoff] INFO  SftpEndpoint:
antFilter = null,
bufferSize = 131072,
camelContext = CamelContext(camel-1),
charset = null,
component = org.apache.camel.component.file.remote.SftpComponent@1e34f445,
configuration = download,
consumerProperties = null,
doneFileName = null,
endpointConfiguration =
org.apache.camel.impl.MappedEndpointConfiguration@8292f75a,
endpointKey = sftp://localhost/download,
endpointUri = sftp://localhost/download,
exchangePattern = InOnly,
exchanges = [Exchange[ADPT5_MKT_20090211_MICF.csv],
Exchange[ADPT5_MKT_20090211_MINOCF.csv],
Exchange[ADPT5_MKT_20090305_VOE.csv],
Exchange[ADPT5_MKT_20090305_VOIR.csv],
Exchange[ADPT5_MKT_20120319_DAILY.csv],
Exchange[ADPT5_MKT_20120319_FX.csv],
Exchange[ADPT5_MKT_20120319_MTX_DAILY.csv],
Exchange[ADPT5_MKT_20120319_VOIR_DAILY.csv],
Exchange[ADPT5_MKT_20121121_HISTORY_EUR_IRBank-FZ-D.csv],
Exchange[ADPT5_MKT_20121121_HISTORY_EUR_IRBank-FZ-M.csv],
Exchange[ADPT5_MKT_20121121_HISTORY_EUR_IRBank-FZ-Y.csv]],
exclude = null,
exclusiveReadLockStrategy = null,
fileExist = Override,
fileName = null,
fileSeparator = /,
filter = ms.algo.adapt.camel.cpmd.CPMDFileFilter@54aa2db,
genericFileProcessStrategy =
org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@67b14530,
id = endpoint13,
idempotentRepository = null,
include = null,
inProgressRepository =
org.apache.camel.processor.idempotent.MemoryIdempotentRepository@563b100c,
localWorkDirectory = /tmp/local/ftpwork,
maxDepth = 2147483647,
maximumReconnectAttempts = 3,
maxMessagesPerPoll = 0,
minDepth = 0,
move = ${file:parent}/../archive/${file:onlyname},,
moveExisting = null,
moveFailed = null,
preMove = null,
processStrategy =
org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@67b14530,
readLock = none,
readLockCheckInterval = 5000,
readLockMinLength = 1,
readLockTimeout = 2,
reconnectDelay = 1000,
scheme = sftp,
sortBy = null,
sorter = null,
status = Started,
tempFileName = null,
tempPrefix = null,
version = 2.10.4,
allowNullBody = false,
autoCreate = true,
delete = false,
directoryMustExist = false,
disconnect = false,
eagerDeleteTargetFile = true,
eagerMaxMessagesPerPoll = true,
fastExistsCheck = false,
flatten = false,
keepLastModified = false,
lenientProperties = false,
noop = false,
recursive = false,
runAllowed = true,
singleton = true,
started = true,
starting = false,
startingDirectoryMustExist = false,
stopped = false,
stopping = false,
suspended = false,
suspending = false,
synchronous = false

Camel 2.11

[Josiah Mangiameli]

Hi

I was wondering when the 2.11 release would be available for download. 
Initially I was told early this week.


Regards,
Josiah Mangiameli

--
Josiah Mangiameli

Software Developer
Urjanet Energy Solutions

Calling WebService with Camel

[PhilBurress]

Has anyone had any success calling a webservice via cxf in Camel? We're
running into a lot of problems. Are there any examples out there?



--
View this message in context: 
http://camel.465427.n5.nabble.com/Calling-WebService-with-Camel-tp5731026.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Camel Properties override

[valerian.merkling]

Hi !

Just a quick question about properties.

If I define two property files like this :




classpath:test1.properties
file:${karaf.home}/etc/test2.properties




And test1 and test2 both define the /foo/property, am I sure that I will
always have the value defined in test2 ? 

I made a few test, and it seems that it is ok, but i need to be sure.

Best regards, 

Valerian Merkling



--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-Properties-override-tp5731025.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Insane logs about RouteContextProcessor

[Claus Ibsen]

Hi

Yeah that is a bug in Camel that is fixed in the next releases.


On Wed, Apr 17, 2013 at 4:48 PM, lleclerc  wrote:
> Hello,
>
> I am using camel 2.10.3 and I try to send files at a scheduled time or by
> call.
>
> Everything works, but after a day, I get this INSANE log :
> http://pastie.org/7630667
>
> Here is my routes :
>
>
> The exceptionHandlingProcessor only do logging, and uploadProcessor save
> files on hard drive and start the route
> exchange.getContext().startRoute(ROUTE_UPLOAD);
>
> Here is the code for the uris and shutdown processor code  :
>
>
> Here is the truncated version of the log:
>
>
> Is there better ways to do what I am trying to do ? I don't want any
> monitoring of files,
> only the transfer on scheduled and direct call.
> I got the graceful shutdown code from
> http://camel.apache.org/how-can-i-stop-a-route-from-a-route.html
>
> Thanks,
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Insane-logs-about-RouteContextProcessor-tp5731023.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cib...@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen

Insane logs about RouteContextProcessor

[lleclerc]

Hello,

I am using camel 2.10.3 and I try to send files at a scheduled time or by
call. 

Everything works, but after a day, I get this INSANE log :
http://pastie.org/7630667

Here is my routes :


The exceptionHandlingProcessor only do logging, and uploadProcessor save
files on hard drive and start the route
exchange.getContext().startRoute(ROUTE_UPLOAD);

Here is the code for the uris and shutdown processor code  :


Here is the truncated version of the log: 


Is there better ways to do what I am trying to do ? I don't want any
monitoring of files, 
only the transfer on scheduled and direct call.
I got the graceful shutdown code from
http://camel.apache.org/how-can-i-stop-a-route-from-a-route.html

Thanks,



--
View this message in context: 
http://camel.465427.n5.nabble.com/Insane-logs-about-RouteContextProcessor-tp5731023.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Setting TaskExecutor for JMS component

[dancerjohn]

Ah, got it. Thanks!



--
View this message in context: 
http://camel.465427.n5.nabble.com/Setting-TaskExecutor-for-JMS-component-tp5731017p5731021.html
Sent from the Camel - Users mailing list archive at Nabble.com.

HTTP with Jetty as consumer with Client Cert Authenticator

[Laurentiu Trica]

Hi,

I need to use jetty as HTTP consumer with Client Cert Authenticator.
In other words, the client should be authenticated by a certificate, not
the Basic method.

How could I do this?
Any help is very appreciated!

Thank you in advance,
Laurentiu

Re: Setting TaskExecutor for JMS component

[Claus Ibsen]

Hi

Use taskExecutor=#jmsExecutorService

See more details at
http://camel.apache.org/how-do-i-configure-endpoints.html

On Wed, Apr 17, 2013 at 1:18 PM, dancerjohn  wrote:
> I would like to set up my jms component to use a specific `TaskExecutor`
> (actually would rather use an `ExecutorService` but doesn't seem possible).
> However why I try to do so I get an error.
>
> My spring has the following:
>
>  class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor>
>
>
> My Route Builder has the following:
>
>
> from("jms:queue:myQueue?concurrentConsumers=20&taskExecutor=jmsExecutorService")...
>
> When I run this I get the following error:
>
> IllegalArgumentException: Could not find a suitable setter for property:
> taskExecutor
>  as there isn't a setter method with same type: String not a
> conversion possible:
>  No type converter available to convert from type: String to the
> required type
>  TaskExecutor with value jmsExecutorService
>
> I have had a hard time finding a working example of setting the
> TaskExecutor. I would like to specify a specific TaskExecutor as I would
> like to name the threads in the thread-pool appropriately.
>
> Would someone either help with the above or point me to documentation on how
> to use / set the TaskExecutor?
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Setting-TaskExecutor-for-JMS-component-tp5731017.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cib...@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen

Setting TaskExecutor for JMS component

[dancerjohn]

I would like to set up my jms component to use a specific `TaskExecutor`
(actually would rather use an `ExecutorService` but doesn't seem possible).
However why I try to do so I get an error.

My spring has the following:

http://camel.465427.n5.nabble.com/Setting-TaskExecutor-for-JMS-component-tp5731017.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel routing issue

[Taariq Levack]

Hi

Looks like java needs a hand[1], after .to(SCHEDULE_QNAME,ONLINE__QNAME),
you can try endChoice()

[1]
http://camel.apache.org/why-can-i-not-use-when-or-otherwise-in-a-java-camel-route.html

Taariq


On Wed, Apr 17, 2013 at 11:00 AM, prabumc...@gmail.com  wrote:

> Thanks Claus for your response..
>
> I facing some issue in below code
>
> if condition satisfy i want forward into 2 queues,If not it check second
> condition forward into next queue.
>
> from(SURVEYINVITATION_QNAME).choice()
> *  .when(SCHEDULE_PREDICATE)*
>.multicast().to(SCHEDULE_QNAME,ONLINE__QNAME)
> *   .when(ACCOUNT_EVENT_CARE_HANDLER_PREDICATE)*
>.to(ACCOUNT_EVENT_CARE_HANDLER_QNAME)
>   .otherwise()
>   .to(ERQ_QNAME)
>  .end();
>
>
> I am getting compilation error,Please correct me what mistake i am making
> here
>
> *Regards*
> Prabu.N
>
>
>
>
>
>
> On Wed, Apr 17, 2013 at 2:21 PM, Claus Ibsen-2 [via Camel] <
> ml-node+s465427n573101...@n5.nabble.com> wrote:
>
> > Hi
> >
> > If no destinations is returned, then the message is not routed anywhere.
> >
> > On Tue, Apr 16, 2013 at 3:44 PM, [hidden email]<
> http://user/SendEmail.jtp?type=node&node=5731013&i=0>
> > <[hidden email] >
> > wrote:
> >
> > > *One quick question.*
> > >
> > >
> >
> from("activemq:queue:HHH.InboundQueue").multicast().beanRef("recipientsGenerator")
> >
> > >
> > > @RecipientList()
> > >  public Set routeTo(Exchange ex) {
> > >
> > >  final Set destinations = new HashSet();
> > >
> > >  //based on condition we add messages header/content ,We add queue
> names
> > in
> > > destinations varible.
> > >  //destinations.add("activemq:queue:listqueue")
> > >
> > >   return destinations;
> > >  }
> > >
> > > some cases,messages content not satisfy any condition and it returning
> > > empty destinations set.
> > >
> > > If destinations set is empty where message will go?.
> > >
> > > Because,i can't see messages in HHH.InboundQueue and any queues.
> > >
> > > *Regards*
> > > Prabu.N
> > >
> > >
> > >
> > >
> > > On Mon, Apr 15, 2013 at 10:00 PM, Prabu <[hidden email]<
> http://user/SendEmail.jtp?type=node&node=5731013&i=2>>
> > wrote:
> > >
> > >> So for dynamic queue i have to use only recipientlist correct,we can't
> > use
> > >> .to
> > >>
> > >> One more question,i can't use otherwise in choice please correct if my
> > >> syntax is wrong.
> > >>
> > >>
> > >> from(INBOUND_QUEUE)
> > >> .choice().when(header(TYPE).isNotNull())
> > >>   .recipientList(simple("activemq:queue:Inbound.${header.TYPE}"))
> > >> .otherwise()
> > >>.to(ERQ_QNAME)
> > >> .endChoice();
> > >>
> > >> After execute i am getting following error.
> > >>
> > >> Error:
> > >>
> > >> Router.java:22: cannot find symbol
> > >> symbol  : method otherwise()
> > >> location: class
> > >> org.apache.camel.model.RecipientListDefinition > >> model.ChoiceDefinition>
> > >>.otherwise()
> > >>^
> > >>
> > >>
> > >>
> > >> On Mon, Apr 15, 2013 at 8:55 PM, Claus Ibsen-2 [via Camel] <
> > >> [hidden email]  >>
> > wrote:
> > >>
> > >>> Hi
> > >>>
> > >>> Yes recipient list uses an expression for evaluating where to send
> the
> > >>> message to.
> > >>> See its doc
> > >>> http://camel.apache.org/recipient-list.html
> > >>>
> > >>> And this FAQ
> > >>> http://camel.apache.org/how-do-i-use-dynamic-uri-in-to.html
> > >>>
> > >>> And there is no performance overhead. eg when you send the message to
> > >>> a previous destination, then that endpoints/producer is reused.
> > >>>
> > >>>
> > >>> On Mon, Apr 15, 2013 at 2:05 PM, [hidden email]<
> > http://user/SendEmail.jtp?type=node&node=5730920&i=0>
> > >>> <[hidden email] <
> http://user/SendEmail.jtp?type=node&node=5730920&i=1>>
> >
> > >>> wrote:
> > >>>
> > >>> > Question:1
> > >>> >
> > >>> > I am having code like blow.based on condition i want forward into
> > >>> dynamic
> > >>> > queue.
> > >>> >
> > >>> >  .when(header(TYPE).isNotNull())
> > >>> >   .recipientList(simple("activemq:queue:Inbound.${header.TYPE}"))
> > >>> >
> > >>> > i want to use .to(simple ) insight of .recipientList(simple)
> > >>> >
> > >>> > Please suggest is it possible?.why it is not possible is there any
> > >>> > performance issue if i use .recipientList(simple)
> > >>> >
> > >>> > Questuon:2
> > >>> >
> > >>> > Error in code
> > >>> >
> > >>> > from(INBOUND_QUEUE)
> > >>> > .choice().when(header(TYPE).isNotNull())
> > >>> >   .recipientList(simple("activemq:queue:Inbound.${header.TYPE}"))
> > >>> > .otherwise()
> > >>> >.to(ERQ_QNAME)
> > >>> > .endChoice();
> > >>> >
> > >>> > After execute i am getting following error.
> > >>> >
> > >>> > Error:
> > >>> >
> > >>> > Router.java:22: cannot find symbol
> > >>> > symbol  : method otherwise()
> > >>> > location: class
> > >>> > org.apache.camel.model.RecipientListDefinition > >>> > model.ChoiceDefinition>
> > >>> >

Re: Block a Queue until all exchanges are received

[Okello Nelson]

Hi Claus,

I also came across Route Policy, http://camel.apache.org/routepolicy.html.

>From its description, I think I can use it to selectively run routes. In my
specific use case, I'd like to be able to suspend a route until it receives
all the exchanges, then run it while suspending the next route, etc etc.

Kind Regards,
Okello Nelson.


On Wed, Apr 17, 2013 at 12:31 PM, Okello Nelson  wrote:

> Thanks a lot, Claus.
>
> Kind Regards,
> Okello Nelson.
>
>
> On Wed, Apr 17, 2013 at 11:07 AM, Claus Ibsen wrote:
>
>> Hi
>>
>> You can control the other route for example as, eg to start|stop it etc
>> http://camel.apache.org/how-can-i-stop-a-route-from-a-route.html
>>
>> Or in Camel 2.11 use the control bus component
>> http://camel.apache.org/controlbus.html
>>
>>
>>
>> On Tue, Apr 16, 2013 at 10:49 AM, Okello Nelson 
>> wrote:
>> > Hi Guys,
>> >
>> > Having a route DSL as:
>> >
>> > from("file:" + classesBaseDir + "/" + fileType +
>> > "/step0?preMove=inprogress&moveFailed=.error&move=.done&readLock=true")
>> > .routeId(dirRepoPrefix + fileType + "-To-" + queuePrefix + fileType +
>> > "_ParsingQ")
>> > .threads(50)
>> > .split().tokenize("\n", 5).streaming().parallelProcessing()
>> > .doTry().to(queuePrefix + fileType + "_ParsingQ?asyncConsumer=true")
>> > .doCatch(Exception.class).to(queuePrefix + fileType +
>> "_InvalidParsingQ");
>> >
>> > There's another route that consumes the exchanges of the "...ParsingQ".
>> > However, I want exchanges at "...ParsingQ" to be consumed only when all
>> the
>> > files have been loaded into the queue. Is there a way I can implement
>> this?
>> >
>> > Thanks a lot in advance.
>> >
>> > Kind Regards,
>> > Okello Nelson.
>>
>>
>>
>> --
>> Claus Ibsen
>> -
>> Red Hat, Inc.
>> FuseSource is now part of Red Hat
>> Email: cib...@redhat.com
>> Web: http://fusesource.com
>> Twitter: davsclaus
>> Blog: http://davsclaus.com
>> Author of Camel in Action: http://www.manning.com/ibsen
>>
>
>
>
> --
> Kind Regards,
> Okello Nelson
> +254 722 137 826
> cn.oke...@gmail.com
>



-- 
Kind Regards,
Okello Nelson
+254 722 137 826
cn.oke...@gmail.com

Re: Block a Queue until all exchanges are received

[Okello Nelson]

Thanks a lot, Claus.

Kind Regards,
Okello Nelson.


On Wed, Apr 17, 2013 at 11:07 AM, Claus Ibsen  wrote:

> Hi
>
> You can control the other route for example as, eg to start|stop it etc
> http://camel.apache.org/how-can-i-stop-a-route-from-a-route.html
>
> Or in Camel 2.11 use the control bus component
> http://camel.apache.org/controlbus.html
>
>
>
> On Tue, Apr 16, 2013 at 10:49 AM, Okello Nelson 
> wrote:
> > Hi Guys,
> >
> > Having a route DSL as:
> >
> > from("file:" + classesBaseDir + "/" + fileType +
> > "/step0?preMove=inprogress&moveFailed=.error&move=.done&readLock=true")
> > .routeId(dirRepoPrefix + fileType + "-To-" + queuePrefix + fileType +
> > "_ParsingQ")
> > .threads(50)
> > .split().tokenize("\n", 5).streaming().parallelProcessing()
> > .doTry().to(queuePrefix + fileType + "_ParsingQ?asyncConsumer=true")
> > .doCatch(Exception.class).to(queuePrefix + fileType +
> "_InvalidParsingQ");
> >
> > There's another route that consumes the exchanges of the "...ParsingQ".
> > However, I want exchanges at "...ParsingQ" to be consumed only when all
> the
> > files have been loaded into the queue. Is there a way I can implement
> this?
> >
> > Thanks a lot in advance.
> >
> > Kind Regards,
> > Okello Nelson.
>
>
>
> --
> Claus Ibsen
> -
> Red Hat, Inc.
> FuseSource is now part of Red Hat
> Email: cib...@redhat.com
> Web: http://fusesource.com
> Twitter: davsclaus
> Blog: http://davsclaus.com
> Author of Camel in Action: http://www.manning.com/ibsen
>



-- 
Kind Regards,
Okello Nelson
+254 722 137 826
cn.oke...@gmail.com

Re: Camel routing issue

[prabumc...@gmail.com]

Thanks Claus for your response..

I facing some issue in below code

if condition satisfy i want forward into 2 queues,If not it check second
condition forward into next queue.

from(SURVEYINVITATION_QNAME).choice()
*  .when(SCHEDULE_PREDICATE)*
   .multicast().to(SCHEDULE_QNAME,ONLINE__QNAME)
*   .when(ACCOUNT_EVENT_CARE_HANDLER_PREDICATE)*
   .to(ACCOUNT_EVENT_CARE_HANDLER_QNAME)
  .otherwise()
  .to(ERQ_QNAME)
 .end();


I am getting compilation error,Please correct me what mistake i am making
here

*Regards*
Prabu.N






On Wed, Apr 17, 2013 at 2:21 PM, Claus Ibsen-2 [via Camel] <
ml-node+s465427n573101...@n5.nabble.com> wrote:

> Hi
>
> If no destinations is returned, then the message is not routed anywhere.
>
> On Tue, Apr 16, 2013 at 3:44 PM, [hidden 
> email]
> <[hidden email] >
> wrote:
>
> > *One quick question.*
> >
> >
> from("activemq:queue:HHH.InboundQueue").multicast().beanRef("recipientsGenerator")
>
> >
> > @RecipientList()
> >  public Set routeTo(Exchange ex) {
> >
> >  final Set destinations = new HashSet();
> >
> >  //based on condition we add messages header/content ,We add queue names
> in
> > destinations varible.
> >  //destinations.add("activemq:queue:listqueue")
> >
> >   return destinations;
> >  }
> >
> > some cases,messages content not satisfy any condition and it returning
> > empty destinations set.
> >
> > If destinations set is empty where message will go?.
> >
> > Because,i can't see messages in HHH.InboundQueue and any queues.
> >
> > *Regards*
> > Prabu.N
> >
> >
> >
> >
> > On Mon, Apr 15, 2013 at 10:00 PM, Prabu <[hidden 
> > email]>
> wrote:
> >
> >> So for dynamic queue i have to use only recipientlist correct,we can't
> use
> >> .to
> >>
> >> One more question,i can't use otherwise in choice please correct if my
> >> syntax is wrong.
> >>
> >>
> >> from(INBOUND_QUEUE)
> >> .choice().when(header(TYPE).isNotNull())
> >>   .recipientList(simple("activemq:queue:Inbound.${header.TYPE}"))
> >> .otherwise()
> >>.to(ERQ_QNAME)
> >> .endChoice();
> >>
> >> After execute i am getting following error.
> >>
> >> Error:
> >>
> >> Router.java:22: cannot find symbol
> >> symbol  : method otherwise()
> >> location: class
> >> org.apache.camel.model.RecipientListDefinition >> model.ChoiceDefinition>
> >>.otherwise()
> >>^
> >>
> >>
> >>
> >> On Mon, Apr 15, 2013 at 8:55 PM, Claus Ibsen-2 [via Camel] <
> >> [hidden email] >
> wrote:
> >>
> >>> Hi
> >>>
> >>> Yes recipient list uses an expression for evaluating where to send the
> >>> message to.
> >>> See its doc
> >>> http://camel.apache.org/recipient-list.html
> >>>
> >>> And this FAQ
> >>> http://camel.apache.org/how-do-i-use-dynamic-uri-in-to.html
> >>>
> >>> And there is no performance overhead. eg when you send the message to
> >>> a previous destination, then that endpoints/producer is reused.
> >>>
> >>>
> >>> On Mon, Apr 15, 2013 at 2:05 PM, [hidden email]<
> http://user/SendEmail.jtp?type=node&node=5730920&i=0>
> >>> <[hidden email] >
>
> >>> wrote:
> >>>
> >>> > Question:1
> >>> >
> >>> > I am having code like blow.based on condition i want forward into
> >>> dynamic
> >>> > queue.
> >>> >
> >>> >  .when(header(TYPE).isNotNull())
> >>> >   .recipientList(simple("activemq:queue:Inbound.${header.TYPE}"))
> >>> >
> >>> > i want to use .to(simple ) insight of .recipientList(simple)
> >>> >
> >>> > Please suggest is it possible?.why it is not possible is there any
> >>> > performance issue if i use .recipientList(simple)
> >>> >
> >>> > Questuon:2
> >>> >
> >>> > Error in code
> >>> >
> >>> > from(INBOUND_QUEUE)
> >>> > .choice().when(header(TYPE).isNotNull())
> >>> >   .recipientList(simple("activemq:queue:Inbound.${header.TYPE}"))
> >>> > .otherwise()
> >>> >.to(ERQ_QNAME)
> >>> > .endChoice();
> >>> >
> >>> > After execute i am getting following error.
> >>> >
> >>> > Error:
> >>> >
> >>> > Router.java:22: cannot find symbol
> >>> > symbol  : method otherwise()
> >>> > location: class
> >>> > org.apache.camel.model.RecipientListDefinition >>> > model.ChoiceDefinition>
> >>> >.otherwise()
> >>> >^
> >>> >
> >>> > Question:3
> >>> >
> >>> > I having more than 85 queues.Based on condition i want to forward to
> >>> correct
> >>> > queue.
> >>> >
> >>> > In my route builder i having code below for all 85 queus.
> >>> >
> >>> >   from(ALERT_QNAME).choice()
> >>> >   .when(ALERT_PREDICATE).to(ALERT_QNAME)
> >>> >   .otherwise()
> >>> >   .to(ERQ_QNAME)
> >>> >  .end();
> >>> >
> >>> > I feel like because of my code performance getting degrade.Please
> >>> suggest if
> >>> > i am wrong?
> >>> >
> >>> > When i open jc

Re: Camel routing issue

[Claus Ibsen]

Hi

If no destinations is returned, then the message is not routed anywhere.

On Tue, Apr 16, 2013 at 3:44 PM, prabumc...@gmail.com
 wrote:
> *One quick question.*
>
> from("activemq:queue:HHH.InboundQueue").multicast().beanRef("recipientsGenerator")
>
> @RecipientList()
>  public Set routeTo(Exchange ex) {
>
>  final Set destinations = new HashSet();
>
>  //based on condition we add messages header/content ,We add queue names in
> destinations varible.
>  //destinations.add("activemq:queue:listqueue")
>
>   return destinations;
>  }
>
> some cases,messages content not satisfy any condition and it returning
> empty destinations set.
>
> If destinations set is empty where message will go?.
>
> Because,i can't see messages in HHH.InboundQueue and any queues.
>
> *Regards*
> Prabu.N
>
>
>
>
> On Mon, Apr 15, 2013 at 10:00 PM, Prabu  wrote:
>
>> So for dynamic queue i have to use only recipientlist correct,we can't use
>> .to
>>
>> One more question,i can't use otherwise in choice please correct if my
>> syntax is wrong.
>>
>>
>> from(INBOUND_QUEUE)
>> .choice().when(header(TYPE).isNotNull())
>>   .recipientList(simple("activemq:queue:Inbound.${header.TYPE}"))
>> .otherwise()
>>.to(ERQ_QNAME)
>> .endChoice();
>>
>> After execute i am getting following error.
>>
>> Error:
>>
>> Router.java:22: cannot find symbol
>> symbol  : method otherwise()
>> location: class
>> org.apache.camel.model.RecipientListDefinition> model.ChoiceDefinition>
>>.otherwise()
>>^
>>
>>
>>
>> On Mon, Apr 15, 2013 at 8:55 PM, Claus Ibsen-2 [via Camel] <
>> ml-node+s465427n5730920...@n5.nabble.com> wrote:
>>
>>> Hi
>>>
>>> Yes recipient list uses an expression for evaluating where to send the
>>> message to.
>>> See its doc
>>> http://camel.apache.org/recipient-list.html
>>>
>>> And this FAQ
>>> http://camel.apache.org/how-do-i-use-dynamic-uri-in-to.html
>>>
>>> And there is no performance overhead. eg when you send the message to
>>> a previous destination, then that endpoints/producer is reused.
>>>
>>>
>>> On Mon, Apr 15, 2013 at 2:05 PM, [hidden 
>>> email]
>>> <[hidden email] >
>>> wrote:
>>>
>>> > Question:1
>>> >
>>> > I am having code like blow.based on condition i want forward into
>>> dynamic
>>> > queue.
>>> >
>>> >  .when(header(TYPE).isNotNull())
>>> >   .recipientList(simple("activemq:queue:Inbound.${header.TYPE}"))
>>> >
>>> > i want to use .to(simple ) insight of .recipientList(simple)
>>> >
>>> > Please suggest is it possible?.why it is not possible is there any
>>> > performance issue if i use .recipientList(simple)
>>> >
>>> > Questuon:2
>>> >
>>> > Error in code
>>> >
>>> > from(INBOUND_QUEUE)
>>> > .choice().when(header(TYPE).isNotNull())
>>> >   .recipientList(simple("activemq:queue:Inbound.${header.TYPE}"))
>>> > .otherwise()
>>> >.to(ERQ_QNAME)
>>> > .endChoice();
>>> >
>>> > After execute i am getting following error.
>>> >
>>> > Error:
>>> >
>>> > Router.java:22: cannot find symbol
>>> > symbol  : method otherwise()
>>> > location: class
>>> > org.apache.camel.model.RecipientListDefinition>> > model.ChoiceDefinition>
>>> >.otherwise()
>>> >^
>>> >
>>> > Question:3
>>> >
>>> > I having more than 85 queues.Based on condition i want to forward to
>>> correct
>>> > queue.
>>> >
>>> > In my route builder i having code below for all 85 queus.
>>> >
>>> >   from(ALERT_QNAME).choice()
>>> >   .when(ALERT_PREDICATE).to(ALERT_QNAME)
>>> >   .otherwise()
>>> >   .to(ERQ_QNAME)
>>> >  .end();
>>> >
>>> > I feel like because of my code performance getting degrade.Please
>>> suggest if
>>> > i am wrong?
>>> >
>>> > When i open jconsole i am getting white screen and queues some time not
>>> > showing any attribute?
>>> >
>>> > Please kindly help me.
>>> >
>>> >
>>> >
>>> > --
>>> > View this message in context:
>>> http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5730898.html
>>>
>>> > Sent from the Camel - Users mailing list archive at Nabble.com.
>>>
>>>
>>>
>>> --
>>> Claus Ibsen
>>> -
>>> Red Hat, Inc.
>>> FuseSource is now part of Red Hat
>>> Email: [hidden email]
>>> Web: http://fusesource.com
>>> Twitter: davsclaus
>>> Blog: http://davsclaus.com
>>> Author of Camel in Action: http://www.manning.com/ibsen
>>>
>>>
>>> --
>>>  If you reply to this email, your message will be added to the
>>> discussion below:
>>>
>>> http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5730920.html
>>>  To unsubscribe from Camel routing issue, click 
>>> here
>>> .
>>> NAML

Re: how to get the ftp reply when uploading a file

[Asbjørn Aarrestad]

I've added a Jira issue: CAMEL-6293

- asbjørn



--
View this message in context: 
http://camel.465427.n5.nabble.com/how-to-get-the-ftp-reply-when-uploading-a-file-tp5730960p5731012.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: how to get the ftp reply when uploading a file

[Claus Ibsen]

Hi

No the pull request is fine.

And no 2.11.0 is currently being built right now. So it will be in
2.11.1 and 2.10.5.
You can of course just patch your code yourselves and use a custom JAR
until a GA release is out.

On Wed, Apr 17, 2013 at 10:06 AM, Asbjørn Aarrestad  wrote:
> I'll do that.
>
> Any chance of merging it into the 2.11 release? Do you want a separate
> pull-request for that?
>
> - asbjørn
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/how-to-get-the-ftp-reply-when-uploading-a-file-tp5730960p5731008.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cib...@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen

Re: Block a Queue until all exchanges are received

[Claus Ibsen]

Hi

You can control the other route for example as, eg to start|stop it etc
http://camel.apache.org/how-can-i-stop-a-route-from-a-route.html

Or in Camel 2.11 use the control bus component
http://camel.apache.org/controlbus.html



On Tue, Apr 16, 2013 at 10:49 AM, Okello Nelson  wrote:
> Hi Guys,
>
> Having a route DSL as:
>
> from("file:" + classesBaseDir + "/" + fileType +
> "/step0?preMove=inprogress&moveFailed=.error&move=.done&readLock=true")
> .routeId(dirRepoPrefix + fileType + "-To-" + queuePrefix + fileType +
> "_ParsingQ")
> .threads(50)
> .split().tokenize("\n", 5).streaming().parallelProcessing()
> .doTry().to(queuePrefix + fileType + "_ParsingQ?asyncConsumer=true")
> .doCatch(Exception.class).to(queuePrefix + fileType + "_InvalidParsingQ");
>
> There's another route that consumes the exchanges of the "...ParsingQ".
> However, I want exchanges at "...ParsingQ" to be consumed only when all the
> files have been loaded into the queue. Is there a way I can implement this?
>
> Thanks a lot in advance.
>
> Kind Regards,
> Okello Nelson.



-- 
Claus Ibsen
-
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cib...@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen

Re: how to get the ftp reply when uploading a file

[Asbjørn Aarrestad]

I'll do that. 

Any chance of merging it into the 2.11 release? Do you want a separate
pull-request for that?

- asbjørn



--
View this message in context: 
http://camel.465427.n5.nabble.com/how-to-get-the-ftp-reply-when-uploading-a-file-tp5730960p5731008.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: InterceptSendToEndpoint - Http Component

[Claus Ibsen]

Hi

Possible use wildcards in the interceptSendToEndpoint to match the
http url. As if you have parameters then that's tricky.
See details about wildcards at: http://camel.apache.org/intercept

On Tue, Apr 16, 2013 at 3:24 PM, dss.light  wrote:
> Hi, tried to use this feature for testing - excellently like advised - it
> still did not skip intercepted endpoint.
>
> Camel 2.10.4
>
> What I am doing wrong? The first endpoint changed and worked;
> In the log I see trying to post message to localhost.
> And test fell down with exception.
> I simply want to replace last endpoint to the other one.
>
> code
>
> context.getRouteDefinitions().get(0).adviceWith(context, new
> AdviceWithRouteBuilder() {
> @Override
> public void configure() throws Exception {
> replaceFromWith("direct:start");
> interceptSendToEndpoint(ReceiverBridge.TO_ENDPOINT)
> .skipSendToOriginalEndpoint()
> .to("mock:result");
> }
> });
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/InterceptSendToEndpoint-Http-Component-tp3296620p5730970.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cib...@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen

Re: Splitting XML into multiple separate bits and send out to webservices

[Claus Ibsen]

Hi

Then use the content based router to do different routing depending on
what you need.
And only split if needed etc.

Or just use a bean / processor to do the logic etc.



On Tue, Apr 16, 2013 at 11:03 PM, RTernier  wrote:
> I don't think the splitter can do what I want.
>
> I want to take a single message, transform that message into X messages
> (sometimes it might split, other times I'll have to take the original
> incoming message, transform it based on an element based inside the
> message).
>
> Looking at other forums, someone mentioned the  Load Broker Example
> 
>
>
> I thought about running multicast/parallelProcessing/to(1, 2, 3, 4 etc.)
> which would send the same message, and I could intercept those...
> (interceptSendToEndpoint)
>
> would that be a better way of doing this?
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Splitting-XML-into-multiple-separate-bits-and-send-out-to-webservices-tp5730936p5730985.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cib...@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen

Re: how to get the ftp reply when uploading a file

[Claus Ibsen]

Hi

Thanks.

Do you mind logging a JIRA ticket as well? We want to have that as
well so we have all the changes cataloged in JIRA.

On Wed, Apr 17, 2013 at 8:22 AM, Asbjørn Aarrestad  wrote:
> I've added a pull request to solve this problem
> https://github.com/apache/camel/pull/19
>
> - asbjørn
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/how-to-get-the-ftp-reply-when-uploading-a-file-tp5730960p5730996.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cib...@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen

Re: Bindy fixed length

[Claus Ibsen]

Hi

I think you should add more detail what you are asking about.
I dont think we understand what you want

On Tue, Apr 16, 2013 at 5:04 PM, fbarbat  wrote:
> Hi,
>
> Is there anything similar to Hibernate's components in bindy? It would be
> nice if we can nest objects to model one line.
>
> Thanks.
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Bindy-fixed-length-tp5730980.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cib...@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen