Java Message Service

 The Java Message Service is an API that allows applications to create,send,receive and read messages.It enables communication loosely coupled and Asynchronous i.e. JMS provider deliver message to a client as they arrive and also reliable in the sense that it delivers the message only once.

Parts of JMS Application
  • JMS Client: Programs that receive and send messages.
  • Non-JMS clients: Clients that use message system's native API instead of JMS.
  • Messages: Information that is used to communicate between its clients.
  • JMS Provider: MOM (Message Oriented Middleware) that implements JMS API
  • Administered Objects: Objects created by administrator for the use of clients. These are placed in JNDI namespace by an administrator. They are
    • ConnectionFactory: Object used by the clients to create connection with the provider
    • Destination: Object that client uses to specify the message source and the destination.
JMS Messaging Models
  • Point To Point model
In this model producer creates and sends the message that will be consumed by a single consumer.Message destination is called queue.There is no timing dependencies.The receiver acknowledges the successful processing of the message.


  • Publish/Subscribe Model
In this, the message created and send by the producer will be received by all the clients who have subscribed to that destination. Message destination is called Topic.This have timing dependencies and the consumer should be active to consume the message.

Comments

Post a Comment

Popular posts from this blog

Transform values with a stream

The goal is to transform an array of numbers into a comma-delimited string using functional programming. The code snippet you provided has a minor issue: String.join(",", strings[0]) is incorrect because it tries to join a single element ( strings[0] ) rather than all elements in the strings array. Here's the corrected code for the transformValues method: import java.util.Arrays; class Answer {     // Change these boolean values to control whether you see      // the expected answer and/or hints.     static boolean showExpectedResult = true;     static boolean showHints = true;     // Transform an array of numbers into a comma-delimited list     // using functional programming.     static String transformValues(int[] numbers) {         // Convert the int array to a stream of integers         // Map each integer to its String representation         // ...
Read more

Collections Framework

 The Java Collections Framework provides a comprehensive set of interfaces, implementations, and algorithms to work with collections of objects in Java. It offers a unified architecture for representing and manipulating collections, making it easier to work with data structures in Java programs. The Collections Framework is a fundamental part of Java programming and is widely used in various applications ranging from simple data manipulation tasks to complex algorithms and data processing pipelines.  Key components of the Collections Framework: Interfaces Collection : The root interface of the Collections Framework hierarchy. Represents a group of objects, known as elements. Subinterfaces include List , Set , and Queue . List : Represents an ordered collection of elements where duplicate elements are allowed. Allows elements to be accessed and inserted by index. Implementations include ArrayList , LinkedList , and Vector . Set : Represents a collection of unique elements ...
Read more

Inspect a collection

Calculate the cart total  import java.util.List; import java.util.concurrent.atomic.AtomicReference; public class Main {     public static void main(String[] args) {         List<Item> items = List.of(             new Item("Item1", 10.0f, 2),             new Item("Item2", 5.0f, 4),             new Item("Item3", 20.0f, 1)         );         float total = getCartTotal(items);         System.out.println("Cart Total: " + total);  // Output: Cart Total: 60.0     }     static float getCartTotal(List<Item> items) {         AtomicReference<Float> total = new AtomicReference<>(0.0f);         items.forEach(item -> {             total.updateAndGet(v -> v + item.getQuantity() * item.getPrice())...
Read more