net.i2p.router
public class OutNetMessage extends Object
Constructor and Description |
---|
OutNetMessage(RouterContext context) |
Modifier and Type | Method and Description |
---|---|
void |
beginPrepare() |
void |
beginSend() |
void |
beginTransmission() |
void |
discardData()
We've done what we need to do with the data from this message, though
we may keep the object around for a while to use its ID, jobs, etc.
|
boolean |
equals(Object obj) |
long |
getCreated() |
Exception |
getCreatedBy() |
long |
getExpiration()
Specify the # ms since the epoch after which if the message has not been
sent the OnFailedSend job should be fired and the message should be
removed from the pool.
|
Set |
getFailedTransports()
not thread safe - dont fail transports and iterate over this at the same time
|
long |
getLifetime()
time since the message was created
|
I2NPMessage |
getMessage()
Specifies the message to be sent
|
int |
getMessageData(byte[] outBuffer) |
long |
getMessageId() |
long |
getMessageSize() |
String |
getMessageType() |
int |
getMessageTypeId() |
Job |
getOnFailedReplyJob()
If the Message selector is specified but it doesn't find a reply before
its expiration passes, this job is enqueued.
|
Job |
getOnFailedSendJob()
If the router could not be reached or the expiration passed, this job
is enqueued.
|
ReplyJob |
getOnReplyJob()
If the MessageSelector detects a reply, this job is enqueued
|
Job |
getOnSendJob()
After the message is successfully passed to the router specified, the
given job is enqueued.
|
long |
getPreparationTime()
how long it took to prepare the i2np message for transmission (including serialization and transport layer encryption)
|
int |
getPriority()
Specify the priority of the message, where higher numbers are higher
priority.
|
int |
getQueueSize()
number of messages ahead of this one going to the targetted peer when it is first enqueued
|
MessageSelector |
getReplySelector()
Defines a MessageSelector to find a reply to this message.
|
long |
getSendBegin()
when did the sending process begin
|
long |
getSendTime()
time the transport tries to send the message (including any queueing)
|
RouterInfo |
getTarget()
Specifies the router to which the message should be delivered.
|
Long |
getTimestamp(String eventName)
Deprecated.
unused
|
Map<String,Long> |
getTimestamps()
Deprecated.
unused
|
long |
getTransmissionTime()
time during which the i2np message is actually in flight
|
int |
hashCode() |
void |
prepared() |
void |
prepared(Object buf) |
Object |
releasePreparationBuffer() |
void |
setExpiration(long expiration) |
void |
setMessage(I2NPMessage msg) |
void |
setOnFailedReplyJob(Job job) |
void |
setOnFailedSendJob(Job job) |
void |
setOnReplyJob(ReplyJob job) |
void |
setOnSendJob(Job job) |
void |
setPriority(int priority) |
void |
setQueueSize(int size) |
void |
setReplySelector(MessageSelector selector) |
void |
setTarget(RouterInfo target) |
long |
timestamp(String eventName)
Stamp the message's progress
|
String |
toString() |
void |
transportFailed(String transportStyle) |
public OutNetMessage(RouterContext context)
public long timestamp(String eventName)
eventName
- what occurredpublic Exception getCreatedBy()
public RouterInfo getTarget()
public void setTarget(RouterInfo target)
public I2NPMessage getMessage()
public void setMessage(I2NPMessage msg)
public String getMessageType()
public int getMessageTypeId()
public long getMessageId()
public long getMessageSize()
public int getMessageData(byte[] outBuffer)
public int getPriority()
public void setPriority(int priority)
public long getExpiration()
public void setExpiration(long expiration)
public Job getOnSendJob()
public void setOnSendJob(Job job)
public Job getOnFailedSendJob()
public void setOnFailedSendJob(Job job)
public ReplyJob getOnReplyJob()
public void setOnReplyJob(ReplyJob job)
public Job getOnFailedReplyJob()
public void setOnFailedReplyJob(Job job)
public MessageSelector getReplySelector()
public void setReplySelector(MessageSelector selector)
public void transportFailed(String transportStyle)
public Set getFailedTransports()
public long getSendBegin()
public void beginSend()
public void beginTransmission()
public void beginPrepare()
public void prepared()
public void prepared(Object buf)
public Object releasePreparationBuffer()
public long getCreated()
public long getLifetime()
public long getSendTime()
public long getTransmissionTime()
public long getPreparationTime()
public int getQueueSize()
public void setQueueSize(int size)
public void discardData()