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
_______________________________________________
jboss-user mailing list
[email protected]
https://lists.jboss.org/mailman/listinfo/jboss-user
