Thank you for your reply Tim. I have not used any acknowledgement mode
explicitly. I presume container will handle it and the default ack is
AUTO_ACKNOWLEDGE. Please correct me if I am wrong
Here is my MDB code
In the below code I have used CDI @Inject used for MessageBus object. Also
attaching ejb-jar.xml for MDB configurations.
Please advise further.
-------------------------PpNamePinpointListener
-------------------------------------------
public class PpNamePinpointListener implements MessageListener,
MessageDrivenBean
{
private static final long serialVersionUID = 1L;
private static final Logger logger = LogManager.getLogger();
private MessageDrivenContext messageDrivenContext = null;
@Inject
@MessageBusType(BusType.MDB_BUS)
private MessageBus messageBus;
@Inject
@BrokerConnectionFactory
private ConnectionFactory connectionFactory;
public void ejbCreate()
{
}
@Override
public void setMessageDrivenContext(MessageDrivenContext
messageDrivenContext)
{
this.messageDrivenContext = messageDrivenContext;
}
@Override
public void ejbRemove()
{
}
@Override
@TransactionAttribute(value = TransactionAttributeType.NOT_SUPPORTED)
public void onMessage(Message message)
{
CourierMessage messageObj = null;
try
{
messageObj = messageBus.resolve(message);
logger
.info("PpNamePinpointListener received message : " +
messageObj.getBody().toString());
System.out.println("PpNamePinpointListener received message : "
+ messageObj.getBody().toString());
}
catch (CourierException e)
{
logger.catching(e);
}
}
}
-------------------------------ejb-jar.xml---------------------------------
<?xml version="1.0" encoding="UTF-8"?>
<ejb-jar id="ejb-jar_ID" version="3.1"
xmlns="http://java.sun.com/xml/ns/javaee";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
http://java.sun.com/xml/ns/javaee/ejb-jar_3_1.xsd";>
<enterprise-beans>
<message-driven>
<display-name>PpNamePinpointListener</display-name>
<ejb-name>PpNamePinpointListener</ejb-name>
<ejb-class>com.fis.ec.courier.reference.PpNamePinpointListener</ejb-class>
<transaction-type>Container</transaction-type>
<activation-config>
<activation-config-property>
<activation-config-property-name>destination</activation-config-property-name>
<activation-config-property-value>IP_NAME_PP</activation-config-property-value>
</activation-config-property>
<activation-config-property>
<activation-config-property-name>destinationType</activation-config-property-name>
<activation-config-property-value>javax.jms.Queue</activation-config-property-value>
</activation-config-property>
</activation-config>
</message-driven>
</enterprise-beans>
</ejb-jar>
---------------------------Attachments--------------------------
ejb-jar.xml
<http://activemq.2283324.n4.nabble.com/file/n4715621/ejb-jar.xml>
PpNamePinpointListener.java
<http://activemq.2283324.n4.nabble.com/file/n4715621/PpNamePinpointListener.java>
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Aysnc-ActiveMQ-MDB-unable-to-consume-messages-tp4715582p4715621.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
