Can you just send me the sample configuration files with the minimum requrired field for the xbean for the jms-consumer su that sends messge to the nmr and bean su that listens to the messge back to the nmr i mean so that i can't get response back to my client program. Regards, Yogaraj
[EMAIL PROTECTED] wrote: > > Hi, > I made an SA successfully using the servicemix-bean su and jms-consumer > su and used mvn command > to make SA out of them and build was successful.I wrote a client jms > program that sends the message.But I couldn't get response back from bean > I am using simple inout echo bean that you listed on the site. > I think problem is with my xbean and target point > i am sending both here. > > > beans xmlns:bean="http://servicemix.apache.org/bean/1.0"; > xmlns:y="http://localhost:8192/yrkproject";> > > <bean:endpoint service="y:service" > endpoint="nih.nci.gov.caXchange.org.servicemix.yrkprojectinput" > bean="#myBean"/> > > <bean id="myBean" class="org.apache.YrkProject.MyBean"/> > </beans> > > beans xmlns:jms="http://servicemix.apache.org/jms/1.0"; > xmlns:y="http://localhost:8192/yrkproject"; > xmlns:amq="http://activemq.org/config/1.0";> > > > <jms:endpoint service="y:yrkproject" > > endpoint="nih.nci.gov.caXchange.org.servicemix.yrkprojectsource" > targetService="y:yrkproject" > > targetEndpoint="nih.nci.gov.caXchange.org.servicemix.yrkprojectsource" > role="consumer" > destinationStyle="queue" > > jmsProviderDestinationName="nih.nci.gov.caXchange.org.servicemix.yrkprojectsource" > defaultMep="http://www.w3.org/2004/08/wsdl/in-out"; > defaultOperation="test:Echo" > connectionFactory="#connectionFactory" /> > <bean id="#connectionFactory" > class="org.apache.activemq.pool.PooledConnectionFactory"> > <property name="connectionFactory"> > <bean class="org.apache.activemq.ActiveMQConnectionFactory"> > <property name="brokerURL" value="tcp://localhost:61616"/> > </bean> > </property> > </bean> > > > > > </beans> > > > > This is my client > > package nih.nci.gov.caXchange; > import javax.jbi.messaging.InOut; > import org.apache.servicemix.client.DefaultServiceMixClient; > import org.apache.servicemix.jbi.jaxp.StringSource; > import javax.xml.namespace.QName; > import javax.jms.*; > > import org.apache.activemq.ActiveMQConnectionFactory; > import org.apache.activemq.command.ActiveMQQueue; > > > public class TestJmsClient { > > /** > * @param args > */ > public static void main(String[] args) throws JMSException{ > System.out.println("Connecting to JMS server."); > // ActiveMQ JMS Provider code > ActiveMQConnectionFactory factory = > new ActiveMQConnectionFactory("tcp://localhost:61616"); > Destination inQueue = new > ActiveMQQueue("nih.nci.gov.caXchange.org.servicemix.yrkprojectsource"); > Destination outQueue = new > ActiveMQQueue("nih.nci.gov.caXchange.org.servicemix.yrkprojectoutput"); > Connection connection = factory.createConnection(); > Session session = connection.createSession(false, > Session.CLIENT_ACKNOWLEDGE); > // Create the message 66 and consumer > MessageProducer producer = session.createProducer(inQueue); > System.out.println("Producer got this: "+producer); > MessageConsumer consumer = session.createConsumer(outQueue); > System.out.println("Consumer got this: "+consumer); > connection.start(); > System.out.println("Sending request."); > //producer.send(session.createTextMessage("<message>Hello, > world!</message>")); > TextMessage tMsg = session.createTextMessage("Yogi"); > System.out.println(tMsg); > tMsg.setJMSReplyTo(inQueue); > producer.send(tMsg); > connection.close(); > System.out.println("Done."); > > > > > } > > /*public void init(ComponentContext context) throws JBIException > { > this.context = context; > context.activateEndpoint(new QName("http://your.namespace";, > "service"), "endpoint"); > }*/ > > /*public void testEcho() throws Exception { > DefaultServiceMixClient client = new > DefaultServiceMixClient(jbi); > InOut me = client.createInOutExchange(); > me.setService(new QName("http://bpmscript.org/jbi";, > "timeout")); > me.getInMessage().setContent(new > StringSource("<hello>world</hello>")); > ssertTrue(client.sendSync(me, 1000000)); > Exception error = me.getError(); > assertTrue(error instanceof TimeoutException); > } */ > > } > > > Can any one suggest me how do I get reply back from servicemix bean. > Regards, > Raj > -- View this message in context: http://www.nabble.com/How-to-build-SA-using-bean-SU-and-jms-consumer-SU-and-debug-and-deploy-in-eclipse-tf4563348s12049.html#a13025278 Sent from the ServiceMix - Dev mailing list archive at Nabble.com.
