public class MapSendTask extends AbstractSendTask implements ISendTask
Modifier and Type | Field and Description |
---|---|
protected java.lang.ClassLoader |
classloader
The classloader.
|
protected java.util.Map<java.lang.String,java.lang.Object> |
message
The message.
|
static byte |
MESSAGE_TYPE_MAP
Constant for string based map message.
|
protected jadex.bridge.service.types.message.MessageType |
messagetype
The message type.
|
acquired, codecids, codecs, data, encodingcontext, future, interest, nonfunc, prolog, receivers, transports, waiting
Constructor and Description |
---|
MapSendTask(java.util.Map<java.lang.String,java.lang.Object> message,
jadex.bridge.service.types.message.MessageType messagetype,
jadex.bridge.ITransportComponentIdentifier[] receivers,
ITransport[] transports,
jadex.bridge.service.types.message.ICodec[] codecs,
java.lang.ClassLoader classloader,
jadex.bridge.service.types.message.IEncodingContext encodingcontext)
Create a new manager send task.
|
Modifier and Type | Method and Description |
---|---|
static byte[] |
createData(java.lang.Object msg,
jadex.bridge.service.types.message.ICodec[] codecs,
java.lang.ClassLoader cl,
jadex.bridge.service.types.message.IEncodingContext context)
Create the data.
|
static byte[] |
createProlog(byte[] codecids)
Create prolog data.
|
static java.lang.Object |
decodeMessage(byte[] rawmsg,
java.util.Map<java.lang.Byte,jadex.bridge.service.types.message.ICodec> codecs,
java.lang.ClassLoader cl,
jadex.commons.transformation.binaryserializer.IErrorReporter rep)
Decode a message.
|
static byte[] |
encodeMessage(java.lang.Object msg,
jadex.bridge.service.types.message.ICodec[] codecs,
java.lang.ClassLoader cl,
jadex.bridge.service.types.message.IEncodingContext context)
Encode a message.
|
protected byte[] |
fetchData()
Provide the data as a byte array.
|
byte[] |
fetchProlog()
Get the prolog bytes.
|
static jadex.bridge.service.types.message.ICodec[] |
getCodecs(byte[] rawmsg,
java.util.Map<java.lang.Byte,jadex.bridge.service.types.message.ICodec> codecs)
Get the codecs that have been used for encoding the message.
|
java.lang.Object |
getMessage()
Get the message.
|
jadex.bridge.service.types.message.MessageType |
getMessageType()
Get the messagetype.
|
done, doSendMessage, encode, getData, getFuture, getNonFunctionalProperties, getProlog, getReceivers, getTransports, ready
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getData, getNonFunctionalProperties, getProlog, getReceivers, ready
public static final byte MESSAGE_TYPE_MAP
protected java.util.Map<java.lang.String,java.lang.Object> message
protected jadex.bridge.service.types.message.MessageType messagetype
protected java.lang.ClassLoader classloader
public MapSendTask(java.util.Map<java.lang.String,java.lang.Object> message, jadex.bridge.service.types.message.MessageType messagetype, jadex.bridge.ITransportComponentIdentifier[] receivers, ITransport[] transports, jadex.bridge.service.types.message.ICodec[] codecs, java.lang.ClassLoader classloader, jadex.bridge.service.types.message.IEncodingContext encodingcontext)
public java.lang.Object getMessage()
getMessage
in interface ISendTask
getMessage
in class AbstractSendTask
public jadex.bridge.service.types.message.MessageType getMessageType()
getMessageType
in class AbstractSendTask
protected byte[] fetchData()
fetchData
in class AbstractSendTask
public byte[] fetchProlog()
fetchProlog
in class AbstractSendTask
public static byte[] createProlog(byte[] codecids)
public static byte[] createData(java.lang.Object msg, jadex.bridge.service.types.message.ICodec[] codecs, java.lang.ClassLoader cl, jadex.bridge.service.types.message.IEncodingContext context)
public static byte[] encodeMessage(java.lang.Object msg, jadex.bridge.service.types.message.ICodec[] codecs, java.lang.ClassLoader cl, jadex.bridge.service.types.message.IEncodingContext context)
public static java.lang.Object decodeMessage(byte[] rawmsg, java.util.Map<java.lang.Byte,jadex.bridge.service.types.message.ICodec> codecs, java.lang.ClassLoader cl, jadex.commons.transformation.binaryserializer.IErrorReporter rep)
public static jadex.bridge.service.types.message.ICodec[] getCodecs(byte[] rawmsg, java.util.Map<java.lang.Byte,jadex.bridge.service.types.message.ICodec> codecs)