Delay By Connect + Formatter By Connect Integrations

Delay by Connect is a simple, lightweight and high-performance Java library for building non-blocking asynchronous applications. Delay by Connect uses a fluent interface to make writing asynchronous code in Java easier and more readable. It has the concept of operations and expressions where we can call methods on an instance of Operation class . All operations must return a Future object which represents the result of an async operation. A Future object provides two methods for the purpose of getting a result. get(. and isDone(. .

Formatter By Connect is a simple Java library for formatting data with the help of pattern and format string. The difference between Formatter By Connect and Simple DateFormat or Java MessageFormat is that it allows inputting pattern and format string separately, not together as "format.pattern" . It also supports multiline patterns and can be used as a template engine.

Integration of Delay By Connect and Formatter By Connect

Delay by Connect can be used to implement message queue. In order to implement this, first we need to create a message queue consumer by using Delay by Connect, here is our consumer implementation :

public class QueueConsumer implements Runnable { private static final String QUEUE_NAME = "queue"; private static final String QUEUE_TOKEN = "queueToken"; private static final String QUEUE_EXCEPTION = "queueException"; private static final String QUEUE_CONSUMER = "queueConsumer"; public void run(. { DelayQueue queue = new DelayQueue(Long.parseLong(System.getenv("QUEUE_PORT"))); // Get the queue token if (queue.getQueueToken(. != null. { System.out.println("Found queue token."); } else { throw new RuntimeException( "Failed to get the queue token"); } try { while (!Thread.currentThread(.isInterrupted(). { Consumer consumer = new Consumer(); consumer.setMessageListener(queue.newMessageListener()); consumer.start(); Thread.sleep(1000); } } catch (InterruptedException e. { Thread.currentThread(.interrupt(); throw new RuntimeException(e); } System.out.println("Queue exited normally."); } }

Then we need to call DelayByConnectConsumer.run(. method from the main method as below :

public static void main(String[] args. throws Exception { String msg = "Hello from Formatter By Connect!"; QueueConsumer consumer = new QueueConsumer(); consumer.run(); }

Benefits of Integration of Delay By Connect and Formatter By Connect

Integrating DelayByConnectConsumer in our application will give us many benefits like :

It will increase performance of our application because messages will be indexed in a queue and our application doesn't need to wait for the response of each message request instead it will just check the queue periodically until there is no more pending messages in the queue. It will improve scalability of our application because more instances of Delay By Connect can be added to handle more requests. Our application will be fault-tperant because messages in the queue can be recovered after an exception occurs (exception handling mechanism is out of scope for this article.

Reference . http://www.delayedbyconnect.org/docs/index.html

The process to integrate Delay By Connect and Formatter By Connect may seem complicated and intimidating. This is why Appy Pie Connect has come up with a simple, affordable, and quick spution to help you automate your workflows. Click on the button below to begin.