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

Class PmMessageSender

java.lang.Object

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

All Implemented Interfaces:

Invalidatable, IpcChannelMessagesSender, UncaughtExceptionsGenerator, AutoCloseable

public class PmMessageSender
extends Object
implements IpcChannelMessagesSender

IpcChannelMessagesSender implementation.

Before send(IpcMessage), opposite side PmMessageReceiver must be created.

Constructor Summary

Constructors

Constructor	Description
PmMessageSender(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.
void	send(IpcMessage message)	Sends given message to receiver on the other side of channel, waiting until it is received.
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

PmMessageSender

public PmMessageSender(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)

send

public void send(IpcMessage message)
          throws InterruptedException,
IOException

Description copied from interface: IpcChannelMessagesSender

Sends given message to receiver on the other side of channel, waiting until it is received.

Specified by:

send in interface IpcChannelMessagesSender

Parameters:

message - given message (not null)

Throws:

InterruptedException - if waiting for message receiving interrupted

IOException - if sending 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: IpcChannelMessagesSender

Specified by:

close in interface AutoCloseable

Specified by:

close in interface IpcChannelMessagesSender

Throws:

IOException - if operatin failed due to I/O exception