On 5/16/07, Benamin <[EMAIL PROTECTED]> wrote:
I need an SE that can do the following:
1. It needs to read data from a database (dequeue).
2. Once read, this data should be sent over http to a web service.
3. Repeat steps 1 and 2.
I have made the SE and an SU for the SE. I have made an http provider.
What I am trying to figure out is where to place the code in the SE to do
the the reading of data from the db. I thought maybe the start method in
MyEndpoint.java, but that doesn't seem to work.
I highly advise you to put your logic in POJOs and then just reference
the POJOs from within MyEndpoint. This is a best practice that allows
the logic to be testable outside of JBI/ServiceMix. Then, inside of
MyEndpoint, you will need to override either processInOnly() or
processInOutI() depending on the MEP your SE supports - based on what
you have described you'll need to override processInOut(). In that
method you will make use of your POJOs.
Secondly, I am trying to figure out how to send the data to the http
provider. Are there any code snippets or pseudocode on how to send data
from an SE to somewhere else like an http provider?
Sure, I've done this before. Below is an example of a method to invoke
a HTTP provider that is a proxy to WSDL web service. the
invokeIdentityService() method just sends a normalized message to the
identity service and the HTTP provider BC automatically transforms it
into SOAP based on the configuration in the HTTP provider BC's
xbean.xml:
-------------------------------------------------------------------------------------------------------------------------
private boolean invokeIdentityService(String msisdn, Source request)
throws MessagingException {
InOut identityExchange = exchangeFactory.createInOutExchange();
configureTarget("Identity Service", identityExchange, ctx,
identityInterface, identityService, identityEndpoint, identityUri);
NormalizedMessage in = identityExchange.createMessage();
in.setContent(support.createIdentityInMessage(msisdn, request));
identityExchange.setInMessage(in);
sendSync(identityExchange);
NormalizedMessage out = identityExchange.getOutMessage();
boolean login = false;
if (out != null) {
login = support.parseIdentityOutMessage(out.getContent());
} else {
// TODO: how should we handle faults
}
done(identityExchange);
return login;
}
...
public void configureTarget(String serviceDesc, MessageExchange
exchange, ComponentContext context,
QName _interface, QName service,
String endpoint, String uri) throws
MessagingException {
if (_interface == null && service == null && uri == null) {
throw new MessagingException(serviceDesc + ": interface,
service or uri should be specified");
}
if (uri != null) {
URIResolver.configureExchange(exchange, context, uri);
}
if (_interface != null) {
exchange.setInterfaceName(_interface);
}
if (service != null) {
exchange.setService(service);
if (endpoint != null) {
ServiceEndpoint se = context.getEndpoint(service, endpoint);
exchange.setEndpoint(se);
}
}
}
-------------------------------------------------------------------------------------------------------------------------
Bruce
--
perl -e 'print unpack("u30","D0G)[EMAIL
PROTECTED]&5R\"F)R=6-E+G-N>61E<D\!G;6%I;\"YC;VT*"
);'
Apache Geronimo - http://geronimo.apache.org/
Apache ActiveMQ - http://activemq.org/
Apache ServiceMix - http://servicemix.org/
Castor - http://castor.org/
