Apache Camel-এ Bean ব্যবহার করে ডেটা প্রসেসিং একটি শক্তিশালী এবং নমনীয় পদ্ধতি। Beans আপনাকে পুনঃব্যবহারযোগ্য কোড লিখতে দেয়, যা বিভিন্ন মেসেজ প্রসেসিং কাজের জন্য কার্যকর। নিচে আমরা দেখবো কিভাবে Apache Camel-এ Beans ব্যবহার করে ডেটা প্রসেসিং করতে হয়।

১. Bean তৈরি করা

প্রথমে, আপনাকে একটি Bean ক্লাস তৈরি করতে হবে। এই ক্লাসে এক বা একাধিক মেথড থাকবে যা মেসেজের ডেটা প্রসেস করতে ব্যবহৃত হবে।

public class MyBean {
    public String convertToUpper(String body) {
        return body.toUpperCase(); // Convert message body to uppercase
    }

    public String appendSuffix(String body) {
        return body + " - processed"; // Append suffix to the message body
    }
}

২. Apache Camel রাউট তৈরি করা

এখন আপনি একটি Apache Camel রাউট তৈরি করতে পারেন যেখানে Bean ব্যবহার করা হবে। এখানে আমরা একটি ডিরেক্ট সোর্স থেকে মেসেজ গ্রহণ করবো এবং Bean ব্যবহার করে প্রসেস করবো।

import org.apache.camel.builder.RouteBuilder;

public class MyRouteBuilder extends RouteBuilder {
    @Override
    public void configure() {
        from("direct:start")
            .bean(MyBean.class, "convertToUpper") // Use the convertToUpper method
            .bean(MyBean.class, "appendSuffix") // Use the appendSuffix method
            .to("log:processed"); // Log the processed message
    }
}

৩. রাউট শুরু করা

CamelContext শুরু করার জন্য আপনাকে এটি সঠিকভাবে সেটআপ করতে হবে। নিচে একটি সম্পূর্ণ উদাহরণ দেয়া হলো:

import org.apache.camel.CamelContext;
import org.apache.camel.impl.DefaultCamelContext;

public class CamelApplication {
    public static void main(String[] args) throws Exception {
        CamelContext context = new DefaultCamelContext();

        // Add the route
        context.addRoutes(new MyRouteBuilder());

        // Start the context
        context.start();

        // Sending a test message
        context.createProducerTemplate().sendBody("direct:start", "hello world");

        // Keep the application running for a while
        Thread.sleep(5000);
        context.stop();
    }
}

৪. ইনপুট এবং আউটপুট

• ইনপুট: যখন আপনি direct:start এ একটি মেসেজ পাঠাবেন, যেমন "hello world"।
• আউটপুট: এই মেসেজটি প্রথমে convertToUpper মেথড দ্বারা প্রসেস হবে, যা এটি "HELLO WORLD" এ পরিণত করবে। তারপর appendSuffix মেথডটি এটিতে - processed যোগ করবে, ফলস্বরূপ মেসেজটি "HELLO WORLD - processed" হবে।

৫. Log Output

যখন আপনি মেসেজটি প্রসেস করবেন, তখন এটি লগে প্রিন্ট হবে। লগ আউটপুট দেখতে পারেন:

2024-10-22 12:00:00.000 [main] INFO org.apache.camel.logger.Logger - processed: HELLO WORLD - processed

উপসংহার

Apache Camel-এ Beans ব্যবহার করে ডেটা প্রসেসিং একটি শক্তিশালী কৌশল, যা আপনাকে পুনঃব্যবহারযোগ্য এবং পরিষ্কার কোড তৈরি করতে সাহায্য করে। Beans ব্যবহার করে, আপনি আপনার ব্যবসায়িক লজিককে সহজেই Camel রাউটে অন্তর্ভুক্ত করতে পারেন, যা মেসেজ প্রসেসিংয়ের প্রক্রিয়াকে আরও কার্যকরী করে তোলে।

আপনি আপনার Beans-এ যেকোনো লজিক রাখতে পারেন, যেমন ডেটা যাচাইকরণ, মেসেজ রূপান্তর, বা কোনও কাস্টম কার্যকলাপ সম্পাদন করা, যা আপনাকে একটি নমনীয় এবং শক্তিশালী ইন্টিগ্রেশন সিস্টেম তৈরি করতে সাহায্য করবে।