Browse files

Use PUSH/PULL for throughput tests.

  • Loading branch information...
1 parent 70d0066 commit 3e4cc0acf13e8a3bb88df387969b290b07fa63d5 @jgoz jgoz committed Nov 14, 2012
Showing with 2 additions and 3 deletions.
  1. +1 −2 src/ZeroMQ.Perf.ThrLocal/Program.cs
  2. +1 −1 src/ZeroMQ.Perf.ThrRemote/Program.cs
View
3 src/ZeroMQ.Perf.ThrLocal/Program.cs
@@ -29,9 +29,8 @@ internal static int Main(string[] args)
// Initialize 0MQ infrastructure
using (ZmqContext ctx = ZmqContext.Create())
- using (ZmqSocket skt = ctx.CreateSocket(SocketType.SUB))
+ using (ZmqSocket skt = ctx.CreateSocket(SocketType.PULL))
{
- skt.SubscribeAll();
skt.Bind(address);
// Wait for the first message.
View
2 src/ZeroMQ.Perf.ThrRemote/Program.cs
@@ -27,7 +27,7 @@ internal static int Main(string[] args)
// Initialize 0MQ infrastructure
using (ZmqContext ctx = ZmqContext.Create())
- using (ZmqSocket skt = ctx.CreateSocket(SocketType.PUB))
+ using (ZmqSocket skt = ctx.CreateSocket(SocketType.PUSH))
{
skt.Connect(address);

0 comments on commit 3e4cc0a

Please sign in to comment.