My servicemix is not generating end point for the following class :
My MessageReceiver code :
public class MessageReceiverImpl extends ComponentSupport implements
MessageExchangeListener,MessageReceiver{
// log
private Log log =
LogFactory.getLog(MessageReceiverImpl.class);
// sourcetransformer to transform message from exchange
private SourceTransformer sourceTransformer = new
SourceTransformer();
public Log getLog() {
return log;
}
public void setLog(Log log) {
this.log = log;
}
public SourceTransformer getSourceTransformer() {
return sourceTransformer;
}
public void setSourceTransformer(SourceTransformer
sourceTransformer) {
this.sourceTransformer = sourceTransformer;
}
/**
* This method will get the Asynchronous messages from
exchange, will transform into Java Bean and then
* call another class method to store into db.
* @return void
* @param args MessageExchange exchange to get messages
*/
public void onMessageExchange(MessageExchange exchange) throws
MessagingException {
// getting the incoming message from exchange
NormalizedMessage message = exchange.getMessage("in");
if (message == null) {
log.warn("Received null message from exchange: " +
exchange);
}
else {
log.info("Exchange: " + exchange + " received IN
message : " + message);
try {
// getting the messaging content from message in
xml format
String xml =
sourceTransformer.toString(message.getContent());
// using the custom utility class to transform
xml into java object
Message messageBean =
XMLBeanUtil.getMessageObjectFromXML(xml);
// saving that java object into database by using
the hibernate
MessagesDAOImpl instance = new MessagesDAOImpl();
instance.saveMessage(messageBean);
}
catch (TransformerException e) {
log.error("Failed to turn message body into text: "
+ e, e);
}
catch(Exception e) {
log.error("Failed to turn message body into
text: " + e, e);
}
}
// done with exchange
done(exchange);
}
}
And servicemix.xml code is :
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:sm="http://servicemix.apache.org/config/1.0";
xmlns:jsr181="http://servicemix.apache.org/jsr181/1.0";
xmlns:http="http://servicemix.apache.org/http/1.0";
xmlns:my="http://servicemix.apache.org/demo/";
xmlns:demo="http://servicemix.apache.org/demo/";>
<!-- the JBI container -->
<sm:container id="jbi"
useMBeanServer="true"
createMBeanServer="true"
dumpStats="true"
rmiPort="2222"
statsInterval="10"
transactionManager="#transactionManager">
<sm:activationSpecs>
<!-- Subscribe to a JMS destination -->
<sm:activationSpec componentName="inputReceiver"
service="my:inputReceiver"
destinationService="demo:savedata">
<sm:component>
<bean
class="org.apache.servicemix.components.jms.JmsInUsingJCABinding">
<property name="jcaContainer" ref="jencks"/>
<property name="activationSpec">
<bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
<property name="destination"
value="com.rhg.servicemix.messaging.errorLogging"/>
<property name="destinationType" value="javax.jms.Topic"/>
</bean>
</property>
</bean>
</sm:component>
</sm:activationSpec>
<sm:activationSpec id="savedata"
service="demo:savedata">
<sm:component>
<bean xmlns="http://xbean.org/schemas/spring/1.0";
class="com.rhg.infrastructure.jms.MessageReceiverImpl" />
</sm:component>
</sm:activationSpec>
</sm:activationSpecs>
</sm:container>
<!-- the JCA container -->
<bean id="jencks" class="org.jencks.JCAContainer" singleton="true">
<!-- lets use the default configuration of work manager and transaction
manager-->
<property name="bootstrapContext">
<bean class="org.jencks.factory.BootstrapContextFactoryBean">
<property name="threadPoolSize" value="25"/>
</bean>
</property>
<!-- the JCA Resource Adapter -->
<property name="resourceAdapter">
<bean id="activeMQResourceAdapter"
class="org.apache.activemq.ra.ActiveMQResourceAdapter" singleton="true">
<property name="serverUrl" value="tcp://localhost:61616"/>
</bean>
</property>
</bean>
<!-- message broker -->
<bean id="broker" class="org.apache.activemq.xbean.BrokerFactoryBean">
<property name="config" value="classpath:activemq.xml"/>
</bean>
<bean id="transactionContextManager"
class="org.jencks.factory.TransactionContextManagerFactoryBean"/>
<bean id="transactionManager"
class="org.jencks.factory.GeronimoTransactionManagerFactoryBean" />
<bean id="jmsFactory"
class="org.apache.activemq.pool.PooledConnectionFactory">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL">
<value>tcp://localhost:61616</value>
</property>
</bean>
</property>
</bean>
</beans>
--
View this message in context:
http://www.nabble.com/error-in-end-point-t1636488.html#a4431816
Sent from the ServiceMix - User forum at Nabble.com.
