Field Detail

• DEFAULT_WAIT

  public static final long DEFAULT_WAIT

  See Also:

  Constant Field Values

• DEFAULT_UNIT

  public static final TimeUnit DEFAULT_UNIT

Constructor Detail

• MessageXC

  public MessageXC(InputStream inStream,
                   OutputStream outStream,
                   TransceiverListener listener,
                   TransceiverExceptionListener listenerE)
            throws IOException

  Throws:

  IOException

• MessageXC

  public MessageXC(InputStream inStream,
                   OutputStream outStream,
                   TransceiverListener listener,
                   TransceiverExceptionListener listenerE,
                   long wait,
                   TimeUnit unit)
            throws IOException

  Throws:

  IOException

Method Detail

• getLastProcessID

  public long getLastProcessID()

• close

  public void close()

  Shutdown this MessageXC, closing the I/O streams as well.

• setListener

  public void setListener(TransceiverListener listener)

• join

  public boolean join()

• queueMessage

  public boolean queueMessage(ClusterMessage message)

• queueMessage

  public boolean queueMessage(MessageType type)

• queueMessage

  public boolean queueMessage(MessageType type,
                              Serializable o)

• getId

  public long getId()

• setId

  public void setId(long id)

• setHostname

  public void setHostname(String host)

• getHostname

  public String getHostname()

• getLocalPath

  public String getLocalPath(String remotePath)

• getRemotePath

  public String getRemotePath(String localPath)

• getLocalFile

  public File getLocalFile(File remoteFile)

• getRemoteFile

  public File getRemoteFile(File localFile)

• setFileSystemTranslator

  public void setFileSystemTranslator(FileTranslator ft)

• unsetFileSystemTranslation

  public void unsetFileSystemTranslation()

• addBottler

  public void addBottler(Bottler bottler)

• getBottlers

  public List<Bottler> getBottlers()