using CFX;
using CFX.Transport;

namespace Sln.Iot.CFX
{
    /// <summary>
    /// CFX接口连接类
    /// </summary>
    public class CFXConnect
    {
        public AmqpCFXEndpoint Endpoint;

        public CFXConnect()
        {
            OpenEndpoint();
        }

        public void OpenEndpoint()
        {
            try
            {
                Endpoint = new AmqpCFXEndpoint();

                Endpoint.Open("CFX.S00.OT23022701", new Uri("amqp://"));

                Endpoint.AddPublishChannel(new Uri("amqp://"), "eventAddress");
            }
            catch (Exception e)
            {

            }
        }
    }
}