Hi,
You need use SMX4 client api to do it.
Take a look at nmr/client example shipped with kit to get details
about how to do it.
Now you create client channel from injected nmr service, but not the
context, so you should not worry about the context injection in this
case.
Freeman
On 2010-8-10, at 上午12:49, gnanda1 wrote:
Hi All,
I am using smx4.2.
I have created a custom Mbean with two operations exposed. The
interface is
defined as below
public interface ServiceResourceManagerMBean {
public void startServiceResource(String servicename, String
resourcename);
public void stopServiceResource(String servicename, String
resourcename);
}
From the jconsole when these operations get called I need to create
a xml
message and post to a jbi endpoint (which is a endpoint in camel
router)
I am trying with the below code
public void startServiceResource(String servicename, String
resourcename){
log.info("startServiceResource");
String xml = this.BuildMessage(servicename, resourcename);
this.sendMessage(xml);
}
public void sendMessage(String xml) {
try {
log.info("sendMessage start");
// ComponentContext context = getContext();
InOnly exchange = context.getDeliveryChannel()
.createExchangeFactory().createInOnlyExchange();
NormalizedMessage message = exchange.createMessage();
message.setContent(new StringSource(xml));
/*
* EndpointResolver resolver =
* channel.lient.createResolverForService(service); if
(resolver !=
* null) { ServiceEndpoint destination =
* resolver.resolveEndpoint(getContext(), exchange,
* NullEndpointFilter.getInstance());
* exchange.setEndpoint(destination); }
*/
QName service = new QName("urn:com.pf.simpleprovider",
"http");
exchange.setService(service);
exchange.setInMessage(message);
// Now, send the message exchange
log.info("sendMessage before send");
exchange.setStatus(ExchangeStatus.ACTIVE);
context.getDeliveryChannel().send(exchange);
log.info("sendMessage end");
} catch (Exception e) {
log.error("error",e);
}
}
I am not sure my approach here is correct or not.
1)Could I use Deliverychannel here to send a message to a jbi
endpoint?
Or do I need get reference to servicemixClient to send a message to
jbi
endpoint?
2) Does this file need to extend messageListener class and in
onlisten()
method do need to close/complete this communication by setting
status to
DONE.
Since it is in-only exchange, I guess I do not expect any return
coming
back, but not sure about it
3) I am having issue with getting reference to ComponentContext
here. I have
posted the error in another thread.
I am really stuck here
Any help is greately appreciated.
Thanks & Regards
Gnanda
--
View this message in context:
http://servicemix.396122.n5.nabble.com/sending-a-message-to-a-jbi-endpoint-from-a-custom-MBean-tp2269081p2269081.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.
--
Freeman Fang
------------------------
Open Source SOA: http://fusesource.com
Apache Servicemix:http://servicemix.apache.org
Apache Cxf: http://cxf.apache.org
Apache Karaf: http://karaf.apache.org
Apache Felix: http://felix.apache.org
