lhein wrote: > > Hi, > > have a look at the FAQ: > > http://servicemix.apache.org/how-do-i-integrate-the-servicemix-jms-component-with-webspheremq.html > > It's actually a description how to connect to IBM Websphere MQ but you can > easily adapt it to work with your > MQ software as well. > > Regards > Lars > > > 2008/11/26 aznmedia <[EMAIL PROTECTED]> > >> >> Hello there. >> I'm fresh to servicemix. >> >> Is there any way to poll message and push message to rabbitMQ broker by >> servicemix? >> What servicemix component I should use? >> >> Cheers, >> MethoD >> -- >> View this message in context: >> http://www.nabble.com/Woking-with-rabbitMQ-by-servicemix-tp20695012p20695012.html >> Sent from the ServiceMix - User mailing list archive at Nabble.com. >> >> > > > -- > http://lhein.blogspot.com > > > ----- > Regards > Lars > > > http://lhein.blogspot.com > >
<beans xmlns:jms="http://servicemix.apache.org/jms/1.0"; xmlns:foo="http://mycompany.com/foo"; xmlns:util="http://www.springframework.org/schema/util";> <jms:endpoint service="foo:MyMQService" endpoint="mq" targetService="foo:TARGET_SERVICE_NAME_GOES_HERE" targetEndpoint="TARGET_ENDPOINT_GOES_HERE" role="consumer" destinationStyle="queue" jmsProviderDestinationName="QUEUE_NAME_GOES_HERE" connectionFactory="#mqConnectionFactory" defaultMep="http://www.w3.org/2004/08/wsdl/in-only"; /> <bean id="mqConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"> <property name="transportType"> <util:constant static-field="com.ibm.mq.jms.JMSC.MQJMS_TP_CLIENT_MQ_TCPIP" /> </property> <property name="queueManager" value="QMGR_NAME_GOES_HERE" /> <property name="hostName" value="HOST_ADDRESS_GOES_HERE" /> <property name="channel" value="QMGR_CHANNEL_NAME_GOES_HERE" /> <property name="port" value="PORT_NUMBER_GOES_HERE" /> </bean> </beans> It seems like requires queueManager name and channel name. But there's no queueManager and channel name in RabbitMQ. Is it possible to remove these properties? Here's the example code that sends message to rabbitmq given queue. // connection objects ConnectionFactory r_connectionFactory; Connection r_connection; Channel r_channel; // connection paramateres String r_hostName = "localhost"; int r_portNumber = AMQP.PROTOCOL.PORT; String r_realm = "/data"; int r_ticket; String r_exchange = ""; String r_routingKey = "jms-rabbit"; // queue name // connect to broker try { r_connectionFactory = new ConnectionFactory(); r_connection = r_connectionFactory.newConnection(r_hostName, r_portNumber); r_channel = r_connection.createChannel(); r_ticket = r_channel.accessRequest(r_realm); r_channel.queueDeclare(r_ticket, r_routingKey); } catch (Exception e) { e.printStackTrace(); } // send message to queue try { String msg = "Hello RabbitMQ!"; BasicProperties props = null; r_channel.basicPublish(r_ticket, r_exchange, r_routingKey, props, msg); } catch(Exception e) { e.printStackTrace(); } -- View this message in context: http://www.nabble.com/Woking-with-rabbitMQ-by-servicemix-tp20695012p20830063.html Sent from the ServiceMix - User mailing list archive at Nabble.com.
