org.apache.reef.javabridge

Class ContextMessageBridge

java.lang.Object

org.apache.reef.javabridge.NativeBridge

org.apache.reef.javabridge.ContextMessageBridge

All Implemented Interfaces:

AutoCloseable, ContextMessage, Message, Identifiable, Numberable

public final class ContextMessageBridge
extends NativeBridge
implements ContextMessage

The Java-CLR bridge object for ContextMessage.

Constructor Summary

Constructors

Constructor and Description
ContextMessageBridge(ContextMessage contextMessage)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
byte[]	get() Message payload.
String	getId() Returns an identifier of this object.
String	getMessageSourceID()
long	getSequenceNumber()

Methods inherited from class org.apache.reef.javabridge.NativeBridge

onError

Methods inherited from class java.lang.Object

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

Constructor Detail

ContextMessageBridge

public ContextMessageBridge(ContextMessage contextMessage)

Method Detail

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

get

public byte[] get()

Description copied from interface: Message

Message payload.

Specified by:

get in interface ContextMessage

Specified by:

get in interface Message

Returns:

the message sent by the Context.

getId

public String getId()

Description copied from interface: Identifiable

Returns an identifier of this object.

Specified by:

getId in interface ContextMessage

Specified by:

getId in interface Identifiable

Returns:

the ID of the sending Context.

getMessageSourceID

public String getMessageSourceID()

Specified by:

getMessageSourceID in interface ContextMessage

Returns:

the ID of the ContextMessageSource that sent the message on the Context.

getSequenceNumber

public long getSequenceNumber()

Specified by:

getSequenceNumber in interface ContextMessage

Specified by:

getSequenceNumber in interface Numberable

Returns:

the sequence number of the message Terminology: a source sends a message to a target. Example sources are Tasks or Contexts. Example targets are Drivers. The method guarantees that sequence numbers increase strictly monotonically per message source. So numbers of messages from different sources should not be compared to each other. Clients of this method must not assume any particular method implementation because it may change in the future. The current implementation returns the timestamp of a heartbeat that contained the message. A heartbeat may contain several messages; all such message will get the same sequence number. A source can attach only one message to a single heartbeat, so the strict sequence number monotonicity per source is guaranteed.