Package com._1c.g5.v8.dt.internal.pm.connection.mmf

Class PmMessageReceiver

java.lang.Object

com._1c.g5.v8.dt.internal.pm.connection.mmf.PmMessageReceiver

All Implemented Interfaces:

Invalidatable, IpcChannelMessagesReceiver, UncaughtExceptionsGenerator, AutoCloseable

public class PmMessageReceiver
extends Object
implements IpcChannelMessagesReceiver

IpcChannelMessagesReceiver implementation.

Before nextMessage(), opposite side PmMessageSender must be created.

Constructor Summary

Constructors

Constructor	Description
PmMessageReceiver(PmTempFilesProvider pmFilesProvider)	Constructs new instance with given PmTempFilesProvider.

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	isValid()	Returns if this instance is not closed.
IpcMessage	nextMessage()	Waits for the next message sent by the other side to this channel and returns obtained message.
void	setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler handler)	Sets Thread.UncaughtExceptionHandler.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PmMessageReceiver

public PmMessageReceiver(PmTempFilesProvider pmFilesProvider)
                  throws IOException

Constructs new instance with given PmTempFilesProvider.

Parameters:

pmFilesProvider - given PmTempFilesProvider (not null)

Throws:

IOException - if construction failed due to I/O exception

Method Details

setUncaughtExceptionHandler

public void setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler handler)

Description copied from interface: UncaughtExceptionsGenerator

Sets Thread.UncaughtExceptionHandler.

Specified by:

setUncaughtExceptionHandler in interface UncaughtExceptionsGenerator

Parameters:

handler - given Thread.UncaughtExceptionHandler (not null)

nextMessage

public IpcMessage nextMessage()
                       throws InterruptedException,
IOException

Description copied from interface: IpcChannelMessagesReceiver

Waits for the next message sent by the other side to this channel and returns obtained message.

Specified by:

nextMessage in interface IpcChannelMessagesReceiver

Returns:

message sent by the other side to this channel (not null)

Throws:

InterruptedException - if waiting for message interrupted

IOException - if reading message failed

isValid

public boolean isValid()

Description copied from interface: Invalidatable

Returns if this instance is not closed.

Specified by:

isValid in interface Invalidatable

Returns:

true, if AutoCloseable.close() was not called, false otherwise

close

public void close()
           throws IOException

Description copied from interface: IpcChannelMessagesReceiver

Specified by:

close in interface AutoCloseable

Specified by:

close in interface IpcChannelMessagesReceiver

Throws:

IOException - if operation failed due to I/O exception