Multiple consumers on endpoint

[Jared Whiklo]

I've hit this in the past and it always confuses me.




This results in the error





But I'm not sure what else to do?



         from(config.getNodeIndex())
                .routeId("FcrepoIndexerNode")

                // Parse the event into a POJO.
                .unmarshal().json(JsonLibrary.Jackson, AS2Event.class)

                // Extract relevant data from the event.
                .setProperty("event").simple("${body}")
.setProperty("uuid").simple("${exchangeProperty.event.object.id.replaceAll(\"urn:uuid:\",\"\")}")
.setProperty("jsonldUrl").simple("${exchangeProperty.event.object.getJsonldUrl().href}")
.setProperty("fedoraBaseUrl").simple("${exchangeProperty.event.target}")


                // Prepare the message.
                .removeHeaders("*", "Authorization")
                .setHeader(Exchange.HTTP_METHOD, constant("POST"))

                .setBody(simple("${null}"))

                 // Prepare the message.

                .removeHeaders("*", "Authorization")
                .setHeader(Exchange.HTTP_METHOD, constant("POST"))

                .setBody(simple("${null}"))
                .multicast().parallelProcessing()
                    .to("direct:versionIndex", "direct:nodeIndex")
                .end();

       from("direct:versionIndex")
.filter(simple("${exchangeProperty.event.object.isNewVersion}"))
                //pass it to milliner
                .log(DEBUG, LOGGER, "Create a new version")

                        "node/${exchangeProperty.uuid}/version"))
                .toD("http://localhost?connectionClose=true";);

        from("direct:nodeIndex")
                .log(DEBUG, LOGGER, config.getMillinerBaseUrl() +
"node/${exchangeProperty.uuid}?connectionClose=true")

                        "node/${exchangeProperty.uuid}"))
                .toD("http://localhost?connectionClose=true";);



Any help appreciated.

Cheers,
jared

--
Jared Whiklo
jwhi...@gmail.com

So I have a route and it multicasts, but for some reason the CamelHttpUri was not set when checking for it in tests. So I tried splitting the two multicast targets into their own routes. org.apache.camel.FailedToStartRouteException: Failed to start route route23 because of Multiple consumers for the same endpoint is not allowed: direct://versionIndex If I switch the nodeIndex and versionIndex route blocks around in the code (not the order in the to() call), then direct://nodeIndex appears in the error which makes me think it is in the calling route.                 .log(DEBUG, LOGGER, "Received Node event for UUID (${exchangeProperty.uuid}), jsonld URL (" +                         "${exchangeProperty.jsonldUrl}), fedora base URL (${exchangeProperty.fedoraBaseUrl})")                 .setHeader("Content-Location", simple("${exchangeProperty.jsonldUrl}"))                 .setHeader(config.getFedoraUriHeader(), exchangeProperty("fedoraBaseUrl"))                 .setHeader("Content-Location", simple("${exchangeProperty.jsonldUrl}"))                 .setHeader(config.getFedoraUriHeader(), exchangeProperty("fedoraBaseUrl"))                 .setHeader(Exchange.HTTP_URI, simple(config.getMillinerBaseUrl() +                 .setHeader(Exchange.HTTP_URI, simple(config.getMillinerBaseUrl() + I've tried changing the ".end()" to ".endParent()" and even removing it, I've tried removing one of the endpoints from the to() and I tried removing the "multicast" and see if it works as a pipeline but the error always occurs.

OpenPGP_signature
Description: OpenPGP digital signature