Permalink
Browse files

fixing typos

git-svn-id: https://rhino-tools.svn.sourceforge.net/svnroot/rhino-tools/trunk@2122 079b0acf-d9fa-0310-9935-e5ade295c882
  • Loading branch information...
1 parent 5e984f2 commit baa3bcd1035a322a6c274a78d45f4aaace5498c4 ayenderahien committed Apr 4, 2009
@@ -8,7 +8,7 @@
namespace Rhino.Queues.Tests.Protocol
{
- public class CanSendAndRecieve : WithDebugging
+ public class CanSendAndReceive : WithDebugging
{
[Fact]
public void OneMessage()
@@ -17,7 +17,7 @@ public void OneMessage()
Message[] recievedMsgs = null;
var endPoint = new Endpoint("localhost", 23456);
- using (var reciever = new Reciever(new IPEndPoint(IPAddress.Loopback, 23456), messages =>
+ using (var reciever = new Receiver(new IPEndPoint(IPAddress.Loopback, 23456), messages =>
{
recievedMsgs = messages;
return MockRepository.GenerateStub<IMessageAcceptance>();
@@ -59,7 +59,7 @@ public void TwoMessagesInSeparateCalls()
var wait = new ManualResetEvent(false);
Message[] recievedMsgs = null;
- using (var reciever = new Reciever(new IPEndPoint(IPAddress.Loopback, 23456), messages =>
+ using (var reciever = new Receiver(new IPEndPoint(IPAddress.Loopback, 23456), messages =>
{
recievedMsgs = messages;
return MockRepository.GenerateStub<IMessageAcceptance>();
@@ -119,7 +119,7 @@ public void TwoMessagesInOneCall()
var wait = new ManualResetEvent(false);
Message[] recievedMsgs = null;
- using (var reciever = new Reciever(new IPEndPoint(IPAddress.Loopback, 23456), messages =>
+ using (var reciever = new Receiver(new IPEndPoint(IPAddress.Loopback, 23456), messages =>
{
recievedMsgs = messages;
return MockRepository.GenerateStub<IMessageAcceptance>();
@@ -25,14 +25,14 @@ public class RecieverFailure : WithDebugging, IDisposable
public RecieverFailure()
{
- logger = ((Logger)(LogManager.GetLogger(typeof(Reciever)).Logger));
+ logger = ((Logger)(LogManager.GetLogger(typeof(Receiver)).Logger));
logger.AddAppender(appender);
}
[Fact]
public void CanHandleClientConnectAndDisconnect()
{
- using (var reciever = new Reciever(endpointToListenTo, messages => null))
+ using (var reciever = new Receiver(endpointToListenTo, messages => null))
{
reciever.CompletedRecievingMessages += () => wait.Set();
reciever.Start();
@@ -56,7 +56,7 @@ public void CanHandleClientConnectAndDisconnect()
[Fact]
public void CanHandleClientSendingThreeBytesAndDisconnecting()
{
- using (var reciever = new Reciever(endpointToListenTo, messages => null))
+ using (var reciever = new Receiver(endpointToListenTo, messages => null))
{
reciever.CompletedRecievingMessages += () => wait.Set();
reciever.Start();
@@ -81,7 +81,7 @@ public void CanHandleClientSendingThreeBytesAndDisconnecting()
[Fact]
public void CanHandleClientSendingNegativeNumberForLength()
{
- using (var reciever = new Reciever(endpointToListenTo, messages => null))
+ using (var reciever = new Receiver(endpointToListenTo, messages => null))
{
reciever.CompletedRecievingMessages += () => wait.Set();
reciever.Start();
@@ -106,7 +106,7 @@ public void CanHandleClientSendingNegativeNumberForLength()
[Fact]
public void CanHandleClientSendingBadLengthOfData()
{
- using (var reciever = new Reciever(endpointToListenTo, messages => null))
+ using (var reciever = new Receiver(endpointToListenTo, messages => null))
{
reciever.CompletedRecievingMessages += () => wait.Set();
reciever.Start();
@@ -133,7 +133,7 @@ public void CanHandleClientSendingBadLengthOfData()
[Fact]
public void CanHandleClientSendingUnseriliazableData()
{
- using (var reciever = new Reciever(endpointToListenTo, messages => null))
+ using (var reciever = new Receiver(endpointToListenTo, messages => null))
{
reciever.CompletedRecievingMessages += () => wait.Set();
reciever.Start();
@@ -160,7 +160,7 @@ public void CanHandleClientSendingUnseriliazableData()
[Fact]
public void WillLetSenderKnowThatMessagesWereNotProcessed()
{
- using (var reciever = new Reciever(endpointToListenTo, messages =>
+ using (var reciever = new Receiver(endpointToListenTo, messages =>
{
throw new InvalidOperationException();
}))
@@ -189,7 +189,7 @@ public void WillLetSenderKnowThatMessagesWereNotProcessed()
[Fact]
public void WillLetSenderKnowThatMessagesWereSentToInvalidQueue()
{
- using (var reciever = new Reciever(endpointToListenTo, messages =>
+ using (var reciever = new Receiver(endpointToListenTo, messages =>
{
throw new QueueDoesNotExistsException();
}))
@@ -219,7 +219,7 @@ public void WillLetSenderKnowThatMessagesWereSentToInvalidQueue()
public void WillSendConfirmationForClient()
{
var acceptance = MockRepository.GenerateStub<IMessageAcceptance>();
- using (var reciever = new Reciever(endpointToListenTo, messages => acceptance))
+ using (var reciever = new Receiver(endpointToListenTo, messages => acceptance))
{
reciever.CompletedRecievingMessages += () => wait.Set();
reciever.Start();
@@ -246,7 +246,7 @@ public void WillSendConfirmationForClient()
public void WillCallAbortAcceptanceIfSenderDoesNotConfirm()
{
var acceptance = MockRepository.GenerateStub<IMessageAcceptance>();
- using (var reciever = new Reciever(endpointToListenTo, messages => acceptance))
+ using (var reciever = new Receiver(endpointToListenTo, messages => acceptance))
{
reciever.CompletedRecievingMessages += () => wait.Set();
reciever.Start();
@@ -275,7 +275,7 @@ public void WillCallAbortAcceptanceIfSenderDoesNotConfirm()
public void WillCallAbortAcceptanceIfSenderSendNonConfirmation()
{
var acceptance = MockRepository.GenerateStub<IMessageAcceptance>();
- using (var reciever = new Reciever(endpointToListenTo, messages => acceptance))
+ using (var reciever = new Receiver(endpointToListenTo, messages => acceptance))
{
reciever.CompletedRecievingMessages += () => wait.Set();
reciever.Start();
@@ -307,7 +307,7 @@ public void WillCallAbortAcceptanceIfSenderSendNonConfirmation()
public void WillCallCommitAcceptanceIfSenderSendConfirmation()
{
var acceptance = MockRepository.GenerateStub<IMessageAcceptance>();
- using (var reciever = new Reciever(endpointToListenTo, messages => acceptance))
+ using (var reciever = new Receiver(endpointToListenTo, messages => acceptance))
{
reciever.CompletedRecievingMessages += () => wait.Set();
reciever.Start();
@@ -340,7 +340,7 @@ public void WillTellSenderIfCommitFailed()
var acceptance = MockRepository.GenerateStub<IMessageAcceptance>();
acceptance.Stub(x => x.Commit()).Throw(new InvalidOperationException());
- using (var reciever = new Reciever(endpointToListenTo, messages => acceptance))
+ using (var reciever = new Receiver(endpointToListenTo, messages => acceptance))
{
reciever.CompletedRecievingMessages += () => wait.Set();
reciever.Start();
@@ -59,7 +59,7 @@
</ItemGroup>
<ItemGroup>
<Compile Include="Properties\AssemblyInfo.cs" />
- <Compile Include="Protocol\CanSendAndRecieve.cs" />
+ <Compile Include="Protocol\CanSendAndReceive.cs" />
<Compile Include="Protocol\RecieverFailure.cs" />
<Compile Include="Protocol\SendingFailure.cs" />
<Compile Include="Protocol\FakeReciever.cs" />
@@ -10,16 +10,16 @@
namespace Rhino.Queues.Protocol
{
- public class Reciever : IDisposable
+ public class Receiver : IDisposable
{
private readonly IPEndPoint endpointToListenTo;
private readonly Func<Message[], IMessageAcceptance> acceptMessages;
private readonly TcpListener listener;
- private readonly ILog logger = LogManager.GetLogger(typeof(Reciever));
+ private readonly ILog logger = LogManager.GetLogger(typeof(Receiver));
public event Action CompletedRecievingMessages;
- public Reciever(IPEndPoint endpointToListenTo, Func<Message[], IMessageAcceptance> acceptMessages)
+ public Receiver(IPEndPoint endpointToListenTo, Func<Message[], IMessageAcceptance> acceptMessages)
{
this.endpointToListenTo = endpointToListenTo;
this.acceptMessages = acceptMessages;
@@ -47,7 +47,7 @@ private void BeginAcceptTcpClientCallback(IAsyncResult result)
logger.DebugFormat("Accepting connection from {0}", client.Client.RemoteEndPoint);
var enumerator = new AsyncEnumerator(
- "Reciever from " + client.Client.RemoteEndPoint
+ "Receiver from " + client.Client.RemoteEndPoint
);
enumerator.BeginExecute(ProcessRequest(client, enumerator), ar =>
{
@@ -28,7 +28,7 @@ public class QueueManager : IDisposable
private readonly string path;
private readonly Timer purgeOldDataTimer;
private readonly QueueStorage queueStorage;
- private readonly Reciever reciever;
+ private readonly Receiver receiver;
private readonly Thread sendingThread;
private readonly QueuedMessagesSender queuedMessagesSender;
private readonly ILog logger = LogManager.GetLogger(typeof(QueueManager));
@@ -51,8 +51,8 @@ public QueueManager(IPEndPoint endpoint, string path)
queueStorage = new QueueStorage(path);
queueStorage.Initialize();
- reciever = new Reciever(endpoint, AcceptMessages);
- reciever.Start();
+ receiver = new Receiver(endpoint, AcceptMessages);
+ receiver.Start();
HandleRecovery();
@@ -155,7 +155,7 @@ public void Dispose()
queuedMessagesSender.Stop();
sendingThread.Join();
- reciever.Dispose();
+ receiver.Dispose();
while (currentlyInCriticalReceiveStatus > 0)
{
@@ -75,7 +75,7 @@
<Compile Include="Properties\AssemblyInfo.cs" />
<Compile Include="Protocol\ProtocolConstants.cs" />
<Compile Include="Protocol\IMessageAcceptance.cs" />
- <Compile Include="Protocol\Reciever.cs" />
+ <Compile Include="Protocol\Receiver.cs" />
<Compile Include="Protocol\Sender.cs" />
<Compile Include="Protocol\SerializationExtensions.cs" />
<Compile Include="Protocol\StreamUtil.cs" />

0 comments on commit baa3bcd

Please sign in to comment.