The problem is not related to your code, but to the test configuration.
The PollingEndpoint is a consumer endpoint, which means it will create
and send JBI exchanges. Thus, you have to tell where the exchange go.
Hence the error you see.
You should set this property in java or xml depending on the way the test
is wired:
endpoint.setTargetService(new QName("urn:test", "svc"));
or
<xxx:endpoint targetService="test:svc" >
I guess you will have to rewrite the test somehow, as it may have been
designed to test a provider endpoint rather than a consumer.
On 5/17/07, Benamin <[EMAIL PROTECTED]> wrote:
gnodet wrote:
>
> On 5/16/07, Benamin <[EMAIL PROTECTED]> wrote
>
>
>> I think you will want to inherit the PollingEndpoint instead. It will
>> take
>> care of periodically
>> call the poll() method that you need to implement. Else you can start
a
>> thread in the start()
>> method and kill it in the stop() method.
>
>
>
I am using your advice and tyring the PollingEndpoint class and use
Bruce's
code to send data to an http provider. At the moment I have left out my
custom logic. I am just trying to get a simple example to send a message
to
the http provider. My code compiles, MySpringComponent test fails. I am
posting my code so far to see if somebody can find the problem. I'll be
glad to post a completed example of this if I can get it to work. Thanks.
public class MyEndpoint extends PollingEndpoint implements
ExchangeProcessor
{
private ServiceEndpoint activated;
private DeliveryChannel channel;
private MessageExchangeFactory exchangeFactory;
public void activate() throws Exception {
logger = this.serviceUnit.getComponent().getLogger();
ComponentContext ctx =
getServiceUnit().getComponent().getComponentContext();
channel = ctx.getDeliveryChannel();
exchangeFactory = channel.createExchangeFactory();
activated = ctx.activateEndpoint(service, endpoint);
start();
}
public String getLocationURI() {
return getService() + "#" + getEndpoint();
}
public void process(MessageExchange exchange) throws Exception {
if (exchange.getRole() == MessageExchange.Role.PROVIDER) {
// Check here if the mep is supported by this component
if (exchange instanceof InOut == false) {
throw new UnsupportedOperationException("Unsupported MEP: "
+
exchange.getPattern());
}
// In message
if (exchange.getMessage("in") != null) {
NormalizedMessage in = exchange.getMessage("in");
NormalizedMessage out = exchange.createMessage();
out.setContent(in.getContent());
exchange.setMessage(out, "out");
channel.send(exchange);
// Fault message
} else if (exchange.getFault() != null) {
// TODO ... handle the fault
exchange.setStatus(ExchangeStatus.DONE);
channel.send(exchange);
// This is not compliant with the default MEPs
} else {
throw new java.lang.IllegalStateException("Provider
exchange
is ACTIVE, but no in or fault is provided");
}
}
}
public void poll() throws Exception
{
invokeIdentityService();
}
private boolean invokeIdentityService() throws MessagingException {
ComponentContext ctx =
getServiceUnit().getComponent().getComponentContext();
QName identityService = new QName("NSR:NSRService", "service");
InOut identityExchange = exchangeFactory.createInOutExchange();
configureTarget("Identity Service", identityExchange, ctx,
null, identityService, "soap", "");
NormalizedMessage in = identityExchange.createMessage();
in.setContent(new StringSource("<hello>Testing</hello>"));
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 (_interface != null) {
exchange.setInterfaceName(_interface);
}
if (service != null) {
exchange.setService(service);
if (endpoint != null) {
ServiceEndpoint se = context.getEndpoint(service,
endpoint);
exchange.setEndpoint(se);
}
}
}
}
The error I am getting is:
test(
org.apache.servicemix.samples.serviceManagerAssembly.MySpringComponentTest
)
Time elapsed: 1.951 sec <<< ERROR!
org.springframework.beans.factory.BeanCreationException: Error creating
bean
with name 'jbi' defined in class path resource [spring.xml]: Invocation of
init method failed; nested exception is
javax.jbi.management.DeploymentException: targetInterface, targetService
or
targetUri should be specified
Caused by: javax.jbi.management.DeploymentException: targetInterface,
targetService or targetUri should be specified
--
View this message in context:
http://www.nabble.com/SE-that-continually-reads-and-sends-data-tf3764809s12049.html#a10656682
Sent from the ServiceMix - User mailing list archive at Nabble.com.
--
Cheers,
Guillaume Nodet
------------------------
Principal Engineer, IONA
Blog: http://gnodet.blogspot.com/
