Examples of send()

Examples of kafka.javaapi.producer.Producer.send()

251
252
253
254
255
256
257
258
259
260
261
    Producer producer = new Producer(new ProducerConfig(props));
    try {
      for (byte[] message : monitorSet) {
        KeyedMessage keyedMessage = new KeyedMessage(
            "TrackingMonitoringEvent", message);
        producer.send(keyedMessage);
      }
    } catch (Exception e) {
      e.printStackTrace();
      System.out.println(topic + " issue sending tracking to "
                    + brokerList.toString());
View Full Code Here

Examples of kafka.producer.SimpleProducer.send()

80
81
82
83
84
85
86
87
88
89
90
      list.add(message);
    }
    // send events
    System.out.println(" send " + list.size() + " " + _topic
        + " count events to " + producerId);
    producer.send(_topic, new ByteBufferMessageSet(list));

    // close all producers
    for (SimpleProducer p : _producers) {
      p.close();
    }
View Full Code Here

Examples of lazyj.mail.Sendmail.send()

97
98
99
100
101
102
103
104
105
    mail.sSubject = m.sSubject!=null ? m.sSubject : this.sDefaultSubject;
   
    if (mail.sBody==null || mail.sSubject==null)
      return false;
   
    return sm.send(mail);
  }

}
View Full Code Here

Examples of lotus.domino.Document.send()

245
246
247
248
249
250
251
252
253
254
255
          doc.appendItemValue("Principal", from);
          doc.appendItemValue("iNetFrom", from);
          doc.appendItemValue("$iNetPrincipal", from);
        }
 
        doc.send(false);
        doc.recycle();
 
        // Set mime conversion back to what it was originally
      } finally {
        session.setConvertMIME(convertMime);
View Full Code Here

Examples of marauroa.functional.SimpleClient.send()

137
138
139
140
141
142
143
144
145
146
147
                   * Send an action to server.
                   */
                  RPAction action = new RPAction();
                  action.put("type", "chat");
                  action.put("text", "Hello world");
                  client.send(action);
                }

                if (rand.nextInt() % 1000 == 0) {
                  /*
                   * Randomly close the connection
View Full Code Here

Examples of me.taylorkelly.bigbrother.datablock.BBDataBlock.send()

24
25
26
27
28
29
30
31
32
33
34
    }

    public static void create(Location location, List<Block> blockList, String world) {
        for (Block block : blockList) {
            BBDataBlock dataBlock = new MiscExplosion(ENVIRONMENT, block, world);
            dataBlock.send();
            if (block.getType() == Material.TNT) {
                TNTLogger.log(ENVIRONMENT, block);
            }
        }
    }
View Full Code Here

Examples of me.taylorkelly.bigbrother.datablock.BrokenBlock.send()

56
57
58
59
60
61
62
63
64
65
66
            BBPlayerInfo pi = BBUsersTable.getInstance().getUserByName(player.getName());
            plugin.closeChestIfOpen(pi);
            if (BBSettings.blockBreak && pi.getWatched()) {
                Block block = event.getBlock();
                BrokenBlock dataBlock = new BrokenBlock(player.getName(), block, block.getWorld().getName());
                dataBlock.send();
            }
        }
    }

    @Override
View Full Code Here

Examples of me.taylorkelly.bigbrother.datablock.ButtonPress.send()

304
305
306
307
308
309
310
311
312
313
314
                        }
                        break;
                    case STONE_BUTTON:
                        if (BBSettings.buttonPress) {
                            ButtonPress buttonDataBlock = new ButtonPress(event.getPlayer().getName(), block, block.getWorld().getName());
                            buttonDataBlock.send();
                        }
                        break;
                    case CHEST:
                        if (BBSettings.chestChanges) {
                            BBDataBlock chestDataBlock = new ChestOpen(event.getPlayer().getName(), block, block.getWorld().getName());
View Full Code Here

Examples of me.taylorkelly.bigbrother.datablock.Chat.send()

122
123
124
125
126
127
128
129
130
131
132
        final Player player = event.getPlayer();
        BBPlayerInfo pi = BBUsersTable.getInstance().getUserByName(player.getName());
        plugin.closeChestIfOpen(pi);
        if (BBSettings.chat && pi.getWatched()) {
            Chat dataBlock = new Chat(player, event.getMessage(), player.getWorld().getName());
            dataBlock.send();
        }
    }
   
    @Override
    public void onPlayerPickupItem(PlayerPickupItemEvent event) {
View Full Code Here

Examples of me.taylorkelly.bigbrother.datablock.ChestOpen.send()

310
311
312
313
314
315
316
317
318
319
320
                        }
                        break;
                    case CHEST:
                        if (BBSettings.chestChanges) {
                            BBDataBlock chestDataBlock = new ChestOpen(event.getPlayer().getName(), block, block.getWorld().getName());
                            chestDataBlock.send();
                        }
                        break;
                    }
                    break;
                }
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.