INNER CODE UNIT · C#

TestMessagePublisher

christopherread/Obvs · Obvs.ActiveMQ.Tests/TestMessagePublisher.cs:18

    public class TestMessagePublisher
    {
        private IConnection _connection;
        private ISession _session;
        private IMessageProducer _producer;
        private IMessageSerializer _serializer;
        private IMessagePublisher<IMessage> _publisher;
        private IDestination _destination;
        private IBytesMessage _message;
        private Func<object, Dictionary<string, object>> _propertyProvider;
        private Lazy<IConnection> _lazyConnection;
        private readonly IScheduler _testScheduler = Scheduler.Immediate;

        private interface ITestMessage : IEvent
        {
        }

        private interface ITestMessage2 : IEvent

View source record →