Package org.drasyl.peer.connection.message

Class ApplicationMessage

java.lang.Object

org.drasyl.peer.connection.message.ApplicationMessage

All Implemented Interfaces:

Message, RequestMessage

public class ApplicationMessage
extends Object
implements RequestMessage

A message that is sent by an application running on drasyl.

Field Summary

Fields

Modifier and Type	Field	Description
static final Supplier<String>	defaultUserAgentGenerator
protected final Map<String,String>	headers
protected short	hopCount
protected final MessageId	id
protected final int	networkId
protected final byte[]	payload
protected final ProofOfWork	proofOfWork
protected final CompressedPublicKey	recipient
protected final CompressedPublicKey	sender
protected final String	userAgent
static Supplier<String>	userAgentGenerator

Constructor Summary

Constructors

Constructor	Description
ApplicationMessage(int networkId, CompressedPublicKey sender, ProofOfWork proofOfWork, CompressedPublicKey recipient, byte[] payload)	Creates a new message.
ApplicationMessage(int networkId, CompressedPublicKey sender, ProofOfWork proofOfWork, CompressedPublicKey recipient, Map<String,String> headers, byte[] payload)	Creates a new message.
ApplicationMessage(MessageId id, int networkId, String userAgent, CompressedPublicKey sender, ProofOfWork proofOfWork, CompressedPublicKey recipient, short hopCount, byte[] payload)
ApplicationMessage(MessageId id, int networkId, CompressedPublicKey sender, ProofOfWork proofOfWork, CompressedPublicKey recipient, short hopCount, byte[] payload)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
String	getHeader(String name)	Returns the value of header with name name, or null if this header does not exist.
Map<String,String>	getHeaders()
short	getHopCount()	Returns this message's hop count.
MessageId	getId()	Returns the unique id of this message.
int	getNetworkId()	Returns the network the sender belongs to.
byte[]	getPayload()
ProofOfWork	getProofOfWork()	Returns this message sender's proof of work.
CompressedPublicKey	getRecipient()	Returns this message's recipient.
CompressedPublicKey	getSender()	Returns this message's sender.
String	getUserAgent()	Returns the user agent of the sender's node.
int	hashCode()
void	incrementHopCount()	Increases the message's hop count.
io.netty.buffer.ByteBuf	payloadAsByteBuf()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.drasyl.peer.connection.message.Message

getHopCount, getId, getNetworkId, getProofOfWork, getRecipient, getSender, getUserAgent, incrementHopCount

Field Details

headers

protected final Map<String,String> headers

payload

protected final byte[] payload

defaultUserAgentGenerator

public static final Supplier<String> defaultUserAgentGenerator

userAgentGenerator

public static Supplier<String> userAgentGenerator

id

protected final MessageId id

userAgent

protected final String userAgent

networkId

protected final int networkId

sender

protected final CompressedPublicKey sender

proofOfWork

protected final ProofOfWork proofOfWork

recipient

protected final CompressedPublicKey recipient

hopCount

protected short hopCount

Constructor Details

ApplicationMessage

public ApplicationMessage(MessageId id,
 int networkId,
 String userAgent,
 CompressedPublicKey sender,
 ProofOfWork proofOfWork,
 CompressedPublicKey recipient,
 short hopCount,
 byte[] payload)

ApplicationMessage

public ApplicationMessage(MessageId id,
 int networkId,
 CompressedPublicKey sender,
 ProofOfWork proofOfWork,
 CompressedPublicKey recipient,
 short hopCount,
 byte[] payload)

ApplicationMessage

public ApplicationMessage(int networkId,
 CompressedPublicKey sender,
 ProofOfWork proofOfWork,
 CompressedPublicKey recipient,
 Map<String,String> headers,
 byte[] payload)

Creates a new message.

Parameters:

networkId - the network the sender belongs to

sender - the sender

proofOfWork - the sender's proof of work

recipient - the recipient

payload - the data to be sent

ApplicationMessage

public ApplicationMessage(int networkId,
 CompressedPublicKey sender,
 ProofOfWork proofOfWork,
 CompressedPublicKey recipient,
 byte[] payload)

Creates a new message.

Parameters:

networkId - the network the sender belongs to

sender - the sender

proofOfWork - the sender's proof of work

recipient - the recipient

payload - the data to be sent

Method Details

getHeaders

public Map<String,String> getHeaders()

getHeader

public String getHeader(String name)

Returns the value of header with name name, or null if this header does not exist. Returns byte[].class.getName() if the header does not contain a value for name = ObjectHolder.CLASS_KEY_NAME.

Returns:

value of header with name name, or null if this header does not exist

getPayload

public byte[] getPayload()

payloadAsByteBuf

public io.netty.buffer.ByteBuf payloadAsByteBuf()

Returns:

a ByteBuf that wraps the underling payload byte array

hashCode

public int hashCode()

equals

public boolean equals(Object o)

toString

public String toString()

Overrides:

toString in class Object

getId

public MessageId getId()

Description copied from interface: Message

Returns the unique id of this message. Each message generates a random id when it is created.

Specified by:

getId in interface Message

Returns:

the unique id of this message. Each message generates a random id when it is created.

getUserAgent

public String getUserAgent()

Description copied from interface: Message

Returns the user agent of the sender's node.

Specified by:

getUserAgent in interface Message

Returns:

the user agent of the sender's node.

getNetworkId

public int getNetworkId()

Description copied from interface: Message

Returns the network the sender belongs to.

Specified by:

getNetworkId in interface Message

Returns:

the network the sender belongs to

getSender

public CompressedPublicKey getSender()

Description copied from interface: Message

Returns this message's sender.

Specified by:

getSender in interface Message

Returns:

this message's sender.

getProofOfWork

public ProofOfWork getProofOfWork()

Description copied from interface: Message

Returns this message sender's proof of work.

Specified by:

getProofOfWork in interface Message

Returns:

this message sender's proof of work.

getRecipient

public CompressedPublicKey getRecipient()

Description copied from interface: Message

Returns this message's recipient.

Specified by:

getRecipient in interface Message

Returns:

this message's recipient.

getHopCount

public short getHopCount()

Description copied from interface: Message

Returns this message's hop count. Starts at 0 and is incremented every time it is sent. Once the message reaches the limit defined in config drasyl.message.hop-limit it will be dropped.

Specified by:

getHopCount in interface Message

Returns:

this message's hop count.

incrementHopCount

public void incrementHopCount()

Description copied from interface: Message

Increases the message's hop count.

Specified by:

incrementHopCount in interface Message