Skip to content

Commit 61808e2

Browse files
author
Ethan Hann
committed
Add MSMQ skeleton classes
1 parent cb7489a commit 61808e2

File tree

4 files changed

+52
-0
lines changed

4 files changed

+52
-0
lines changed

IntegrationEngine.Tests/Scheduler/EngineSchedulerTest.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
using IntegrationEngine.Scheduler;
2+
using NUnit.Framework;
23
using Quartz.Impl;
34
using System;
45
using System.Collections.Generic;
@@ -7,6 +8,7 @@ namespace IntegrationEngine.Tests.Scheduler
78
{
89
public class EngineSchedulerTest
910
{
11+
[Test]
1012
public void ShouldDeleteTrigger()
1113
{
1214
var jobType = typeof(IntegrationJobFixture);
Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
using System;
2+
using System.Collections.Generic;
3+
using System.Linq;
4+
using System.Text;
5+
using System.Threading.Tasks;
6+
7+
namespace IntegrationEngine.MessageQueue
8+
{
9+
public interface IMessageQueueListener
10+
{
11+
public void Listener();
12+
}
13+
}
Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
using System;
2+
using System.Collections.Generic;
3+
using System.Linq;
4+
using System.Text;
5+
using System.Threading.Tasks;
6+
7+
namespace IntegrationEngine.MessageQueue
8+
{
9+
public class MsmqClient : IMessageQueueClient
10+
{
11+
public void Publish<T>(T value)
12+
{
13+
throw new NotImplementedException();
14+
}
15+
16+
public bool IsServerAvailable()
17+
{
18+
throw new NotImplementedException();
19+
}
20+
}
21+
}
Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
using System;
2+
using System.Collections.Generic;
3+
using System.Linq;
4+
using System.Text;
5+
using System.Threading.Tasks;
6+
7+
namespace IntegrationEngine.MessageQueue
8+
{
9+
public class MsmqListener : IMessageQueueListener
10+
{
11+
void IMessageQueueListener.Listener()
12+
{
13+
throw new NotImplementedException();
14+
}
15+
}
16+
}

0 commit comments

Comments
 (0)