Erlang/OTP Forums

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.ericsson.otp.erlang.OtpNode;
import com.ericsson.otp.erlang.OtpMbox;
import com.ericsson.otp.erlang.OtpErlangAtom;
import com.ericsson.otp.erlang.OtpErlangPid;
import com.ericsson.otp.erlang.OtpErlangObject;
import com.ericsson.otp.erlang.OtpErlangString;
import com.ericsson.otp.erlang.OtpErlangTuple;

import java.io.IOException;


public class MboxWorker {

  // -------------------------------------- Constructor
  public MboxWorker(String nodeName, String mboxName) throws IOException {
    node = new OtpNode(nodeName);
    mbox = node.createMbox(mboxName);
  }

  // -------------------------------------- Constants
  private static final Logger logger  =
    LoggerFactory.getLogger(MboxWorker.class);

  // -------------------------------------- Static Variables

  // -------------------------------------- Variables
  OtpNode node;
  OtpMbox mbox = null;
  OtpErlangAtom _logAtom = new OtpErlangAtom("pn0000");
 
  // -------------------------------------- Protected Methods

  // -------------------------------------- Public Methods
 
  public void doService() throws Exception {
    try {
      OtpErlangObject o;
      OtpErlangTuple msg;
      OtpErlangPid from;
      OtpErlangAtom logAtom;
      OtpErlangString logstr;
     
      logger.debug("{} : waiting", mbox.getName());
      while (true) {
        try {
          o = mbox.receive();
          if (o instanceof OtpErlangTuple) {
            msg = (OtpErlangTuple) o;
            from = (OtpErlangPid) (msg.elementAt(0));
            logAtom = (OtpErlangAtom)(msg.elementAt(1));
            logstr = (OtpErlangString)(msg.elementAt(2));
           
            if (logAtom.equals(this._logAtom)) {
              logger.info(logstr.stringValue());
              logger.debug("{} : write a log", mbox.getName());
              mbox.send(from, msg.elementAt(3));
            }
            else {
              logger.warn("{} : Illegal Message received : From["
                  + from + "] logstr[" + logstr + "]", mbox.getName());
            }         
          }
        }
        catch (Exception e) {
          logger.error(e.getMessage());
          e.printStackTrace();
        }
        finally {
        }
      }
    }
    catch (Exception e) {
      throw e;
    }
    finally {
    }
  }
}

write_log(LogLine, Target) ->
    {Target, mboxName@nodeName} ! {self(), pn0000, LogLine, ok},

    receive
        ok ->
            ok;
        Error ->
            Error
    after 1500 ->
            false
    end.