Refactor code base

Author: ayeshLK

examples/ez-food/order-processor/Ballerina.toml

@@ -22,4 +22,3 @@ filePath = "persist/model.bal"
 groupId = "io.ballerina.stdlib"
 artifactId = "persist.inmemory-native"
 version = "1.6.0"
-

examples/ez-food/order-processor/connections.bal

@@ -0,0 +1,36 @@
+// Copyright (c) 2025, WSO2 LLC. (http://www.wso2.org).
+//
+// WSO2 LLC. licenses this file to you under the Apache License,
+// Version 2.0 (the "License"); you may not use this file except
+// in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+import ballerinax/java.jms;
+
+const string ORDERS_QUEUE = "orders";
+const string ORDER_CONFIRMATIONS_QUEUE = "order-confirmation";
+const string ORDER_STATUS_UPDATE_TOPIC = "order-status-update";
+
+configurable jms:ConnectionConfiguration activeMqConnectionConfig = {
+    initialContextFactory: "org.apache.activemq.jndi.ActiveMQInitialContextFactory",
+    providerUrl: "tcp://localhost:61616"
+};
+
+final jms:MessageProducer producer = check createProducer();
+
+isolated function createProducer() returns jms:MessageProducer|error {
+    jms:Connection connection = check new (activeMqConnectionConfig);
+    jms:Session session = check connection->createSession();
+    return session.createProducer();
+}
+
+listener jms:Listener activeMqListener = check new (activeMqConnectionConfig);

examples/ez-food/order-processor/order_details_listener.bal

@@ -17,28 +17,10 @@ import orderprocessor.store;
 
 import ballerinax/java.jms;
 
-const string ORDERS_QUEUE = "orders";
-const string ORDER_CONFIRMATIONS_QUEUE = "order-confirmation";
-
-configurable jms:ConnectionConfiguration activeMqConnectionConfig = {
-    initialContextFactory: "org.apache.activemq.jndi.ActiveMQInitialContextFactory",
-    providerUrl: "tcp://localhost:61616"
-};
-
-final jms:MessageProducer producer = check createProducer();
-
-isolated function createProducer() returns jms:MessageProducer|error {
-    jms:Connection connection = check new (activeMqConnectionConfig);
-    jms:Session session = check connection->createSession();
-    return session.createProducer();
-}
-
-listener jms:Listener orderDetailsListener = check new (activeMqConnectionConfig);
-
 @jms:ServiceConfig {
     queueName: ORDERS_QUEUE
 }
-service "order-details-receiver" on orderDetailsListener {
+service "order-details-receiver" on activeMqListener {
     remote function onMessage(jms:Message message) returns error? {
         if message !is jms:BytesMessage {
             return;

examples/ez-food/order-processor/order_status_listener.bal

@@ -15,15 +15,11 @@
 // under the License.
 import ballerinax/java.jms;
 
-const string ORDER_STATUS_UPDATE_TOPIC = "order-status-update";
-
-listener jms:Listener orderStatusListener = check new (activeMqConnectionConfig);
-
 @jms:ServiceConfig {
     topicName: ORDER_STATUS_UPDATE_TOPIC,
     subscriberName: "order-processor-consumer"
 }
-service "order-status-update-receiver" on orderStatusListener {
+service "order-status-update-receiver" on activeMqListener {
     remote function onMessage(jms:Message message) returns error? {
         if message !is jms:BytesMessage {
             return;