@Test public void exit () throws Exception { val name = createName(); node = Nodes.singleNode(name, true); Mailbox mailbox1 = node.mailbox().build(); Mailbox mailbox2 = node.mailbox().build(); mailbox2.link(mailbox1.getPid()); SECONDS.sleep(1); mailbox2.exit("popa"); try { mailbox1.receive(); } catch (ReceivedExitException ex) { assertThat(ex.getFrom()) .isEqualTo(mailbox2.getPid()); assertThat(ex.getReason()) .isEqualTo(new ErlangAtom("popa")); return; } assertThat(false).isTrue(); }
public ModuleMailbox.NewMailboxBuilder mailbox () { return moduleMailbox.mailbox(); }
Node implements Closeable { public ModuleMailbox.NewMailboxBuilder mailbox () { return moduleMailbox.mailbox(); } }
Node implements Closeable { public ModuleMailbox.NewMailboxBuilder mailbox () { return moduleMailbox.mailbox(); } @Builder private  Node(@NonNull NodeDescriptor descriptor,
                @NonNull Meta meta,
                @NonNull EpmdClient epmd,
                int creation,
                @NonNull NodeConfig config
  ); }
Node implements Closeable { public ModuleMailbox.NewMailboxBuilder mailbox () { return moduleMailbox.mailbox(); } @Builder private  Node(@NonNull NodeDescriptor descriptor,
                @NonNull Meta meta,
                @NonNull EpmdClient epmd,
                int creation,
                @NonNull NodeConfig config
  ); RemoteNode lookup(String name); RemoteNode lookup(ErlangPid pid); RemoteNode lookup(NodeDescriptor nodeDescriptor); boolean ping(String name); boolean ping(NodeDescriptor nodeDescriptor); boolean ping(RemoteNode remote); ErlangReference newReference(); ModuleMailbox.NewMailboxBuilder mailbox(); boolean register(Mailbox mailbox, String name); void deregister(String name); Mailbox mailbox(String name); Mailbox mailbox(ErlangPid pid); void remove(Mailbox mailbox); void remove(String name); void remove(ErlangPid pid); Map<ErlangPid, Mailbox> mailboxes(); CompletableFuture<Connection> connectAsync(RemoteNode remote); Connection connect(RemoteNode remote); Connection connect(RemoteNode remote, long timeout, TimeUnit unit); boolean isAvailable(RemoteNode remote); @Override void close(); }
Node implements Closeable { public ModuleMailbox.NewMailboxBuilder mailbox () { return moduleMailbox.mailbox(); } @Builder private  Node(@NonNull NodeDescriptor descriptor,
                @NonNull Meta meta,
                @NonNull EpmdClient epmd,
                int creation,
                @NonNull NodeConfig config
  ); RemoteNode lookup(String name); RemoteNode lookup(ErlangPid pid); RemoteNode lookup(NodeDescriptor nodeDescriptor); boolean ping(String name); boolean ping(NodeDescriptor nodeDescriptor); boolean ping(RemoteNode remote); ErlangReference newReference(); ModuleMailbox.NewMailboxBuilder mailbox(); boolean register(Mailbox mailbox, String name); void deregister(String name); Mailbox mailbox(String name); Mailbox mailbox(ErlangPid pid); void remove(Mailbox mailbox); void remove(String name); void remove(ErlangPid pid); Map<ErlangPid, Mailbox> mailboxes(); CompletableFuture<Connection> connectAsync(RemoteNode remote); Connection connect(RemoteNode remote); Connection connect(RemoteNode remote, long timeout, TimeUnit unit); boolean isAvailable(RemoteNode remote); @Override void close();  }