INNER CODE UNIT · C#

TestMessageSource

christopherread/Obvs · Obvs.ActiveMQ.Tests/TestMessageSource.cs:16

    public class TestMessageSource
    {
        private IConnection _connection;
        private ISession _session;
        private IMessageConsumer _consumer;
        private IMessageDeserializer<ITestMessage> _deserializer;
        private IObserver<ITestMessage> _observer;
        private IMessageSource<ITestMessage> _source;
        private IDestination _destination;
        private AcknowledgementMode _acknowledgementMode;
        private Lazy<IConnection> _lazyConnection;

        public interface ITestMessage : IMessage
        {
        }

        [XmlRoot]
        public class TestMessage : ITestMessage

View source record →