Shaker/Communication/ActiveMQ/EasyMQ/ActiveHutch.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace EasyMQ
{
    public sealed class ActiveHutch
    {
        public const string CLIENT_ID_KEY = "ActiveMQClientID";
        public IBus CreateBus(string ip,int port,ISerializer serializer)
        {
            string connectstring = $"tcp://{ip}:{port}?wireFormat.maxInactivityDuration=0&wireFormat.tightEncodingEnabled=false&timeout = 3000&nested.wireFormat.maxInactivityDuration=2000&connectionTimeout= 10000&keepAlive=true";
            if (serializer == null) throw new ArgumentNullException(nameof(serializer));
            ActiveMQBus bus = new ActiveMQBus(connectstring, serializer);
            return bus;
        }
        public static ActiveHutch Default { get; } = new ActiveHutch();
    }
}