kimathie

import (
	"context"
	"time"
)

type Task[t any] func() (t, error)

type result[t any] struct {
	Error   error
	Success t

kimathie

try (ServerLocator locator = ActiveMQClient.createServerLocator("tcp://localhost:61617");
     ClientSessionFactory factory = locator.createSessionFactory();
     ClientSession session = factory.createSession(true, true, 0)) {

   String queueName = "router::hornetq";
   /**
    * In reference to the question
    * https://stackoverflow.com/questions/67606298/how-to-configure-an-activemq-artemis-queue-not-be-created-again
    * Just catch the Exception and handle it quietly and proceed executing the rest of the code.
    * Hopefully this wont be necessary in future versions.

kimathie

import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.TimeUnit;

/**
 * A timing wheel is a data structure that that provides the ability to manage
 * an event/action that should take place within a specified time window. The
 * idea is to have a time facility that schedules and manage timeouts
 * efficiently as described by George Varghese and Tony Lauck.
 *

kimathie

const fs = require('fs');
const http = require('http');
const path = require('path');
const process = require('process');
const server = http.createServer();
const corsHeaders = {
  "Access-Control-Allow-Origin": "*",
  "Access-Control-Allow-Methods": "*",
  "Access-Control-Max-Age": 2592000
};

kimathie

import java.math.BigInteger;
import java.security.MessageDigest;
import java.security.SecureRandom;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.util.Base64;

/**
 * Web Services Security (WS-Security) enhancement to SOAP messaging to provide
 * quality of protection through message integrity, message confidentiality, and

kimathie

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketException;
import java.net.SocketTimeoutException;

kimathie

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.DatagramChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.Iterator;

kimathie

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.ClosedChannelException;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.concurrent.ExecutorService;

kimathie

import java.math.BigInteger;
import java.nio.charset.StandardCharsets;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import javax.xml.bind.DatatypeConverter;

/**
 *