i stop the consumer route, but why can't execute the doStop() method?
i use camelContext.stopRoute(routeId);
the consumer route bind the port 6, but when i stopRoute, it's listened
on 6 yet.
why can't execute the component's doStop() method on Consumer? because i
start the route it
i make a pressure test. the client send 50 threads with 5minutes using
soapUI, and my application use camel recevie webservices request,
application running on linux, use Xmx512m on jvm. but the top display RES
column has 1400m memory, why? i wan't to know how the cxf manager the
threads. and how
i use camel-cxf in apache ofbiz, so my services should be using the tomcat?
--
View this message in context:
http://camel.465427.n5.nabble.com/how-to-improve-concurrent-performance-use-cxf-in-Camel-tp5131454p5665140.html
Sent from the Camel - Users mailing list archive at Nabble.com.
14:03:26.944 [main] DEBUG o.a.c.i.DefaultExecutorServiceStrategy -
ShutdownNow ExecutorService:
java.util.concurrent.Executors$FinalizableDelegatedExecutorService@140984b
14:03:26.944 [main] INFO o.a.c.impl.DefaultInflightRepository - Shutting
down with no inflight exchanges.
14:03:26.944 [main]
if my uri is :
from(netty:tcp://localhost:6789?encoders=#myEncodersdecoders=myDecoderssync=true)
.process(new MyFromProcessor());
the myDecoders has two decoder, and return two values.
but how to get the two values in MyFromProcessor?
--
View this message in context:
my URI is
.to(netty:tcp://localhost:6789?encoders=#myEncodersdecoders=myDecoderssync=true)
test main program like:
Object decoder = new LengthDecoder(); //appctx.getBean(mydecoder);
Object encoder = new MessageEncoder(10);
//appctx.getBean(myencoder);
the class LengthDecoder and MessageEncoder code:
public class LengthDecoder extends FrameDecoder {
private static final transient Logger LOG =
LoggerFactory.getLogger(LengthDecoder.class);
@Override
protected Object decode(
ChannelHandlerContext ctx, Channel channel,
if i use encoders and decoders property, the program is ok.
Object decoder = new LengthDecoder(); //appctx.getBean(mydecoder);
Object encoder = new MessageEncoder(10);
//appctx.getBean(myencoder);
SimpleRegistry registry = new SimpleRegistry();
Object decoder = appctx.getBean(mydecoder);
Object encoder = appctx.getBean(myencoder);
SimpleRegistry registry = new SimpleRegistry();
ListChannelDownstreamHandler encoders = new
ArrayListChannelDownstreamHandler();
i use netty example client/server for test, recved content is correct.
but why add 8 bytes at header in Camel-netty?
--
View this message in context:
http://camel.465427.n5.nabble.com/in-netty-why-sended-6bytes-but-server-recved-9bytes-tp5131271p5141678.html
Sent from the Camel - Users mailing
bean id=myencoder
class=org.jboss.netty.handler.codec.string.StringEncoder/
my code like:
ApplicationContext appctx =
new
ClassPathXmlApplicationContext(/org/apache/camel/component/netty/test-codecs.xml);
Object decoder = appctx.getBean(mydecoder);
Object encoder =
my Encoder:
protected Object encode(
ChannelHandlerContext ctx, Channel channel, Object msg) throws
Exception {
if (!(msg instanceof String)) {
return msg;//(1)
}
System.out.println(IN INCODE: + msg);
buf.writeBytes(data); //6bytes
test-codes.xml like :
beans
bean id=myencoder
class=org.jboss.netty.handler.codec.string.StringEncoder/
/beans
--
View this message in context:
http://camel.465427.n5.nabble.com/set-encoder-in-netty-exception-tp5130760p5131323.html
Sent from the Camel - Users mailing list archive at
Camel version is 2.7.2
and run as a java application (main method) using in eclipse.
--
View this message in context:
http://camel.465427.n5.nabble.com/set-encoder-in-netty-exception-tp5130760p5131372.html
Sent from the Camel - Users mailing list archive at Nabble.com.
sorry, my server recved 14bytes.
client in Camel send 230111 string.
but server recved 000A05740006323338303131 by hex string
why had 8bytes with 000A05740006 ?
--
View this message in context:
yes, i'm sure 6bytes only. add 8bytes to the header of netty by default. why?
--
View this message in context:
http://camel.465427.n5.nabble.com/in-netty-why-sended-6bytes-but-server-recved-9bytes-tp5131271p5132953.html
Sent from the Camel - Users mailing list archive at Nabble.com.
if i use registry.put(myDecoder, new MyDecoder);
And then I also need to use the beans configure file?
--
View this message in context:
http://camel.465427.n5.nabble.com/Netty-for-TCP-communication-tp3409969p5107705.html
Sent from the Camel - Users mailing list archive at Nabble.com.
i had implements my Decoder named MessageDecoder. and use by
from(host:port?decoder=com.test.MessageDecoder), but where i need to put
the class?
second, why need use decoders and encoders? if i need implements some
decoder, why not to implements
a big decoder?
public class MessageDecoder extends
i'm a newbie in java, i'm use j2se usually。so i don't know how to use
camel-test.., and we don't need more configure file of camel in my
application, so i need to use the api and parse my configure file.
--
View this message in context:
system A send request to system B, communicate to system B use IBM MQ. and
received response from system B and return to A.
request to B use Queue1 and receive response from Queue2, response may be
one, or twice, or more times.
so how to sync recevied the all response in use camel-jms?
--
i know it. and i want to know how to receive once or twice.
--
View this message in context:
http://camel.465427.n5.nabble.com/how-to-use-jms-to-sync-twice-response-tp5077335p5079016.html
Sent from the Camel - Users mailing list archive at Nabble.com.
MQQueueConnectionFactory cf = new MQQueueConnectionFactory();
JmsConfiguration jc = new JmsConfiguration(cf);
cf.setHostName(172.16.16.136);
cf.setPort(1416);
cf.setQueueManager(QM2);
cf.setChannel(BTOA);
is to(ibmmq:QRB) means to connect the qmgr? is it connect the remote server
everytime?
not a long connection? so it's inefficient?
i want to connect the qmgr once. then send messages to the queue not need to
connect.
--
View this message in context:
i can't use JNDI and can't use some configure file. so i wan't know how to
use
from(uri) to receive or send message to remote ibm mq queue. how to sepecial
the address and port.
--
View this message in context:
i only want to use camel api to setup the jms to access ibm mq.
and i want to extend camel-jms to support my application message protocol.
like big message how to
split some small message.
--
View this message in context:
i wan't to use camel-jms component，but my application must implements some
strategies to hander the big message, like how to merge some small message
to a whole message.
so i want to extend the camel-jms, if i create a new camel-myjms component
and the MyProducer extend JmsProducer, MyConsumer
how to implement the synchronized communicate by camel-jms ? i need to extend
JmsProducer and override the process method?
--
View this message in context:
http://camel.465427.n5.nabble.com/how-to-extend-the-component-tp5073447p5073527.html
Sent from the Camel - Users mailing list archive at
i means why the remote mq server address or port is not part of the camel-jms
uri or some properties.
like jms://localhost:1414:queueName=Q1qmgrName=QM1...
--
View this message in context:
and when i received the message's ApplIdentityData is HEAD, i need to
receive others message.
so how to send/receive message more than one in camel-jms producer/consumer.
--
View this message in context:
how the camel find the wsdl file in classpath? use classLoader.getResource??
--
View this message in context:
http://camel.465427.n5.nabble.com/cxf-uri-can-t-use-wsdlURL-classpath-file-wsdl-tp4703461p5067081.html
Sent from the Camel - Users mailing list archive at Nabble.com.
my camel version is 2.7.2, and the route use compoment sunlink created
myself.
i configure some endpoints in xml file like:
endpoint id=WXFPH uri=sunlink://0.0.0.0:5090/
endpoint id=SZFPH uri=sunlink://0.0.0.0:5091/
sunlink component is like a socket server, so my program like:
RouteDefinition
RouteBuilder can't set a ID to mark the difference routes, how to distinguish
the received message from the different servers listening at two ports, and
i don't know what the difference RouteDefintion with RouteBuilder.
--
View this message in context:
i use RouteBuilder and can't get the correct routeId.
my SunLinkConsumer implement refers to the Mina component, and my
ReceiveHandler like
Exchange exchange = getEndpoint().createConsumerExchange(context, request);
public Exchange createConsumerExchange(SunLinkContext context, SLData data)
{
i had create two RouteDefinitions, like
RouteDefinition route = new RouteDefinition();
route.from().process();
route.setId(routeIdA); //another route id is routeIdB
these RouteDefinitions listening at 5090 and 5091 port.
my client send message to the 5091 port, and i use
[java] Caused by: org.apache.camel.ResolveEndpointFailedException:
Failed to resolve endpoint: sunlink:/
0.0.0.0:5090?backLog=100fileDir=runtime%2FfileslocalNode=999logDir=runtime%2FlogspoolQueueDepth=10poolSi
e=20remoteNode=000version=2 due to: Invalid byte 1 of 1-byte UTF-8
sequence.
i use log4j.xml in my project classpath, content like:
log4j:configuration
appender name=camel class=org.apache.log4j.RollingFileAppender
layout class=org.apache.log4j.PatternLayout
Producer producer = endpoint.createProducer();
producer.process(exchange); //throw an Exception
return (Maplt;String, Objectgt;)exchange.getOut().getBody(); //why run to
here?
my route defined
from(direct://test).process(ProcesssA).to(myComponent://).process(ProcessB);
if my ProcessA
my platform need to communicate with other corporation, other corporations
system use TUXEDO, so i want to communicate to TUXEDO use camel. not manage
other resources use TUXEDO .
--
View this message in context:
i have see the camel source with camel-web-standalone components, but can't
find the document about it on apache. how to monitor and control the route
or endpoint?
--
View this message in context:
http://camel.465427.n5.nabble.com/how-to-run-and-use-the-web-module-tp4737628p4737628.html
Sent
Producer producer = endpoint.createProducer();
producer.process(exchange);
return exchange.getOut().getBody();
i have put the message to direct compoment, and want to get the response in
sync mode. the remote is web services server. but how to ensure to return
the
i use RouteDefinition to add processor and the processor implements camel's
Processor.
but why AsyncProcessorTypeConverter appeared when i debug my application.
i need the processor handle in sync mode. why is async processor?
--
View this message in context:
i need get the request body content in the response message.
my application like
from(direct://test).process(new ProcessA()).to(cxf://remote).process(new
ProcessB())
ProcessA set exchange.getOut().setBody() at last, example
exchange.getOut().setBody(mapObj)
but in ProcessB need get the
i use soap-ui to send request the same service server, very fast and less
than 1 seconds.
but use cxf-module to send need 6 seconds. my program use wsdl and payload
format, and no serviceClass.
--
View this message in context:
the service must be provide by CXF when user CxfPayLoad ??
i had search operationNamespace in the cxf-module, nothing about it.
i means i should send message like:
helloServiceRequest
namefldsjaflkjdsa/name
/helloServiceRequest
not like:
iws:helloServiceRequest
thanks, i had make mistake with the namespace, so i debug it in cxf endpoint
with the exception.
and my code like:
DocumentBuilderFactory factory =
DocumentBuilderFactory.newInstance();
factory.setNamespaceAware(true);
Document doc =
i need to invoke service operationName decide by program logic.
so i want to config the URI point the service address and not appoint the
special operationName.
but how to know the namespace and the webservice wsdl:message by camel? if i
appoint the operationName,
why camel can't know the
I set the keys at runtime, but can't find the service in the server.
Exchange exchange = endpoint.createExchange();
exchange.getIn().setHeader(operationName, helloService);
exchange.getIn().setHeader(operationNamespace,
http://www.wstest.sunyard.com/IWSTestService/;);
your means i can set message body like
helloServiceRequest
namefldsjaflkjdsa/name
/helloServiceRequest
and invoke helloService in remote?
--
View this message in context:
CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
public void configure() throws Exception {
from(direct:test)
.process(new MyProcessor())
i had send the request message to web services, and the services can execute
successful.
but the camel message's out body is HttpInputStream, and i read from the
stream by
byte[] b = new byte[4096];
int len = ((InputStream)exchange.getOut().getBody()).read(b);
output string is
what's the mean that uri set by wsdlURL=classpath:IWSService.wsdl ?
it's can find IWSService.wsdl file in the whole classpath?
--
View this message in context:
http://camel.465427.n5.nabble.com/cxf-uri-can-t-use-wsdlURL-classpath-file-wsdl-tp4703461p4718123.html
Sent from the Camel - Users
how to send webservice request use wsdl and operation name?
--
View this message in context:
http://camel.465427.n5.nabble.com/how-to-invoke-webservice-with-wsdl-or-not-in-camel-tp4700436p4719616.html
Sent from the Camel - Users mailing list archive at Nabble.com.
my cxf from endpoint uri like
cxf://http://localhost:8000/SCCS?dataFormat=PAYLOADwsdlURL=classpath:IWSService.wsdl;,
but start camel error as:
The service name of the URI is empty, cxf will try to load the first one
in wsdl for you.
i put the IWSService.wsdl in the classpath.
--
View this
i need to use wsdl and not send envelop message only, but i need to set the
operationName dynamic by program.
i want to send service request to the special service adress and invoke the
operationName in the special wsdl file . how to use uri and set the
message body?
--
View this message in
the uri
cxf://http://localhost:8000/SCCS?dataFormat=PAYLOADwsdlURL=classpath:IWSService.wsdl;
is set to from in camel. but it's ok while use
cxf://http://localhost:8000/SCCS?dataFormat=PAYLOADwsdlURL=d:/IWSService.wsdl;,
i want to put the wsdl file to classpath so i don't need to write d: fixed.
i need to send message to webservice server, like
from(direct://test).process().to(cxf://...)
i have get the remote webservice wsdl, and i know what service name i will
invoke, how to write the to URI?
and if i have not the wsdl, and i know the webservice adress, service name,
input and output,
this is my wsdl generate the request in soap ui:
soapenv:Envelope xmlns:soapenv=http://schemas.xmlsoap.org/soap/envelope/;
xmlns:iws=http://www.wstest.sunyard.com/IWSTestService/;
soapenv:Header/
soapenv:Body
iws:getComplexObjectRequest
iws:userNames
my route like
from(direct://test).process(convertOut).to(mycompomnent).process(convertIn)
i need to send local message to mycompomnent, but i need to convert message
to the format before send and mycompomnent is sync mode, so i need to
convert the response message to my format after get response.
why must set serviceClass when use dataFormat as pojo or message, and payload
not need.
and i want use cxf component by the WSDL file only, how to convert the
payload message to document?
and then i want to convert xml to map format.
--
View this message in context:
my application need to send message to the other application by webservices.
so i need to execute the message route by hand. how to send once and
received the response than finished?
--
View this message in context:
because my platform need send message to webservice server, socket server,
ftp server, or other unknow protocol communication， so i want use camel
send message to some server by the endpoint define, and my platform give the
message to camel by direct. so if i need to use
Camel In Action 7.7.1 wrote:
The Direct component lets you make a synchronous
call to a route or, conversely, expose a route as a synchronous service.
To demonstrate, say you have a route that’s exposed by a direct endpoint
as follows:
from(direct:startOrder)
what's the difference between use endpoint to create producer with use
template? or when should to use template? only the difference with the code
lines count?
other question:
Producer producer = endpoint.createProducer();
producer.process(exchange);
why i use from(direct:name).to() i
what mechanism about the produce? has length limit? has the relation with
current time?
i saw the message id like host-name-serial number
how to intervent the produce?
--
View this message in context:
http://camel.465427.n5.nabble.com/about-the-message-id-tp4642608p4642608.html
Sent from the
i have get some endpoint uri strings,
and some route be defined as
from(endpoint1).to(direct:name)
from(endpoint2).to(direct:name)
...
i have new CamelContext(), and want to add these route to it then start.
how to add dynamic use api, not use like :
context.addRoutes(new RouteBuilder() {
i look RouteDefinition class in camel-core javadoc from website
public RouteDefinition(Endpoint endpoint)
what the input endpoint mean?
but i can't find the souce from 2.7.2 version
--
View this message in context:
but it's successful when use mvn archetype:generate to select
camel-archetype-component number and then selected step by step
--
View this message in context:
http://camel.465427.n5.nabble.com/create-myComponent-error-use-maven-tp4637541p4637712.html
Sent from the Camel - Users mailing list
how to implement the transport protocol ?
i create myComponent and myConsumer extends DefaultConsumer,
where to add my protocol handle when i received client request.
--
View this message in context:
i take a look at mina Consumer, i have some question
MyConsumer must handle the processor in the DSL by from().process()? if
have some processes how to write? why the mina call the process(exchange)
only once? or it's recursive auto?
the mina consumer code like :
//received message
try {
not a .ear file, just a main program, run as java application.and classpath
is the jars copied from all camel-core and camel-mina dependency in
WEB-INF/lib .
but the same main program is running fine in mina maven project. i don't
know what's the difference?
--
View this message in context:
i means it's successful in camel-mina maven project, but exception in my j2ee
project.
in camel-mina project the camel-context.xml at
camel-mina\target\test-classes. and in camel-mina project i have not use
spring to load the context file. why in my j2ee project it's fail?
--
View this message
in my application platform, the communicate relation like this:
http://camel.465427.n5.nabble.com/file/n4585397/aa.jpg
if every arrowhead show a request. and all request must receive response
with synchronous mode.
so which routes should to be define ?
is every request shold be define with a
i import camel-mina components into myeclipse as a maven project. and write a
test Class like this:
public class SocketTest {
public static void main(String args[]) throws Exception {
CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
if my application use route config like :
routes
route1 enable=yes/route1
route2 enable=yes/route2
route3 enable=no/route3
/routes
how to start the route1 and route2, i must control it by java coding?
--
View this message in context:
If my client application want to send message to my Camel with socket, and
application communication protocol is send three bytes like 'REQ' to server
first, and the server response three bytes like 'ANS' to client for affirm
the request, then client begin to send application message package to
yes, i means to be an application level handshake, but my client provide by
other systems , like c or c++ implements, so you can't decide the clients
use uuid to distinguish the twice interaction.
by the way, what the principle about the message exchange in Camel, use
something like MQ ?
excuse
i want to use camel in ofbiz, and use camel to handle receive request,
transform message and send response , how to integrate camel to ofbiz?
--
View this message in context:
http://camel.465427.n5.nabble.com/How-does-Camel-work-with-ofbiz-tp4522972p4522972.html
Sent from the Camel - Users
i want to select a Routing and Transformation tool，i found camel, openAdapter
and xbus have these functions, but i can't decide what i need to select, who
can help me how to choice?
--
View this message in context:
[ERROR] COMPILATION ERROR :
[INFO] -
[ERROR]
\workspace9\apache-camel-2.7.2\camel-core\src\main\java\org\apache\camel\model\LoadBalanceDefinition.j
ava:[131,16] inconvertible types
found：
79 matches
Mail list logo
