JBossDeveloper

"system.out" wrote:
I am trying to build something similar to fun-cbr but using objects in messaeg that needs to be evaluated by jboss rules.
Correct me if I am wrong: I assume when you use gateways as a bridge between esb-unaware user and esb-engine, gateway creates byteArray out of object and put it in the message body. Is that correct?

If yes, then how can I put my object in esb message differently, as you suggested?

We're always looking for contributors.

I would be more than happy to contribute, when I have the solution :)

Hi system.out,

Maybe I can help you.

In request message, you can use

requestMessage = mfactory.getMessage(MessageType.JBOSS_XML);

// Object specify the command (command "gravar")
Comando cmd = new Comando();
cmd.setValor("gravar");
requestMessage.getBody().add("Comando",cmd);

// Data to process
EnderecoBean e = new EnderecoBean();
e.setId(1);
e.setName("Test");
requestMessage.getBody().add("empresa",e);

Send the message

In ESB, edit jboss-esb.xml:

<service category="Empresa" name="Endereco" description="Manipula as acoes com enderecos">
 <listeners>
 <jms-listener name="JMS-ESBListener" busidref="enderecoEsbChannel" maxThreads="1" />
 </listeners>
 <actions>
 <action class="org.jboss.soa.esb.actions.ContentBasedRouter" name="ContentBasedRouter">
 <property name="ruleSet" value="RegrasParaEndereco.drl" />
 <property name="ruleReload" value="true" />
 <property name="destinations">
 <route-to destination-name="gravaEndereco" service-category="Endereco" service-name="GravaEndereco" />
 <route-to destination-name="apagaEndereco" service-category="Endereco" service-name="ApagaEndereco" />
 </property>
 <property name="object-paths">
 <object-path path="body.Comando" />
 </property>
 </action>
 </actions>
</service>

package com

import org.jboss.soa.esb.message.Message;
import org.jboss.soa.esb.message.format.MessageType;
import com.Comando;

#declare any global variables here
global java.util.List destinations;

rule "Gravar"
 when
 Comando(valor == "gravar")
 then
 System.out.println("Roteador Gravar");
 destinations.add("gravaEndereco");
end

rule "Apagar"
 when
 Comando(valor == "apagar")
 then
 System.out.println("Roteador Apagar");
 destinations.add("apagaEndereco");
end

Claudio this is excellent.

If system.out can verify that it solves his question then it would be great if you could build a wiki page that describes this begin to end example.

We should have a quickstart that illustrates this more clearly in the future.as well in the future.

Burr

"burrsutter" wrote:
Claudio this is excellent.

If system.out can verify that it solves his question then it would be great if you could build a wiki page that describes this begin to end example.

We should have a quickstart that illustrates this more clearly in the future.as well in the future.

Burr

using objects in messaeg that needs to be evaluated by jboss rules.

Mark is right. I want to do this through gateways. It is a very simple use case:
- QueueSender sends an Object to a queue
- Gateway translate/delegate the message to esb service listener
- ContentBasedRouter re-route the message based on myObject content

public void sendAMessage(Object myObject /**String msg**/) throws JMSException {
 QueueSender send = session.createSender(que);
 ObjectMessage tm = session.createObjectMessage(myObject /**msg*//);
 send.send(tm);
 send.close();
 }

At what point does your scenario become something to do with the ESB? I'm just wondering if all you need is CBR in a non-ESB environment?

I have many actions in the esb service pipeline. I also need to do CBR in esb environment based on "myObject".

I would personally take option 2. It is very easy and Claudio's response is very close to that solution.

A custom gateway is harder to build.


I'm working an example for option 2 now as this is an area that I think many folks will have questions in.

Hi system.out,

You will need create java object to send in ESB.
You can do this with a webservice or with xml. In xml, you can parser xml in pojo.

Claudio_br,

I am sending java object to esb pipeline thrugh JCA. JCA module receives date from outside world using different protocol, parses & creates java object, then posts it to a queue to be consumed by esb actions.

Why should I create a webservice to do that? Can't esb provide a simple api to handle java objects, a gateway looking at such a Queue ?!

Burr said it is harder to build a custom gateway, and I agree. I think it is a good idea to ship jbossesb with such a gateway !
If I get time, I will build one and submit it to jbossesb team. Burr, let me know if that helps.

Thanks,
Mike

I've not tried pushing a Java object into a JMS queue and then having a ESB JMS gateway listening on that queue. That is something I'll have to try. However, if you call the ESB with its native API then passing a Java object should be no problem.
The best example of using the native API for the ESB is demonstrated by quickstart webservice_war1 where WS receives the generic SOAP request, passes it to the ESB, waits a response from the ESB and then makes the ESB response the SOAP response - HelloWorldWS.java

 MessageDeliveryAdapter deliveryAdapter;
 Message requestMessage;
 Message replyMessage = null;

 // Create the delivery adapter for the target service (you'd normally cache this!!)...
 deliveryAdapter = new MessageDeliveryAdapter("MyServiceCategory", "MyService");
 // Create and populate the request message...
 requestMessage = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML);
 requestMessage.getBody().setByteArray(toWhom.getBytes()); // inject the value from the WS client
 // Deliver the request message synchronously - timeout after 20 seconds...
 replyMessage = deliveryAdapter.deliverSync(requestMessage, 20000);