Custom processor methods not visible in JConsole

[tcdewit]

Hi,

Part of my camel route consists of a JMS queue, being polled and its
messages being stored in a db, depending on message type. The route is
transacted, and therefore it's not possible to configure redeliveryDelay in
the ActiveMQXAConnectionFactory bean, but i had to use a custom processor
"redeliveryDelay" instead that checks the JMSXDeliveryCount in the header
and introduces a delay depending on the retry count.
I would like to have the possibility to configure/manage this processor and
its methods through jconsole/jmx but am having some problems with it:
- without using the annotations @ManagedResource, @ManagedAttribute i can
see the processor mbean, but cannot see its methods
- with annotations the processor mbean is not visible anymore (even if i
"implement Service" like mentioned in the camel FAQ, or if i implement the
deprecated ManagementAware). I also tried using only @ManagedResource or
@ManagedAttribute separately...
- when moving the processor to the recoverable camel:onException route
(preferable since its only executed when needed) the mbean is not visible at
all; even without annotations.


Any ideas?

regards, Tim


Relevant part of route:

<camel:route id="routeStoreInDB">
        <camel:from uri="jms:queue:incoming?transacted=true" />
        <camel:transacted ref="PROPAGATION_REQUIRED"/>
        <camel:process ref="redeliveryDelay" id="redeliveryDelay"/>
        <camel:choice>
                <camel:when>
                        <camel:spel>#{request.headers['CamelHL7MessageType'] ==
'ADT'}</camel:spel>
                                <camel:bean ref="ADTHandler" 
method="processADT" />
                        </camel:when>
                        <camel:when>
                                
<camel:spel>#{request.headers['CamelHL7MessageType'] ==
'ORM'}</camel:spel>
                                <camel:bean ref="ORMHandler" 
method="processORM" />
                        </camel:when>
                <camel:otherwise>
                        <camel:log message="NOT HANDLED 
Type:${header.CamelHL7MessageType}
Msg:${body}" />
                </camel:otherwise>
        </camel:choice>
        <camel:onException> 
                <camel:exception>java.sql.SQLException</camel:exception>
        
<camel:exception>org.springframework.jdbc.CannotGetJdbcConnectionException</camel:exception>
                <camel:handled>
                        <camel:constant>false</camel:constant>
                </camel:handled>
                <camel:log message="Recoverable error occurred! Will retry in a 
few
seconds..." loggingLevel="ERROR" logName="routeStoreInDB_ORM"/>
                
                <camel:rollback markRollbackOnly="true" />
        </camel:onException>
        <camel:onException> 
                <camel:exception>java.lang.Exception</camel:exception>
        
<camel:exception>org.springframework.jdbc.UncategorizedSQLException</camel:exception>
                <camel:handled>
                        <camel:constant>true</camel:constant>
                </camel:handled>
                <camel:log message="Irrecoverable error occurred!" 
loggingLevel="ERROR"
logName="routeStoreInDB_ORM"/>
                <camel:to uri="jms:queue:DLQ" />
</camel:onException>
</camel:route>


Processor code:

import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.api.management.ManagedAttribute;
import org.apache.camel.api.management.ManagedResource;

@ManagedResource
public class redeliveryDelay implements Processor {
    
    private long delay = 0;
    
    @ManagedAttribute
    public long getDelay() {
        return delay;
    }

    @ManagedAttribute
    public void setDelay(long delay) {
        this.delay = delay;
    }
    
    @Override
    public void process(Exchange exchange) throws Exception {
        String redeliveryCountAsString =
exchange.getIn().getHeader("JMSXDeliveryCount", String.class);
        if(redeliveryCountAsString==null) { redeliveryCountAsString="1"; }
        int redeliveryCount = Integer.parseInt(redeliveryCountAsString);
        
        switch (redeliveryCount) {
            case  0: this.setDelay(0);             break;
            case  1: 
            case  2: 
            case  3: this.setDelay(5000);          break;   // 3 x 5 seconds
            case  4: this.setDelay(60*1000);       break;   // 1 minute
            case  5: this.setDelay(5*60*1000);     break;   // 5 minutes
            case  6: this.setDelay(30*60*1000);    break;   // 30 minutes
            case  7: this.setDelay(60*60*1000);    break;   // 60 minutes
            default: this.setDelay(8*60*60*1000); break;   // every 8 hours
        }
        
        Thread.sleep(this.getDelay());
    }
    
}



--
View this message in context: 
http://camel.465427.n5.nabble.com/Custom-processor-methods-not-visible-in-JConsole-tp5768796.html
Sent from the Camel - Users mailing list archive at Nabble.com.