Package backtype.storm.messaging

Examples of backtype.storm.messaging.TaskMessage.message()

74
75
76
77
78
79
80
81
82
83
      LOG.warn("Received invalid message directed at port " + task
          + ". Dropping...");
      return;
    }

    queue.publish(message.message());

  }

}
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
    list.add(message);

    client.send(message);

    TaskMessage recv = server.recv(0);
    Assert.assertEquals(req_msg, new String(recv.message()));

    System.out.println("!!!!!!!!!!!!!!!!!!Test one time!!!!!!!!!!!!!!!!!");

    server.close();
    client.close();
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
    LOG.info("Client send data");
    client.send(message);

    TaskMessage recv = server.recv(0);
    Assert.assertEquals(req_msg, new String(recv.message()));

    client.close();
    server.close();
    context.term();
    System.out.println("!!!!!!!!!!End larget message test!!!!!!!!");
View Full Code Here
163
164
165
166
167
168
169
170
171
172
173
    LOG.info("Client send data");
    client.send(message);
    Thread.sleep(1000);

    TaskMessage recv = server.recv(0);
    Assert.assertEquals(req_msg, new String(recv.message()));

    server.close();
    client.close();
    context.term();
    System.out.println("!!!!!!!!!!End delay message test!!!!!!!!");
View Full Code Here
223
224
225
226
227
228
229
230
231
232
233
    DisruptorQueue recvQueue = new DisruptorQueue(
        "NettyUnitTest", ProducerType.SINGLE, 1024, waitStrategy);
    server.registerQueue(recvQueue);

    TaskMessage recv = server.recv(0);
    Assert.assertEquals(req_msg, new String(recv.message()));

    lock.lock();
    clientClose.signal();
    server.close();
    contextClose.await();
View Full Code Here
299
300
301
302
303
304
305
306
307
308
309
    for (int i = 1; i < Short.MAX_VALUE; i++) {
      TaskMessage message = server.recv(0);

      Assert.assertEquals(String.valueOf(i + base),
          new String(message.message()));

      if (i % 1000 == 0) {
        System.out.println("Receive " + message.task());
      }
    }
View Full Code Here
383
384
385
386
387
388
389
390
391
392
393
    for (int i = 1; i < Short.MAX_VALUE; i++) {
      TaskMessage message = server.recv(0);
      JStormUtils.sleepMs(1);

      Assert.assertEquals(String.valueOf(i + base),
          new String(message.message()));

      if (i % 1000 == 0) {
        System.out.println("Receive " + message.task());
      }
    }
View Full Code Here
456
457
458
459
460
461
462
463
464
465
466
    for (int i = 1; i < base; i++) {
      TaskMessage message = server.recv(0);
      JStormUtils.sleepMs(100);

      Assert.assertEquals(req_msg, new String(message.message()));
      System.out.println("receive " + message.task());

    }

    System.out.println("Finish Receive ");
View Full Code Here
537
538
539
540
541
542
543
544
545
546
547
        "NettyUnitTest", ProducerType.SINGLE, 1024, waitStrategy);
    server.registerQueue(recvQueue);

    TaskMessage recv = server.recv(0);
    System.out.println("Sever receive first");
    Assert.assertEquals(req_msg, new String(recv.message()));

    Thread.sleep(1000);

    TaskMessage recv2 = server.recv(0);
    System.out.println("Sever receive second");
View Full Code Here
543
544
545
546
547
548
549
550
551
552
553
    Thread.sleep(1000);

    TaskMessage recv2 = server.recv(0);
    System.out.println("Sever receive second");
    Assert.assertEquals(req_msg, new String(recv2.message()));

    lock.lock();
        clientClose.signal();
        server.close();
        contextClose.await();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.