Camel - Binding a bean method with paramete of camel exchange

[balavino <ba...@gmail.com>]

Hi,

I need to bind and call a bean method with some parameters - 1: a string 2:
a exchange. I see from camel page #http://camel.apache.org/bean-binding.html
that exchange binding as parameter is possible.
I'm using bean expression to do it.

In the code, i need to know the correct way of using (in the bolded line).
I'm here trying to set the throttle value of a camel route via some logic i
have to build in the binding method call.

/configure() method of a camel processor
-----------------------------------------------

    @Override
    public final void configure() throws Exception {
        
        System.out.println("Exchange from Processor: " + e);
        
        String queueName = toUri.split(":")[2];      
        String throttleValue =
*"${bean:queueCounter?method=getQueueSize("+queueName+",${"+e+"})}";*
        
        from(fromUri).routeId(routeId)
        .routePolicyRef("haRoutePolicy")
        .throttle(simple(throttleValue))
        .timePeriodMillis(timeInterval)
        .setHeader("HostId", simple(hostName))
        .process(new MessageProcessor())
        .log("Started Polling the Source Directory for Files.")
        .to(toUri);
    }



Method that i need to bind
-------------------------------

ublic class QueueSizeCounter  {

    private ActiveMQComponent activemqComponent;
    private Session session;

    public Long getQueueSize(String queueName, Exchange e) throws
JMSException {
        
        activemqComponent = (ActiveMQComponent) e.getContext()
                .getComponent("activemq");
        Connection connection1 =
activemqComponent.getConfiguration().getConnectionFactory().createConnection();
        connection1.start();
        session = connection1.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
        
        Queue replyTo = session.createTemporaryQueue();
        MessageConsumer consumer = session.createConsumer(replyTo);
        
        Queue query = session.createQueue("ActiveMQ.Statistics.Destination"
+ queueName );
        MessageProducer producer = session.createProducer(query);
        Message msg = session.createMessage();
        msg.setJMSReplyTo(replyTo);
        producer.send(msg);
        
        MapMessage reply = (MapMessage) consumer.receive();
        for (Enumeration en = reply.getMapNames();en.hasMoreElements();) {
            String name = en.nextElement().toString();
            System.out.println(name + "=" + reply.getObject(name));
          }
        
            return 1L;
        }
    }/



--
View this message in context: http://camel.465427.n5.nabble.com/Camel-Binding-a-bean-method-with-paramete-of-camel-exchange-tp5768582.html
Sent from the Camel Development mailing list archive at Nabble.com.