[EJB 3.0] - Re: Extensions to EJB3: Message Driven POJOs
by FrJaSoBe
Hi,
I have use @MessageDriven with no problem but when I have tried to use @Producer and @Consumer, I think I can't refactorize method start in that code(we filtrate message and add a listener):
...
@MessageDriven(mappedName = "queue/CentralitaInQueue", activationConfig = {
@ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/CentralitaInQueue"),
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
}
)
public class ConectorJBoss extends Conector implements MessageListener {
...
public void onMessage(Message message) {
ObjectMessage objMessage = (ObjectMessage) message;
try {
ApduCentralita apdu = (ApduCentralita) objMessage.getObject();
super.enviarComando(apdu);
} catch (JMSException e) {
Log.getLogger(this).error(e);
}
}
...
public void start() {
try {
//se crea el jmsworker
//jmsworker = new JMSWorker(null, JMSWorker.TIPO_LOCAL);
jmsworker = new JMSWorker(Constantes.CONNECTION_FACTORY_CENTRALITAS);
//jmsworker = new JMSWorker(this.queueConnectionFactory, this.topicConnectionFactory);
//selector jms para que solo tome los comandos que le corresponden
String selector = SELECTOR_JMS_CENTRALITA.replaceAll("\\#host_centralita", inetSockAddr.getAddress().getHostAddress());
selector = selector.replaceAll("\\#puerto_centralita", new Integer(inetSockAddr.getPort()).toString());
//anyadirse a si mismo como listener de la queue de comandos
jmsworker.receiverQueue(Constantes.QUEUE_CENTRALITAS_COMANDOS, this, selector);
//jmsworker.receiverQueue(this.queue, this, selector);
//se inicializa y cachea el publisher que se utilizara para enviar eventos a la cola de eventos
jmsworker.openCachedPublisher(Constantes.TOPIC_CENTRALITAS_EVENTOS);
//jmsworker.openCachedPublisher(this.topic);
} catch (Exception e) {
Log.getLogger(this).error(e);
}
}
...
}
Can I do this with JBoss Extension for MDB ?
Thanks.
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4006283#4006283
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4006283
19 years, 3 months